[people/ms/linux.git] / fs / gfs2 / glops.c

/*
 * Copyright (C) Sistina Software, Inc.  1997-2003 All rights reserved.
 * Copyright (C) 2004-2008 Red Hat, Inc.  All rights reserved.
 *
 * This copyrighted material is made available to anyone wishing to use,
 * modify, copy, or redistribute it subject to the terms and conditions
 * of the GNU General Public License version 2.
 */

#include <linux/slab.h>
#include <linux/spinlock.h>
#include <linux/completion.h>
#include <linux/buffer_head.h>
#include <linux/gfs2_ondisk.h>
#include <linux/lm_interface.h>
#include <linux/bio.h>

#include "gfs2.h"
#include "incore.h"
#include "bmap.h"
#include "glock.h"
#include "glops.h"
#include "inode.h"
#include "log.h"
#include "meta_io.h"
#include "recovery.h"
#include "rgrp.h"
#include "util.h"
#include "trans.h"

/**
 * ail_empty_gl - remove all buffers for a given lock from the AIL
 * @gl: the glock
 *
 * None of the buffers should be dirty, locked, or pinned.
 */

static void gfs2_ail_empty_gl(struct gfs2_glock *gl)
{
	struct gfs2_sbd *sdp = gl->gl_sbd;
	unsigned int blocks;
	struct list_head *head = &gl->gl_ail_list;
	struct gfs2_bufdata *bd;
	struct buffer_head *bh;
	int error;

	blocks = atomic_read(&gl->gl_ail_count);
	if (!blocks)
		return;

	error = gfs2_trans_begin(sdp, 0, blocks);
	if (gfs2_assert_withdraw(sdp, !error))
		return;

	gfs2_log_lock(sdp);
	while (!list_empty(head)) {
		bd = list_entry(head->next, struct gfs2_bufdata,
				bd_ail_gl_list);
		bh = bd->bd_bh;
		gfs2_remove_from_ail(bd);
		bd->bd_bh = NULL;
		bh->b_private = NULL;
		bd->bd_blkno = bh->b_blocknr;
		gfs2_assert_withdraw(sdp, !buffer_busy(bh));
		gfs2_trans_add_revoke(sdp, bd);
	}
	gfs2_assert_withdraw(sdp, !atomic_read(&gl->gl_ail_count));
	gfs2_log_unlock(sdp);

	gfs2_trans_end(sdp);
	gfs2_log_flush(sdp, NULL);
}

/**
 * gfs2_pte_inval - Sync and invalidate all PTEs associated with a glock
 * @gl: the glock
 *
 */

static void gfs2_pte_inval(struct gfs2_glock *gl)
{
	struct gfs2_inode *ip;
	struct inode *inode;

	ip = gl->gl_object;
	inode = &ip->i_inode;
	if (!ip || !S_ISREG(inode->i_mode))
		return;

	unmap_shared_mapping_range(inode->i_mapping, 0, 0);
	if (test_bit(GIF_SW_PAGED, &ip->i_flags))
		set_bit(GLF_DIRTY, &gl->gl_flags);

}

/**
 * meta_go_sync - sync out the metadata for this glock
 * @gl: the glock
 *
 * Called when demoting or unlocking an EX glock.  We must flush
 * to disk all dirty buffers/pages relating to this glock, and must not
 * not return to caller to demote/unlock the glock until I/O is complete.
 */

static void meta_go_sync(struct gfs2_glock *gl)
{
	if (gl->gl_state != LM_ST_EXCLUSIVE)
		return;

	if (test_and_clear_bit(GLF_DIRTY, &gl->gl_flags)) {
		gfs2_log_flush(gl->gl_sbd, gl);
		gfs2_meta_sync(gl);
		gfs2_ail_empty_gl(gl);
	}
}

/**
 * meta_go_inval - invalidate the metadata for this glock
 * @gl: the glock
 * @flags:
 *
 */

static void meta_go_inval(struct gfs2_glock *gl, int flags)
{
	if (!(flags & DIO_METADATA))
		return;

	gfs2_meta_inval(gl);
	if (gl->gl_object == GFS2_I(gl->gl_sbd->sd_rindex))
		gl->gl_sbd->sd_rindex_uptodate = 0;
	else if (gl->gl_ops == &gfs2_rgrp_glops && gl->gl_object) {
		struct gfs2_rgrpd *rgd = (struct gfs2_rgrpd *)gl->gl_object;

		rgd->rd_flags &= ~GFS2_RDF_UPTODATE;
	}
}

