Linux Audio

Check our new training course

Loading...
v3.1
 
  1/*
  2 * Copyright (C) Sistina Software, Inc.  1997-2003 All rights reserved.
  3 * Copyright (C) 2004-2006 Red Hat, Inc.  All rights reserved.
  4 *
  5 * This copyrighted material is made available to anyone wishing to use,
  6 * modify, copy, or redistribute it subject to the terms and conditions
  7 * of the GNU General Public License version 2.
  8 */
  9
 
 
 10#include <linux/spinlock.h>
 11#include <linux/completion.h>
 12#include <linux/buffer_head.h>
 13#include <linux/crc32.h>
 14#include <linux/gfs2_ondisk.h>
 15#include <asm/uaccess.h>
 
 16
 17#include "gfs2.h"
 18#include "incore.h"
 19#include "glock.h"
 
 
 
 
 
 
 20#include "util.h"
 21
 22struct kmem_cache *gfs2_glock_cachep __read_mostly;
 23struct kmem_cache *gfs2_glock_aspace_cachep __read_mostly;
 24struct kmem_cache *gfs2_inode_cachep __read_mostly;
 25struct kmem_cache *gfs2_bufdata_cachep __read_mostly;
 26struct kmem_cache *gfs2_rgrpd_cachep __read_mostly;
 27struct kmem_cache *gfs2_quotad_cachep __read_mostly;
 
 
 
 28
 29void gfs2_assert_i(struct gfs2_sbd *sdp)
 30{
 31	printk(KERN_EMERG "GFS2: fsid=%s: fatal assertion failed\n",
 32	       sdp->sd_fsname);
 33}
 34
 35int gfs2_lm_withdraw(struct gfs2_sbd *sdp, char *fmt, ...)
 
 
 
 
 
 
 
 
 
 36{
 37	struct lm_lockstruct *ls = &sdp->sd_lockstruct;
 38	const struct lm_lockops *lm = ls->ls_ops;
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 39	va_list args;
 40
 41	if (sdp->sd_args.ar_errors == GFS2_ERRORS_WITHDRAW &&
 42	    test_and_set_bit(SDF_SHUTDOWN, &sdp->sd_flags))
 43		return 0;
 44
 45	va_start(args, fmt);
 46	vprintk(fmt, args);
 
 
 47	va_end(args);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 48
 49	if (sdp->sd_args.ar_errors == GFS2_ERRORS_WITHDRAW) {
 50		fs_err(sdp, "about to withdraw this file system\n");
 51		BUG_ON(sdp->sd_args.ar_debug);
 52
 
 
 53		kobject_uevent(&sdp->sd_kobj, KOBJ_OFFLINE);
 54
 
 
 
 55		if (lm->lm_unmount) {
 56			fs_err(sdp, "telling LM to unmount\n");
 57			lm->lm_unmount(sdp);
 58		}
 59		fs_err(sdp, "withdrawn\n");
 
 60		dump_stack();
 
 
 
 61	}
 62
 63	if (sdp->sd_args.ar_errors == GFS2_ERRORS_PANIC)
 64		panic("GFS2: fsid=%s: panic requested.\n", sdp->sd_fsname);
 65
 66	return -1;
 67}
 68
 69/**
 70 * gfs2_assert_withdraw_i - Cause the machine to withdraw if @assertion is false
 71 * Returns: -1 if this call withdrew the machine,
 72 *          -2 if it was already withdrawn
 73 */
 74
 75int gfs2_assert_withdraw_i(struct gfs2_sbd *sdp, char *assertion,
 76			   const char *function, char *file, unsigned int line)
 77{
 78	int me;
 79	me = gfs2_lm_withdraw(sdp,
 80		"GFS2: fsid=%s: fatal: assertion \"%s\" failed\n"
 81		"GFS2: fsid=%s:   function = %s, file = %s, line = %u\n",
 82		sdp->sd_fsname, assertion,
 83		sdp->sd_fsname, function, file, line);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 84	dump_stack();
 85	return (me) ? -1 : -2;
 86}
 87
 88/**
 89 * gfs2_assert_warn_i - Print a message to the console if @assertion is false
 90 * Returns: -1 if we printed something
 91 *          -2 if we didn't
 92 */
 93
 94int gfs2_assert_warn_i(struct gfs2_sbd *sdp, char *assertion,
 95		       const char *function, char *file, unsigned int line)
 96{
 97	if (time_before(jiffies,
 98			sdp->sd_last_warning +
 99			gfs2_tune_get(sdp, gt_complain_secs) * HZ))
100		return -2;
101
102	if (sdp->sd_args.ar_errors == GFS2_ERRORS_WITHDRAW)
103		printk(KERN_WARNING
104		       "GFS2: fsid=%s: warning: assertion \"%s\" failed\n"
105		       "GFS2: fsid=%s:   function = %s, file = %s, line = %u\n",
106		       sdp->sd_fsname, assertion,
107		       sdp->sd_fsname, function, file, line);
108
109	if (sdp->sd_args.ar_debug)
110		BUG();
111	else
112		dump_stack();
113
114	if (sdp->sd_args.ar_errors == GFS2_ERRORS_PANIC)
115		panic("GFS2: fsid=%s: warning: assertion \"%s\" failed\n"
116		      "GFS2: fsid=%s:   function = %s, file = %s, line = %u\n",
117		      sdp->sd_fsname, assertion,
118		      sdp->sd_fsname, function, file, line);
119
120	sdp->sd_last_warning = jiffies;
121
122	return -1;
123}
124
125/**
126 * gfs2_consist_i - Flag a filesystem consistency error and withdraw
127 * Returns: -1 if this call withdrew the machine,
128 *          0 if it was already withdrawn
129 */
130
131int gfs2_consist_i(struct gfs2_sbd *sdp, int cluster_wide, const char *function,
132		   char *file, unsigned int line)
133{
134	int rv;
135	rv = gfs2_lm_withdraw(sdp,
136		"GFS2: fsid=%s: fatal: filesystem consistency error\n"
137		"GFS2: fsid=%s:   function = %s, file = %s, line = %u\n",
138		sdp->sd_fsname,
139		sdp->sd_fsname, function, file, line);
140	return rv;
141}
142
143/**
144 * gfs2_consist_inode_i - Flag an inode consistency error and withdraw
145 * Returns: -1 if this call withdrew the machine,
146 *          0 if it was already withdrawn
147 */
148
149int gfs2_consist_inode_i(struct gfs2_inode *ip, int cluster_wide,
150			 const char *function, char *file, unsigned int line)
151{
152	struct gfs2_sbd *sdp = GFS2_SB(&ip->i_inode);
153	int rv;
154	rv = gfs2_lm_withdraw(sdp,
155		"GFS2: fsid=%s: fatal: filesystem consistency error\n"
156		"GFS2: fsid=%s:   inode = %llu %llu\n"
157		"GFS2: fsid=%s:   function = %s, file = %s, line = %u\n",
158		sdp->sd_fsname,
159		sdp->sd_fsname, (unsigned long long)ip->i_no_formal_ino,
160		(unsigned long long)ip->i_no_addr,
161		sdp->sd_fsname, function, file, line);
162	return rv;
163}
164
165/**
166 * gfs2_consist_rgrpd_i - Flag a RG consistency error and withdraw
167 * Returns: -1 if this call withdrew the machine,
168 *          0 if it was already withdrawn
169 */
170
171int gfs2_consist_rgrpd_i(struct gfs2_rgrpd *rgd, int cluster_wide,
172			 const char *function, char *file, unsigned int line)
173{
174	struct gfs2_sbd *sdp = rgd->rd_sbd;
175	int rv;
176	rv = gfs2_lm_withdraw(sdp,
177		"GFS2: fsid=%s: fatal: filesystem consistency error\n"
178		"GFS2: fsid=%s:   RG = %llu\n"
179		"GFS2: fsid=%s:   function = %s, file = %s, line = %u\n",
180		sdp->sd_fsname,
181		sdp->sd_fsname, (unsigned long long)rgd->rd_addr,
182		sdp->sd_fsname, function, file, line);
183	return rv;
 
 
184}
185
186/**
187 * gfs2_meta_check_ii - Flag a magic number consistency error and withdraw
188 * Returns: -1 if this call withdrew the machine,
189 *          -2 if it was already withdrawn
190 */
191
192int gfs2_meta_check_ii(struct gfs2_sbd *sdp, struct buffer_head *bh,
193		       const char *type, const char *function, char *file,
194		       unsigned int line)
195{
196	int me;
197	me = gfs2_lm_withdraw(sdp,
198		"GFS2: fsid=%s: fatal: invalid metadata block\n"
199		"GFS2: fsid=%s:   bh = %llu (%s)\n"
200		"GFS2: fsid=%s:   function = %s, file = %s, line = %u\n",
201		sdp->sd_fsname,
202		sdp->sd_fsname, (unsigned long long)bh->b_blocknr, type,
203		sdp->sd_fsname, function, file, line);
 
204	return (me) ? -1 : -2;
205}
206
207/**
208 * gfs2_metatype_check_ii - Flag a metadata type consistency error and withdraw
209 * Returns: -1 if this call withdrew the machine,
210 *          -2 if it was already withdrawn
211 */
212
213int gfs2_metatype_check_ii(struct gfs2_sbd *sdp, struct buffer_head *bh,
214			   u16 type, u16 t, const char *function,
215			   char *file, unsigned int line)
216{
217	int me;
218	me = gfs2_lm_withdraw(sdp,
219		"GFS2: fsid=%s: fatal: invalid metadata block\n"
220		"GFS2: fsid=%s:   bh = %llu (type: exp=%u, found=%u)\n"
221		"GFS2: fsid=%s:   function = %s, file = %s, line = %u\n",
222		sdp->sd_fsname,
223		sdp->sd_fsname, (unsigned long long)bh->b_blocknr, type, t,
224		sdp->sd_fsname, function, file, line);
 
225	return (me) ? -1 : -2;
226}
227
228/**
229 * gfs2_io_error_i - Flag an I/O error and withdraw
230 * Returns: -1 if this call withdrew the machine,
231 *          0 if it was already withdrawn
232 */
233
234int gfs2_io_error_i(struct gfs2_sbd *sdp, const char *function, char *file,
235		    unsigned int line)
236{
237	int rv;
238	rv = gfs2_lm_withdraw(sdp,
239		"GFS2: fsid=%s: fatal: I/O error\n"
240		"GFS2: fsid=%s:   function = %s, file = %s, line = %u\n",
241		sdp->sd_fsname,
242		sdp->sd_fsname, function, file, line);
243	return rv;
244}
245
246/**
247 * gfs2_io_error_bh_i - Flag a buffer I/O error and withdraw
248 * Returns: -1 if this call withdrew the machine,
249 *          0 if it was already withdrawn
250 */
251
252int gfs2_io_error_bh_i(struct gfs2_sbd *sdp, struct buffer_head *bh,
253		       const char *function, char *file, unsigned int line)
254{
255	int rv;
256	rv = gfs2_lm_withdraw(sdp,
257		"GFS2: fsid=%s: fatal: I/O error\n"
258		"GFS2: fsid=%s:   block = %llu\n"
259		"GFS2: fsid=%s:   function = %s, file = %s, line = %u\n",
260		sdp->sd_fsname,
261		sdp->sd_fsname, (unsigned long long)bh->b_blocknr,
262		sdp->sd_fsname, function, file, line);
263	return rv;
264}
265
266void gfs2_icbit_munge(struct gfs2_sbd *sdp, unsigned char **bitmap,
267		      unsigned int bit, int new_value)
268{
269	unsigned int c, o, b = bit;
270	int old_value;
271
272	c = b / (8 * PAGE_SIZE);
273	b %= 8 * PAGE_SIZE;
274	o = b / 8;
275	b %= 8;
276
277	old_value = (bitmap[c][o] & (1 << b));
278	gfs2_assert_withdraw(sdp, !old_value != !new_value);
279
280	if (new_value)
281		bitmap[c][o] |= 1 << b;
282	else
283		bitmap[c][o] &= ~(1 << b);
284}
285
v5.14.15
  1// SPDX-License-Identifier: GPL-2.0-only
  2/*
  3 * Copyright (C) Sistina Software, Inc.  1997-2003 All rights reserved.
  4 * Copyright (C) 2004-2006 Red Hat, Inc.  All rights reserved.
 
 
 
 
  5 */
  6
  7#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
  8
  9#include <linux/spinlock.h>
 10#include <linux/completion.h>
 11#include <linux/buffer_head.h>
 12#include <linux/crc32.h>
 13#include <linux/gfs2_ondisk.h>
 14#include <linux/delay.h>
 15#include <linux/uaccess.h>
 16
 17#include "gfs2.h"
 18#include "incore.h"
 19#include "glock.h"
 20#include "glops.h"
 21#include "log.h"
 22#include "lops.h"
 23#include "recovery.h"
 24#include "rgrp.h"
 25#include "super.h"
 26#include "util.h"
 27
 28struct kmem_cache *gfs2_glock_cachep __read_mostly;
 29struct kmem_cache *gfs2_glock_aspace_cachep __read_mostly;
 30struct kmem_cache *gfs2_inode_cachep __read_mostly;
 31struct kmem_cache *gfs2_bufdata_cachep __read_mostly;
 32struct kmem_cache *gfs2_rgrpd_cachep __read_mostly;
 33struct kmem_cache *gfs2_quotad_cachep __read_mostly;
 34struct kmem_cache *gfs2_qadata_cachep __read_mostly;
 35struct kmem_cache *gfs2_trans_cachep __read_mostly;
 36mempool_t *gfs2_page_pool __read_mostly;
 37
 38void gfs2_assert_i(struct gfs2_sbd *sdp)
 39{
 40	fs_emerg(sdp, "fatal assertion failed\n");
 
 41}
 42
 43/**
 44 * check_journal_clean - Make sure a journal is clean for a spectator mount
 45 * @sdp: The GFS2 superblock
 46 * @jd: The journal descriptor
 47 * @verbose: Show more prints in the log
 48 *
 49 * Returns: 0 if the journal is clean or locked, else an error
 50 */
 51int check_journal_clean(struct gfs2_sbd *sdp, struct gfs2_jdesc *jd,
 52			bool verbose)
 53{
 54	int error;
 55	struct gfs2_holder j_gh;
 56	struct gfs2_log_header_host head;
 57	struct gfs2_inode *ip;
 58
 59	ip = GFS2_I(jd->jd_inode);
 60	error = gfs2_glock_nq_init(ip->i_gl, LM_ST_SHARED, LM_FLAG_NOEXP |
 61				   GL_EXACT | GL_NOCACHE, &j_gh);
 62	if (error) {
 63		if (verbose)
 64			fs_err(sdp, "Error %d locking journal for spectator "
 65			       "mount.\n", error);
 66		return -EPERM;
 67	}
 68	error = gfs2_jdesc_check(jd);
 69	if (error) {
 70		if (verbose)
 71			fs_err(sdp, "Error checking journal for spectator "
 72			       "mount.\n");
 73		goto out_unlock;
 74	}
 75	error = gfs2_find_jhead(jd, &head, false);
 76	if (error) {
 77		if (verbose)
 78			fs_err(sdp, "Error parsing journal for spectator "
 79			       "mount.\n");
 80		goto out_unlock;
 81	}
 82	if (!(head.lh_flags & GFS2_LOG_HEAD_UNMOUNT)) {
 83		error = -EPERM;
 84		if (verbose)
 85			fs_err(sdp, "jid=%u: Journal is dirty, so the first "
 86			       "mounter must not be a spectator.\n",
 87			       jd->jd_jid);
 88	}
 89
 90out_unlock:
 91	gfs2_glock_dq_uninit(&j_gh);
 92	return error;
 93}
 94
 95/**
 96 * gfs2_freeze_lock - hold the freeze glock
 97 * @sdp: the superblock
 98 * @freeze_gh: pointer to the requested holder
 99 * @caller_flags: any additional flags needed by the caller
100 */
101int gfs2_freeze_lock(struct gfs2_sbd *sdp, struct gfs2_holder *freeze_gh,
102		     int caller_flags)
103{
104	int flags = LM_FLAG_NOEXP | GL_EXACT | caller_flags;
105	int error;
106
107	error = gfs2_glock_nq_init(sdp->sd_freeze_gl, LM_ST_SHARED, flags,
108				   freeze_gh);
109	if (error && error != GLR_TRYFAILED)
110		fs_err(sdp, "can't lock the freeze lock: %d\n", error);
111	return error;
112}
113
114void gfs2_freeze_unlock(struct gfs2_holder *freeze_gh)
115{
116	if (gfs2_holder_initialized(freeze_gh))
117		gfs2_glock_dq_uninit(freeze_gh);
118}
119
120static void signal_our_withdraw(struct gfs2_sbd *sdp)
121{
122	struct gfs2_glock *live_gl = sdp->sd_live_gh.gh_gl;
123	struct inode *inode;
124	struct gfs2_inode *ip;
125	struct gfs2_glock *i_gl;
126	u64 no_formal_ino;
127	int log_write_allowed = test_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags);
128	int ret = 0;
129	int tries;
130
131	if (test_bit(SDF_NORECOVERY, &sdp->sd_flags) || !sdp->sd_jdesc)
132		return;
133
134	gfs2_ail_drain(sdp); /* frees all transactions */
135	inode = sdp->sd_jdesc->jd_inode;
136	ip = GFS2_I(inode);
137	i_gl = ip->i_gl;
138	no_formal_ino = ip->i_no_formal_ino;
139
140	/* Prevent any glock dq until withdraw recovery is complete */
141	set_bit(SDF_WITHDRAW_RECOVERY, &sdp->sd_flags);
142	/*
143	 * Don't tell dlm we're bailing until we have no more buffers in the
144	 * wind. If journal had an IO error, the log code should just purge
145	 * the outstanding buffers rather than submitting new IO. Making the
146	 * file system read-only will flush the journal, etc.
147	 *
148	 * During a normal unmount, gfs2_make_fs_ro calls gfs2_log_shutdown
149	 * which clears SDF_JOURNAL_LIVE. In a withdraw, we must not write
150	 * any UNMOUNT log header, so we can't call gfs2_log_shutdown, and
151	 * therefore we need to clear SDF_JOURNAL_LIVE manually.
152	 */
153	clear_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags);
154	if (!sb_rdonly(sdp->sd_vfs)) {
155		struct gfs2_holder freeze_gh;
156
157		gfs2_holder_mark_uninitialized(&freeze_gh);
158		if (sdp->sd_freeze_gl &&
159		    !gfs2_glock_is_locked_by_me(sdp->sd_freeze_gl)) {
160			ret = gfs2_freeze_lock(sdp, &freeze_gh,
161				       log_write_allowed ? 0 : LM_FLAG_TRY);
162			if (ret == GLR_TRYFAILED)
163				ret = 0;
164		}
165		if (!ret)
166			gfs2_make_fs_ro(sdp);
167		gfs2_freeze_unlock(&freeze_gh);
168	}
169
170	if (sdp->sd_lockstruct.ls_ops->lm_lock == NULL) { /* lock_nolock */
171		if (!ret)
172			ret = -EIO;
173		clear_bit(SDF_WITHDRAW_RECOVERY, &sdp->sd_flags);
174		goto skip_recovery;
175	}
176	/*
177	 * Drop the glock for our journal so another node can recover it.
178	 */
179	if (gfs2_holder_initialized(&sdp->sd_journal_gh)) {
180		gfs2_glock_dq_wait(&sdp->sd_journal_gh);
181		gfs2_holder_uninit(&sdp->sd_journal_gh);
182	}
183	sdp->sd_jinode_gh.gh_flags |= GL_NOCACHE;
184	gfs2_glock_dq(&sdp->sd_jinode_gh);
185	if (test_bit(SDF_FS_FROZEN, &sdp->sd_flags)) {
186		/* Make sure gfs2_unfreeze works if partially-frozen */
187		flush_work(&sdp->sd_freeze_work);
188		atomic_set(&sdp->sd_freeze_state, SFS_FROZEN);
189		thaw_super(sdp->sd_vfs);
190	} else {
191		wait_on_bit(&i_gl->gl_flags, GLF_DEMOTE,
192			    TASK_UNINTERRUPTIBLE);
193	}
194
195	/*
196	 * holder_uninit to force glock_put, to force dlm to let go
197	 */
198	gfs2_holder_uninit(&sdp->sd_jinode_gh);
199
200	/*
201	 * Note: We need to be careful here:
202	 * Our iput of jd_inode will evict it. The evict will dequeue its
203	 * glock, but the glock dq will wait for the withdraw unless we have
204	 * exception code in glock_dq.
205	 */
206	iput(inode);
207	/*
208	 * Wait until the journal inode's glock is freed. This allows try locks
209	 * on other nodes to be successful, otherwise we remain the owner of
210	 * the glock as far as dlm is concerned.
211	 */
212	if (i_gl->gl_ops->go_free) {
213		set_bit(GLF_FREEING, &i_gl->gl_flags);
214		wait_on_bit(&i_gl->gl_flags, GLF_FREEING, TASK_UNINTERRUPTIBLE);
215	}
216
217	/*
218	 * Dequeue the "live" glock, but keep a reference so it's never freed.
219	 */
220	gfs2_glock_hold(live_gl);
221	gfs2_glock_dq_wait(&sdp->sd_live_gh);
222	/*
223	 * We enqueue the "live" glock in EX so that all other nodes
224	 * get a demote request and act on it. We don't really want the
225	 * lock in EX, so we send a "try" lock with 1CB to produce a callback.
226	 */
227	fs_warn(sdp, "Requesting recovery of jid %d.\n",
228		sdp->sd_lockstruct.ls_jid);
229	gfs2_holder_reinit(LM_ST_EXCLUSIVE, LM_FLAG_TRY_1CB | LM_FLAG_NOEXP,
230			   &sdp->sd_live_gh);
231	msleep(GL_GLOCK_MAX_HOLD);
232	/*
233	 * This will likely fail in a cluster, but succeed standalone:
234	 */
235	ret = gfs2_glock_nq(&sdp->sd_live_gh);
236
237	/*
238	 * If we actually got the "live" lock in EX mode, there are no other
239	 * nodes available to replay our journal. So we try to replay it
240	 * ourselves. We hold the "live" glock to prevent other mounters
241	 * during recovery, then just dequeue it and reacquire it in our
242	 * normal SH mode. Just in case the problem that caused us to
243	 * withdraw prevents us from recovering our journal (e.g. io errors
244	 * and such) we still check if the journal is clean before proceeding
245	 * but we may wait forever until another mounter does the recovery.
246	 */
247	if (ret == 0) {
248		fs_warn(sdp, "No other mounters found. Trying to recover our "
249			"own journal jid %d.\n", sdp->sd_lockstruct.ls_jid);
250		if (gfs2_recover_journal(sdp->sd_jdesc, 1))
251			fs_warn(sdp, "Unable to recover our journal jid %d.\n",
252				sdp->sd_lockstruct.ls_jid);
253		gfs2_glock_dq_wait(&sdp->sd_live_gh);
254		gfs2_holder_reinit(LM_ST_SHARED, LM_FLAG_NOEXP | GL_EXACT,
255				   &sdp->sd_live_gh);
256		gfs2_glock_nq(&sdp->sd_live_gh);
257	}
258
259	gfs2_glock_queue_put(live_gl); /* drop extra reference we acquired */
260	clear_bit(SDF_WITHDRAW_RECOVERY, &sdp->sd_flags);
261
262	/*
263	 * At this point our journal is evicted, so we need to get a new inode
264	 * for it. Once done, we need to call gfs2_find_jhead which
265	 * calls gfs2_map_journal_extents to map it for us again.
266	 *
267	 * Note that we don't really want it to look up a FREE block. The
268	 * GFS2_BLKST_FREE simply overrides a block check in gfs2_inode_lookup
269	 * which would otherwise fail because it requires grabbing an rgrp
270	 * glock, which would fail with -EIO because we're withdrawing.
271	 */
272	inode = gfs2_inode_lookup(sdp->sd_vfs, DT_UNKNOWN,
273				  sdp->sd_jdesc->jd_no_addr, no_formal_ino,
274				  GFS2_BLKST_FREE);
275	if (IS_ERR(inode)) {
276		fs_warn(sdp, "Reprocessing of jid %d failed with %ld.\n",
277			sdp->sd_lockstruct.ls_jid, PTR_ERR(inode));
278		goto skip_recovery;
279	}
280	sdp->sd_jdesc->jd_inode = inode;
281
282	/*
283	 * Now wait until recovery is complete.
284	 */
285	for (tries = 0; tries < 10; tries++) {
286		ret = check_journal_clean(sdp, sdp->sd_jdesc, false);
287		if (!ret)
288			break;
289		msleep(HZ);
290		fs_warn(sdp, "Waiting for journal recovery jid %d.\n",
291			sdp->sd_lockstruct.ls_jid);
292	}
293skip_recovery:
294	if (!ret)
295		fs_warn(sdp, "Journal recovery complete for jid %d.\n",
296			sdp->sd_lockstruct.ls_jid);
297	else
298		fs_warn(sdp, "Journal recovery skipped for %d until next "
299			"mount.\n", sdp->sd_lockstruct.ls_jid);
300	fs_warn(sdp, "Glock dequeues delayed: %lu\n", sdp->sd_glock_dqs_held);
301	sdp->sd_glock_dqs_held = 0;
302	wake_up_bit(&sdp->sd_flags, SDF_WITHDRAW_RECOVERY);
303}
304
305void gfs2_lm(struct gfs2_sbd *sdp, const char *fmt, ...)
306{
307	struct va_format vaf;
308	va_list args;
309
310	if (sdp->sd_args.ar_errors == GFS2_ERRORS_WITHDRAW &&
311	    test_bit(SDF_WITHDRAWN, &sdp->sd_flags))
312		return;
313
314	va_start(args, fmt);
315	vaf.fmt = fmt;
316	vaf.va = &args;
317	fs_err(sdp, "%pV", &vaf);
318	va_end(args);
319}
320
321int gfs2_withdraw(struct gfs2_sbd *sdp)
322{
323	struct lm_lockstruct *ls = &sdp->sd_lockstruct;
324	const struct lm_lockops *lm = ls->ls_ops;
325
326	if (sdp->sd_args.ar_errors == GFS2_ERRORS_WITHDRAW &&
327	    test_and_set_bit(SDF_WITHDRAWN, &sdp->sd_flags)) {
328		if (!test_bit(SDF_WITHDRAW_IN_PROG, &sdp->sd_flags))
329			return -1;
330
331		wait_on_bit(&sdp->sd_flags, SDF_WITHDRAW_IN_PROG,
332			    TASK_UNINTERRUPTIBLE);
333		return -1;
334	}
335
336	set_bit(SDF_WITHDRAW_IN_PROG, &sdp->sd_flags);
337
338	if (sdp->sd_args.ar_errors == GFS2_ERRORS_WITHDRAW) {
339		fs_err(sdp, "about to withdraw this file system\n");
340		BUG_ON(sdp->sd_args.ar_debug);
341
342		signal_our_withdraw(sdp);
343
344		kobject_uevent(&sdp->sd_kobj, KOBJ_OFFLINE);
345
346		if (!strcmp(sdp->sd_lockstruct.ls_ops->lm_proto_name, "lock_dlm"))
347			wait_for_completion(&sdp->sd_wdack);
348
349		if (lm->lm_unmount) {
350			fs_err(sdp, "telling LM to unmount\n");
351			lm->lm_unmount(sdp);
352		}
353		set_bit(SDF_SKIP_DLM_UNLOCK, &sdp->sd_flags);
354		fs_err(sdp, "File system withdrawn\n");
355		dump_stack();
356		clear_bit(SDF_WITHDRAW_IN_PROG, &sdp->sd_flags);
357		smp_mb__after_atomic();
358		wake_up_bit(&sdp->sd_flags, SDF_WITHDRAW_IN_PROG);
359	}
360
361	if (sdp->sd_args.ar_errors == GFS2_ERRORS_PANIC)
362		panic("GFS2: fsid=%s: panic requested\n", sdp->sd_fsname);
363
364	return -1;
365}
366
367/*
368 * gfs2_assert_withdraw_i - Cause the machine to withdraw if @assertion is false
 
 
369 */
370
371void gfs2_assert_withdraw_i(struct gfs2_sbd *sdp, char *assertion,
372			    const char *function, char *file, unsigned int line,
373			    bool delayed)
374{
375	if (gfs2_withdrawn(sdp))
376		return;
377
378	fs_err(sdp,
379	       "fatal: assertion \"%s\" failed\n"
380	       "   function = %s, file = %s, line = %u\n",
381	       assertion, function, file, line);
382
383	/*
384	 * If errors=panic was specified on mount, it won't help to delay the
385	 * withdraw.
386	 */
387	if (sdp->sd_args.ar_errors == GFS2_ERRORS_PANIC)
388		delayed = false;
389
390	if (delayed)
391		gfs2_withdraw_delayed(sdp);
392	else
393		gfs2_withdraw(sdp);
394	dump_stack();
 
395}
396
397/*
398 * gfs2_assert_warn_i - Print a message to the console if @assertion is false
 
 
399 */
400
401void gfs2_assert_warn_i(struct gfs2_sbd *sdp, char *assertion,
402			const char *function, char *file, unsigned int line)
403{
404	if (time_before(jiffies,
405			sdp->sd_last_warning +
406			gfs2_tune_get(sdp, gt_complain_secs) * HZ))
407		return;
408
409	if (sdp->sd_args.ar_errors == GFS2_ERRORS_WITHDRAW)
410		fs_warn(sdp, "warning: assertion \"%s\" failed at function = %s, file = %s, line = %u\n",
411			assertion, function, file, line);
 
 
 
412
413	if (sdp->sd_args.ar_debug)
414		BUG();
415	else
416		dump_stack();
417
418	if (sdp->sd_args.ar_errors == GFS2_ERRORS_PANIC)
419		panic("GFS2: fsid=%s: warning: assertion \"%s\" failed\n"
420		      "GFS2: fsid=%s:   function = %s, file = %s, line = %u\n",
421		      sdp->sd_fsname, assertion,
422		      sdp->sd_fsname, function, file, line);
423
424	sdp->sd_last_warning = jiffies;
 
 
425}
426
427/*
428 * gfs2_consist_i - Flag a filesystem consistency error and withdraw
 
 
429 */
430
431void gfs2_consist_i(struct gfs2_sbd *sdp, const char *function,
432		    char *file, unsigned int line)
433{
434	gfs2_lm(sdp,
435		"fatal: filesystem consistency error - function = %s, file = %s, line = %u\n",
436		function, file, line);
437	gfs2_withdraw(sdp);
 
 
 
438}
439
440/*
441 * gfs2_consist_inode_i - Flag an inode consistency error and withdraw
 
 
442 */
443
444void gfs2_consist_inode_i(struct gfs2_inode *ip,
445			  const char *function, char *file, unsigned int line)
446{
447	struct gfs2_sbd *sdp = GFS2_SB(&ip->i_inode);
448
449	gfs2_lm(sdp,
450		"fatal: filesystem consistency error\n"
451		"  inode = %llu %llu\n"
452		"  function = %s, file = %s, line = %u\n",
453		(unsigned long long)ip->i_no_formal_ino,
 
454		(unsigned long long)ip->i_no_addr,
455		function, file, line);
456	gfs2_withdraw(sdp);
457}
458
459/*
460 * gfs2_consist_rgrpd_i - Flag a RG consistency error and withdraw
 
 
461 */
462
463void gfs2_consist_rgrpd_i(struct gfs2_rgrpd *rgd,
464			  const char *function, char *file, unsigned int line)
465{
466	struct gfs2_sbd *sdp = rgd->rd_sbd;
467	char fs_id_buf[sizeof(sdp->sd_fsname) + 7];
468
469	sprintf(fs_id_buf, "fsid=%s: ", sdp->sd_fsname);
470	gfs2_rgrp_dump(NULL, rgd, fs_id_buf);
471	gfs2_lm(sdp,
472		"fatal: filesystem consistency error\n"
473		"  RG = %llu\n"
474		"  function = %s, file = %s, line = %u\n",
475		(unsigned long long)rgd->rd_addr,
476		function, file, line);
477	gfs2_withdraw(sdp);
478}
479
480/*
481 * gfs2_meta_check_ii - Flag a magic number consistency error and withdraw
482 * Returns: -1 if this call withdrew the machine,
483 *          -2 if it was already withdrawn
484 */
485
486int gfs2_meta_check_ii(struct gfs2_sbd *sdp, struct buffer_head *bh,
487		       const char *type, const char *function, char *file,
488		       unsigned int line)
489{
490	int me;
491
492	gfs2_lm(sdp,
493		"fatal: invalid metadata block\n"
494		"  bh = %llu (%s)\n"
495		"  function = %s, file = %s, line = %u\n",
496		(unsigned long long)bh->b_blocknr, type,
497		function, file, line);
498	me = gfs2_withdraw(sdp);
499	return (me) ? -1 : -2;
500}
501
502/*
503 * gfs2_metatype_check_ii - Flag a metadata type consistency error and withdraw
504 * Returns: -1 if this call withdrew the machine,
505 *          -2 if it was already withdrawn
506 */
507
508int gfs2_metatype_check_ii(struct gfs2_sbd *sdp, struct buffer_head *bh,
509			   u16 type, u16 t, const char *function,
510			   char *file, unsigned int line)
511{
512	int me;
513
514	gfs2_lm(sdp,
515		"fatal: invalid metadata block\n"
516		"  bh = %llu (type: exp=%u, found=%u)\n"
517		"  function = %s, file = %s, line = %u\n",
518		(unsigned long long)bh->b_blocknr, type, t,
519		function, file, line);
520	me = gfs2_withdraw(sdp);
521	return (me) ? -1 : -2;
522}
523
524/*
525 * gfs2_io_error_i - Flag an I/O error and withdraw
526 * Returns: -1 if this call withdrew the machine,
527 *          0 if it was already withdrawn
528 */
529
530int gfs2_io_error_i(struct gfs2_sbd *sdp, const char *function, char *file,
531		    unsigned int line)
532{
533	gfs2_lm(sdp,
534		"fatal: I/O error\n"
535		"  function = %s, file = %s, line = %u\n",
536		function, file, line);
537	return gfs2_withdraw(sdp);
 
 
538}
539
540/*
541 * gfs2_io_error_bh_i - Flag a buffer I/O error
542 * @withdraw: withdraw the filesystem
 
543 */
544
545void gfs2_io_error_bh_i(struct gfs2_sbd *sdp, struct buffer_head *bh,
546			const char *function, char *file, unsigned int line,
547			bool withdraw)
548{
549	if (gfs2_withdrawn(sdp))
550		return;
551
552	fs_err(sdp, "fatal: I/O error\n"
553	       "  block = %llu\n"
554	       "  function = %s, file = %s, line = %u\n",
555	       (unsigned long long)bh->b_blocknr, function, file, line);
556	if (withdraw)
557		gfs2_withdraw(sdp);
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
558}
559