/**
 * inode_go_sync - Sync the dirty data and/or metadata for an inode glock
 * @gl: the glock protecting the inode
 *
 */

static void inode_go_sync(struct gfs2_glock *gl)
{
	struct gfs2_inode *ip = gl->gl_object;
	struct address_space *metamapping = gl->gl_aspace->i_mapping;
	int error;

	if (gl->gl_state != LM_ST_UNLOCKED)
		gfs2_pte_inval(gl);
	if (gl->gl_state != LM_ST_EXCLUSIVE)
		return;

	if (ip && !S_ISREG(ip->i_inode.i_mode))
		ip = NULL;

	if (test_bit(GLF_DIRTY, &gl->gl_flags)) {
		gfs2_log_flush(gl->gl_sbd, gl);
		filemap_fdatawrite(metamapping);
		if (ip) {
			struct address_space *mapping = ip->i_inode.i_mapping;
			filemap_fdatawrite(mapping);
			error = filemap_fdatawait(mapping);
			mapping_set_error(mapping, error);
		}
		error = filemap_fdatawait(metamapping);
		mapping_set_error(metamapping, error);
		clear_bit(GLF_DIRTY, &gl->gl_flags);
		gfs2_ail_empty_gl(gl);
	}
}

/**
 * inode_go_inval - prepare a inode glock to be released
 * @gl: the glock
 * @flags:
 *
 */

static void inode_go_inval(struct gfs2_glock *gl, int flags)
{
	struct gfs2_inode *ip = gl->gl_object;
	int meta = (flags & DIO_METADATA);

	if (meta) {
		gfs2_meta_inval(gl);
		if (ip)
			set_bit(GIF_INVALID, &ip->i_flags);
	}

	if (ip && S_ISREG(ip->i_inode.i_mode))
		truncate_inode_pages(ip->i_inode.i_mapping, 0);
}

/**
 * inode_go_demote_ok - Check to see if it's ok to unlock an inode glock
 * @gl: the glock
 *
 * Returns: 1 if it's ok
 */

static int inode_go_demote_ok(struct gfs2_glock *gl)
{
	struct gfs2_sbd *sdp = gl->gl_sbd;
	int demote = 0;

	if (!gl->gl_object && !gl->gl_aspace->i_mapping->nrpages)
		demote = 1;
	else if (!sdp->sd_args.ar_localcaching &&
		 time_after_eq(jiffies, gl->gl_stamp +
			       gfs2_tune_get(sdp, gt_demote_secs) * HZ))
		demote = 1;

	return demote;
}

/**
 * inode_go_lock - operation done after an inode lock is locked by a process
 * @gl: the glock
 * @flags:
 *
 * Returns: errno
 */

static int inode_go_lock(struct gfs2_holder *gh)
{
	struct gfs2_glock *gl = gh->gh_gl;
	struct gfs2_sbd *sdp = gl->gl_sbd;
	struct gfs2_inode *ip = gl->gl_object;
	int error = 0;

	if (!ip || (gh->gh_flags & GL_SKIP))
		return 0;

	if (test_bit(GIF_INVALID, &ip->i_flags)) {
		error = gfs2_inode_refresh(ip);
		if (error)
			return error;
	}

	if ((ip->i_diskflags & GFS2_DIF_TRUNC_IN_PROG) &&
	    (gl->gl_state == LM_ST_EXCLUSIVE) &&
	    (gh->gh_state == LM_ST_EXCLUSIVE)) {
		spin_lock(&sdp->sd_trunc_lock);
		if (list_empty(&ip->i_trunc_list))
			list_add(&sdp->sd_trunc_list, &ip->i_trunc_list);
		spin_unlock(&sdp->sd_trunc_lock);
		wake_up(&sdp->sd_quota_wait);
		return 1;
	}

	return error;
}

/**
 * inode_go_dump - print information about an inode
 * @seq: The iterator
 * @ip: the inode
 *
 * Returns: 0 on success, -ENOBUFS when we run out of space
 */

static int inode_go_dump(struct seq_file *seq, const struct gfs2_glock *gl)
{
	const struct gfs2_inode *ip = gl->gl_object;
	if (ip == NULL)
		return 0;
	gfs2_print_dbg(seq, " I: n:%llu/%llu t:%u f:0x%02lx d:0x%08x s:%llu/%llu\n",
		  (unsigned long long)ip->i_no_formal_ino,
		  (unsigned long long)ip->i_no_addr,
		  IF2DT(ip->i_inode.i_mode), ip->i_flags,
		  (unsigned int)ip->i_diskflags,
		  (unsigned long long)ip->i_inode.i_size,
		  (unsigned long long)ip->i_disksize);
	return 0;
}

/**
 * rgrp_go_demote_ok - Check to see if it's ok to unlock a RG's glock
 * @gl: the glock
 *
 * Returns: 1 if it's ok
 */

static int rgrp_go_demote_ok(struct gfs2_glock *gl)
{
	return !gl->gl_aspace->i_mapping->nrpages;
}

/**
 * rgrp_go_lock - operation done after an rgrp lock is locked by
 *    a first holder on this node.
 * @gl: the glock
 * @flags:
 *
 * Returns: errno
 */

static int rgrp_go_lock(struct gfs2_holder *gh)
{
	return gfs2_rgrp_bh_get(gh->gh_gl->gl_object);
}

/**
 * rgrp_go_unlock - operation done before an rgrp lock is unlocked by
 *    a last holder on this node.
 * @gl: the glock
 * @flags:
 *
 */

static void rgrp_go_unlock(struct gfs2_holder *gh)
{
	gfs2_rgrp_bh_put(gh->gh_gl->gl_object);
}

/**
 * rgrp_go_dump - print out an rgrp
 * @seq: The iterator
 * @gl: The glock in question
 *
 */

static int rgrp_go_dump(struct seq_file *seq, const struct gfs2_glock *gl)
{
	const struct gfs2_rgrpd *rgd = gl->gl_object;
	if (rgd == NULL)
		return 0;
	gfs2_print_dbg(seq, " R: n:%llu f:%02x b:%u/%u i:%u\n",
		       (unsigned long long)rgd->rd_addr, rgd->rd_flags,
		       rgd->rd_free, rgd->rd_free_clone, rgd->rd_dinodes);
	return 0;
}

/**
 * trans_go_sync - promote/demote the transaction glock
 * @gl: the glock
 * @state: the requested state
 * @flags:
 *
 */

static void trans_go_sync(struct gfs2_glock *gl)
{
	struct gfs2_sbd *sdp = gl->gl_sbd;

	if (gl->gl_state != LM_ST_UNLOCKED &&
	    test_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags)) {
		gfs2_meta_syncfs(sdp);
		gfs2_log_shutdown(sdp);
	}
}

/**
 * trans_go_xmote_bh - After promoting/demoting the transaction glock
 * @gl: the glock
 *
 */

static int trans_go_xmote_bh(struct gfs2_glock *gl, struct gfs2_holder *gh)
{
	struct gfs2_sbd *sdp = gl->gl_sbd;
	struct gfs2_inode *ip = GFS2_I(sdp->sd_jdesc->jd_inode);
	struct gfs2_glock *j_gl = ip->i_gl;
	struct gfs2_log_header_host head;
	int error;

	if (test_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags)) {
		j_gl->gl_ops->go_inval(j_gl, DIO_METADATA);

		error = gfs2_find_jhead(sdp->sd_jdesc, &head);
		if (error)
			gfs2_consist(sdp);
		if (!(head.lh_flags & GFS2_LOG_HEAD_UNMOUNT))
			gfs2_consist(sdp);

		/*  Initialize some head of the log stuff  */
		if (!test_bit(SDF_SHUTDOWN, &sdp->sd_flags)) {
			sdp->sd_log_sequence = head.lh_sequence + 1;
			gfs2_log_pointers_init(sdp, head.lh_blkno);
		}
	}
	return 0;
}

/**
 * quota_go_demote_ok - Check to see if it's ok to unlock a quota glock
 * @gl: the glock
 *
 * Returns: 1 if it's ok
 */

static int quota_go_demote_ok(struct gfs2_glock *gl)
{
	return !atomic_read(&gl->gl_lvb_count);
}

const struct gfs2_glock_operations gfs2_meta_glops = {
	.go_xmote_th = meta_go_sync,
	.go_type = LM_TYPE_META,
};

const struct gfs2_glock_operations gfs2_inode_glops = {
	.go_xmote_th = inode_go_sync,
	.go_inval = inode_go_inval,
	.go_demote_ok = inode_go_demote_ok,
	.go_lock = inode_go_lock,
	.go_dump = inode_go_dump,
	.go_type = LM_TYPE_INODE,
	.go_min_hold_time = HZ / 5,
};

const struct gfs2_glock_operations gfs2_rgrp_glops = {
	.go_xmote_th = meta_go_sync,
	.go_inval = meta_go_inval,
	.go_demote_ok = rgrp_go_demote_ok,
	.go_lock = rgrp_go_lock,
	.go_unlock = rgrp_go_unlock,
	.go_dump = rgrp_go_dump,
	.go_type = LM_TYPE_RGRP,
	.go_min_hold_time = HZ / 5,
};

const struct gfs2_glock_operations gfs2_trans_glops = {
	.go_xmote_th = trans_go_sync,
	.go_xmote_bh = trans_go_xmote_bh,
	.go_type = LM_TYPE_NONDISK,
};

const struct gfs2_glock_operations gfs2_iopen_glops = {
	.go_type = LM_TYPE_IOPEN,
};

const struct gfs2_glock_operations gfs2_flock_glops = {
	.go_type = LM_TYPE_FLOCK,
};

const struct gfs2_glock_operations gfs2_nondisk_glops = {
	.go_type = LM_TYPE_NONDISK,
};

const struct gfs2_glock_operations gfs2_quota_glops = {
	.go_demote_ok = quota_go_demote_ok,
	.go_type = LM_TYPE_QUOTA,
};

const struct gfs2_glock_operations gfs2_journal_glops = {
	.go_type = LM_TYPE_JOURNAL,
};
Commit	Line	Data
b3b94faa DT	1	/*
b3b94faa DT	2	* Copyright (C) Sistina Software, Inc. 1997-2003 All rights reserved.
cf45b752	3	* Copyright (C) 2004-2008 Red Hat, Inc. All rights reserved.
b3b94faa DT	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
e9fc2aa0	7	* of the GNU General Public License version 2.
b3b94faa DT	8	*/
b3b94faa DT	9
b3b94faa DT	10	#include <linux/slab.h>
	11	#include <linux/spinlock.h>
	12	#include <linux/completion.h>
	13	#include <linux/buffer_head.h>
5c676f6d	14	#include <linux/gfs2_ondisk.h>
7d308590	15	#include <linux/lm_interface.h>
6802e340	16	#include <linux/bio.h>
b3b94faa DT	17
b3b94faa DT	18	#include "gfs2.h"
5c676f6d	19	#include "incore.h"
b3b94faa DT	20	#include "bmap.h"
	21	#include "glock.h"
	22	#include "glops.h"
	23	#include "inode.h"
	24	#include "log.h"
	25	#include "meta_io.h"
b3b94faa DT	26	#include "recovery.h"
b3b94faa DT	27	#include "rgrp.h"
5c676f6d	28	#include "util.h"
ddacfaf7	29	#include "trans.h"
b3b94faa	30
ddacfaf7 SW	31	/**
	32	* ail_empty_gl - remove all buffers for a given lock from the AIL
	33	* @gl: the glock
	34	*
	35	* None of the buffers should be dirty, locked, or pinned.
	36	*/
	37
	38	static void gfs2_ail_empty_gl(struct gfs2_glock *gl)
	39	{
	40	struct gfs2_sbd *sdp = gl->gl_sbd;
	41	unsigned int blocks;
	42	struct list_head *head = &gl->gl_ail_list;
	43	struct gfs2_bufdata *bd;
	44	struct buffer_head *bh;
ddacfaf7 SW	45	int error;
	46
	47	blocks = atomic_read(&gl->gl_ail_count);
	48	if (!blocks)
	49	return;
	50
	51	error = gfs2_trans_begin(sdp, 0, blocks);
	52	if (gfs2_assert_withdraw(sdp, !error))
	53	return;
	54
	55	gfs2_log_lock(sdp);
	56	while (!list_empty(head)) {
	57	bd = list_entry(head->next, struct gfs2_bufdata,
	58	bd_ail_gl_list);
	59	bh = bd->bd_bh;
f91a0d3e	60	gfs2_remove_from_ail(bd);
1ad38c43 SW	61	bd->bd_bh = NULL;
	62	bh->b_private = NULL;
	63	bd->bd_blkno = bh->b_blocknr;
	64	gfs2_assert_withdraw(sdp, !buffer_busy(bh));
	65	gfs2_trans_add_revoke(sdp, bd);
ddacfaf7 SW	66	}
	67	gfs2_assert_withdraw(sdp, !atomic_read(&gl->gl_ail_count));
	68	gfs2_log_unlock(sdp);
	69
	70	gfs2_trans_end(sdp);
	71	gfs2_log_flush(sdp, NULL);
	72	}
ba7f7290 SW	73
	74	/**
	75	* gfs2_pte_inval - Sync and invalidate all PTEs associated with a glock
	76	* @gl: the glock
	77	*
	78	*/
	79
	80	static void gfs2_pte_inval(struct gfs2_glock *gl)
	81	{
	82	struct gfs2_inode *ip;
	83	struct inode *inode;
	84
	85	ip = gl->gl_object;
	86	inode = &ip->i_inode;
b60623c2	87	if (!ip \|\| !S_ISREG(inode->i_mode))
ba7f7290 SW	88	return;
ba7f7290 SW	89
ba7f7290	90	unmap_shared_mapping_range(inode->i_mapping, 0, 0);
ba7f7290 SW	91	if (test_bit(GIF_SW_PAGED, &ip->i_flags))
	92	set_bit(GLF_DIRTY, &gl->gl_flags);
	93
ba7f7290 SW	94	}
ba7f7290 SW	95
b3b94faa DT	96	/**
	97	* meta_go_sync - sync out the metadata for this glock
	98	* @gl: the glock
b3b94faa DT	99	*
	100	* Called when demoting or unlocking an EX glock. We must flush
	101	* to disk all dirty buffers/pages relating to this glock, and must not
	102	* not return to caller to demote/unlock the glock until I/O is complete.
	103	*/
	104
1a14d3a6	105	static void meta_go_sync(struct gfs2_glock *gl)
b3b94faa	106	{
b5d32bea SW	107	if (gl->gl_state != LM_ST_EXCLUSIVE)
	108	return;
	109
b3b94faa	110	if (test_and_clear_bit(GLF_DIRTY, &gl->gl_flags)) {
b09e593d	111	gfs2_log_flush(gl->gl_sbd, gl);
7276b3b0	112	gfs2_meta_sync(gl);
1a14d3a6	113	gfs2_ail_empty_gl(gl);
b3b94faa	114	}
b3b94faa DT	115	}
	116
	117	/**
	118	* meta_go_inval - invalidate the metadata for this glock
	119	* @gl: the glock
	120	* @flags:
	121	*
	122	*/
	123
	124	static void meta_go_inval(struct gfs2_glock *gl, int flags)
	125	{
	126	if (!(flags & DIO_METADATA))
	127	return;
	128
	129	gfs2_meta_inval(gl);
cf45b752 BP	130	if (gl->gl_object == GFS2_I(gl->gl_sbd->sd_rindex))
	131	gl->gl_sbd->sd_rindex_uptodate = 0;
	132	else if (gl->gl_ops == &gfs2_rgrp_glops && gl->gl_object) {
	133	struct gfs2_rgrpd rgd = (struct gfs2_rgrpd )gl->gl_object;
	134
	135	rgd->rd_flags &= ~GFS2_RDF_UPTODATE;
	136	}
b3b94faa DT	137	}
b3b94faa DT	138
b5d32bea SW	139	/**
	140	* inode_go_sync - Sync the dirty data and/or metadata for an inode glock
	141	* @gl: the glock protecting the inode
	142	*
	143	*/
	144
	145	static void inode_go_sync(struct gfs2_glock *gl)
	146	{
	147	struct gfs2_inode *ip = gl->gl_object;
3042a2cc SW	148	struct address_space *metamapping = gl->gl_aspace->i_mapping;
	149	int error;
	150
	151	if (gl->gl_state != LM_ST_UNLOCKED)
	152	gfs2_pte_inval(gl);
	153	if (gl->gl_state != LM_ST_EXCLUSIVE)
	154	return;
b5d32bea SW	155
	156	if (ip && !S_ISREG(ip->i_inode.i_mode))
	157	ip = NULL;
	158
	159	if (test_bit(GLF_DIRTY, &gl->gl_flags)) {
b524fe64	160	gfs2_log_flush(gl->gl_sbd, gl);
3042a2cc	161	filemap_fdatawrite(metamapping);
b5d32bea SW	162	if (ip) {
b5d32bea SW	163	struct address_space *mapping = ip->i_inode.i_mapping;
3042a2cc SW	164	filemap_fdatawrite(mapping);
3042a2cc SW	165	error = filemap_fdatawait(mapping);
3e9f45bd	166	mapping_set_error(mapping, error);
b5d32bea	167	}
3042a2cc SW	168	error = filemap_fdatawait(metamapping);
3042a2cc SW	169	mapping_set_error(metamapping, error);
b5d32bea SW	170	clear_bit(GLF_DIRTY, &gl->gl_flags);
	171	gfs2_ail_empty_gl(gl);
	172	}
	173	}
	174
b3b94faa DT	175	/**
	176	* inode_go_inval - prepare a inode glock to be released
	177	* @gl: the glock
	178	* @flags:
	179	*
	180	*/
	181
	182	static void inode_go_inval(struct gfs2_glock *gl, int flags)
	183	{
b004157a	184	struct gfs2_inode *ip = gl->gl_object;
b3b94faa	185	int meta = (flags & DIO_METADATA);
b3b94faa DT	186
	187	if (meta) {
	188	gfs2_meta_inval(gl);
b004157a SW	189	if (ip)
	190	set_bit(GIF_INVALID, &ip->i_flags);
	191	}
	192
3cc3f710	193	if (ip && S_ISREG(ip->i_inode.i_mode))
b004157a	194	truncate_inode_pages(ip->i_inode.i_mapping, 0);
b3b94faa DT	195	}
	196
	197	/**
	198	* inode_go_demote_ok - Check to see if it's ok to unlock an inode glock
	199	* @gl: the glock
	200	*
	201	* Returns: 1 if it's ok
	202	*/
	203
	204	static int inode_go_demote_ok(struct gfs2_glock *gl)
	205	{
	206	struct gfs2_sbd *sdp = gl->gl_sbd;
	207	int demote = 0;
	208
5c676f6d	209	if (!gl->gl_object && !gl->gl_aspace->i_mapping->nrpages)
b3b94faa DT	210	demote = 1;
	211	else if (!sdp->sd_args.ar_localcaching &&
	212	time_after_eq(jiffies, gl->gl_stamp +
	213	gfs2_tune_get(sdp, gt_demote_secs) * HZ))
	214	demote = 1;
	215
	216	return demote;
	217	}
	218
	219	/**
	220	* inode_go_lock - operation done after an inode lock is locked by a process
	221	* @gl: the glock
	222	* @flags:
	223	*
	224	* Returns: errno
	225	*/
	226
	227	static int inode_go_lock(struct gfs2_holder *gh)
	228	{
	229	struct gfs2_glock *gl = gh->gh_gl;
813e0c46	230	struct gfs2_sbd *sdp = gl->gl_sbd;
5c676f6d	231	struct gfs2_inode *ip = gl->gl_object;
b3b94faa DT	232	int error = 0;
b3b94faa DT	233
091806ed	234	if (!ip \|\| (gh->gh_flags & GL_SKIP))
b3b94faa DT	235	return 0;
b3b94faa DT	236
bfded27b	237	if (test_bit(GIF_INVALID, &ip->i_flags)) {
b3b94faa DT	238	error = gfs2_inode_refresh(ip);
	239	if (error)
	240	return error;
b3b94faa DT	241	}
b3b94faa DT	242
383f01fb	243	if ((ip->i_diskflags & GFS2_DIF_TRUNC_IN_PROG) &&
b3b94faa	244	(gl->gl_state == LM_ST_EXCLUSIVE) &&
813e0c46 SW	245	(gh->gh_state == LM_ST_EXCLUSIVE)) {
	246	spin_lock(&sdp->sd_trunc_lock);
	247	if (list_empty(&ip->i_trunc_list))
	248	list_add(&sdp->sd_trunc_list, &ip->i_trunc_list);
	249	spin_unlock(&sdp->sd_trunc_lock);
	250	wake_up(&sdp->sd_quota_wait);
	251	return 1;
	252	}
b3b94faa DT	253
	254	return error;
	255	}
	256
6802e340 SW	257	/**
	258	* inode_go_dump - print information about an inode
	259	* @seq: The iterator
	260	* @ip: the inode
	261	*
	262	* Returns: 0 on success, -ENOBUFS when we run out of space
	263	*/
	264
	265	static int inode_go_dump(struct seq_file seq, const struct gfs2_glock gl)
	266	{
	267	const struct gfs2_inode *ip = gl->gl_object;
	268	if (ip == NULL)
	269	return 0;
fa75cedc	270	gfs2_print_dbg(seq, " I: n:%llu/%llu t:%u f:0x%02lx d:0x%08x s:%llu/%llu\n",
6802e340 SW	271	(unsigned long long)ip->i_no_formal_ino,
6802e340 SW	272	(unsigned long long)ip->i_no_addr,
fa75cedc SW	273	IF2DT(ip->i_inode.i_mode), ip->i_flags,
	274	(unsigned int)ip->i_diskflags,
	275	(unsigned long long)ip->i_inode.i_size,
	276	(unsigned long long)ip->i_disksize);
6802e340 SW	277	return 0;
	278	}
	279
b3b94faa DT	280	/**
	281	* rgrp_go_demote_ok - Check to see if it's ok to unlock a RG's glock
	282	* @gl: the glock
	283	*
	284	* Returns: 1 if it's ok
	285	*/
	286
	287	static int rgrp_go_demote_ok(struct gfs2_glock *gl)
	288	{
	289	return !gl->gl_aspace->i_mapping->nrpages;
	290	}
	291
	292	/**
	293	* rgrp_go_lock - operation done after an rgrp lock is locked by
	294	* a first holder on this node.
	295	* @gl: the glock
	296	* @flags:
	297	*
	298	* Returns: errno
	299	*/
	300
	301	static int rgrp_go_lock(struct gfs2_holder *gh)
	302	{
5c676f6d	303	return gfs2_rgrp_bh_get(gh->gh_gl->gl_object);
b3b94faa DT	304	}
	305
	306	/**
	307	* rgrp_go_unlock - operation done before an rgrp lock is unlocked by
	308	* a last holder on this node.
	309	* @gl: the glock
	310	* @flags:
	311	*
	312	*/
	313
	314	static void rgrp_go_unlock(struct gfs2_holder *gh)
	315	{
5c676f6d	316	gfs2_rgrp_bh_put(gh->gh_gl->gl_object);
b3b94faa DT	317	}
b3b94faa DT	318
6802e340 SW	319	/**
	320	* rgrp_go_dump - print out an rgrp
	321	* @seq: The iterator
	322	* @gl: The glock in question
	323	*
	324	*/
	325
	326	static int rgrp_go_dump(struct seq_file seq, const struct gfs2_glock gl)
	327	{
	328	const struct gfs2_rgrpd *rgd = gl->gl_object;
	329	if (rgd == NULL)
	330	return 0;
fa75cedc SW	331	gfs2_print_dbg(seq, " R: n:%llu f:%02x b:%u/%u i:%u\n",
	332	(unsigned long long)rgd->rd_addr, rgd->rd_flags,
	333	rgd->rd_free, rgd->rd_free_clone, rgd->rd_dinodes);
6802e340 SW	334	return 0;
	335	}
	336
b3b94faa	337	/**
3042a2cc	338	* trans_go_sync - promote/demote the transaction glock
b3b94faa DT	339	* @gl: the glock
	340	* @state: the requested state
	341	* @flags:
	342	*
	343	*/
	344
3042a2cc	345	static void trans_go_sync(struct gfs2_glock *gl)
b3b94faa DT	346	{
	347	struct gfs2_sbd *sdp = gl->gl_sbd;
	348
	349	if (gl->gl_state != LM_ST_UNLOCKED &&
	350	test_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags)) {
	351	gfs2_meta_syncfs(sdp);
	352	gfs2_log_shutdown(sdp);
	353	}
b3b94faa DT	354	}
	355
	356	/**
	357	* trans_go_xmote_bh - After promoting/demoting the transaction glock
	358	* @gl: the glock
	359	*
	360	*/
	361
6802e340	362	static int trans_go_xmote_bh(struct gfs2_glock gl, struct gfs2_holder gh)
b3b94faa DT	363	{
b3b94faa DT	364	struct gfs2_sbd *sdp = gl->gl_sbd;
feaa7bba	365	struct gfs2_inode *ip = GFS2_I(sdp->sd_jdesc->jd_inode);
5c676f6d	366	struct gfs2_glock *j_gl = ip->i_gl;
55167622	367	struct gfs2_log_header_host head;
b3b94faa DT	368	int error;
b3b94faa DT	369
6802e340	370	if (test_bit(SDF_JOURNAL_LIVE, &sdp->sd_flags)) {
1a14d3a6	371	j_gl->gl_ops->go_inval(j_gl, DIO_METADATA);
b3b94faa DT	372
	373	error = gfs2_find_jhead(sdp->sd_jdesc, &head);
	374	if (error)
	375	gfs2_consist(sdp);
	376	if (!(head.lh_flags & GFS2_LOG_HEAD_UNMOUNT))
	377	gfs2_consist(sdp);
	378
	379	/* Initialize some head of the log stuff */
	380	if (!test_bit(SDF_SHUTDOWN, &sdp->sd_flags)) {
	381	sdp->sd_log_sequence = head.lh_sequence + 1;
	382	gfs2_log_pointers_init(sdp, head.lh_blkno);
	383	}
	384	}
6802e340	385	return 0;
b3b94faa DT	386	}
b3b94faa DT	387
b3b94faa DT	388	/**
	389	* quota_go_demote_ok - Check to see if it's ok to unlock a quota glock
	390	* @gl: the glock
	391	*
	392	* Returns: 1 if it's ok
	393	*/
	394
	395	static int quota_go_demote_ok(struct gfs2_glock *gl)
	396	{
	397	return !atomic_read(&gl->gl_lvb_count);
	398	}
	399
8fb4b536	400	const struct gfs2_glock_operations gfs2_meta_glops = {
b5d32bea	401	.go_xmote_th = meta_go_sync,
ea67eedb	402	.go_type = LM_TYPE_META,
b3b94faa DT	403	};
b3b94faa DT	404
8fb4b536	405	const struct gfs2_glock_operations gfs2_inode_glops = {
3042a2cc	406	.go_xmote_th = inode_go_sync,
b3b94faa DT	407	.go_inval = inode_go_inval,
	408	.go_demote_ok = inode_go_demote_ok,
	409	.go_lock = inode_go_lock,
6802e340	410	.go_dump = inode_go_dump,
ea67eedb	411	.go_type = LM_TYPE_INODE,
6802e340	412	.go_min_hold_time = HZ / 5,
b3b94faa DT	413	};
b3b94faa DT	414
8fb4b536	415	const struct gfs2_glock_operations gfs2_rgrp_glops = {
cad5b939	416	.go_xmote_th = meta_go_sync,
b3b94faa DT	417	.go_inval = meta_go_inval,
	418	.go_demote_ok = rgrp_go_demote_ok,
	419	.go_lock = rgrp_go_lock,
	420	.go_unlock = rgrp_go_unlock,
6802e340	421	.go_dump = rgrp_go_dump,
ea67eedb	422	.go_type = LM_TYPE_RGRP,
6802e340	423	.go_min_hold_time = HZ / 5,
b3b94faa DT	424	};
b3b94faa DT	425
8fb4b536	426	const struct gfs2_glock_operations gfs2_trans_glops = {
3042a2cc	427	.go_xmote_th = trans_go_sync,
b3b94faa	428	.go_xmote_bh = trans_go_xmote_bh,
ea67eedb	429	.go_type = LM_TYPE_NONDISK,
b3b94faa DT	430	};
b3b94faa DT	431
8fb4b536	432	const struct gfs2_glock_operations gfs2_iopen_glops = {
ea67eedb	433	.go_type = LM_TYPE_IOPEN,
b3b94faa DT	434	};
b3b94faa DT	435
8fb4b536	436	const struct gfs2_glock_operations gfs2_flock_glops = {
ea67eedb	437	.go_type = LM_TYPE_FLOCK,
b3b94faa DT	438	};
b3b94faa DT	439
8fb4b536	440	const struct gfs2_glock_operations gfs2_nondisk_glops = {
ea67eedb	441	.go_type = LM_TYPE_NONDISK,
b3b94faa DT	442	};
b3b94faa DT	443
8fb4b536	444	const struct gfs2_glock_operations gfs2_quota_glops = {
b3b94faa	445	.go_demote_ok = quota_go_demote_ok,
ea67eedb	446	.go_type = LM_TYPE_QUOTA,
b3b94faa DT	447	};
b3b94faa DT	448
8fb4b536	449	const struct gfs2_glock_operations gfs2_journal_glops = {
ea67eedb	450	.go_type = LM_TYPE_JOURNAL,
b3b94faa DT	451	};
b3b94faa DT	452