[net-next-2.6.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 "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_xmote_bh - After promoting/demoting a glock
 * @gl: the glock
 *
 */

static void inode_go_xmote_bh(struct gfs2_glock *gl)
{
	struct gfs2_holder *gh = gl->gl_req_gh;
	struct buffer_head *bh;
	int error;

	if (gl->gl_state != LM_ST_UNLOCKED &&
	    (!gh || !(gh->gh_flags & GL_SKIP))) {
		error = gfs2_meta_read(gl, gl->gl_name.ln_number, 0, &bh);
		if (!error)
			brelse(bh);
	}
}

/**
 * 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_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_di.di_flags & GFS2_DIF_TRUNC_IN_PROG) &&
	    (gl->gl_state == LM_ST_EXCLUSIVE) &&
	    (gh->gh_state == LM_ST_EXCLUSIVE))
		error = gfs2_truncatei_resume(ip);

	return error;
}

/**
 * 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);
}

/**
 * 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 void trans_go_xmote_bh(struct gfs2_glock *gl)
{
	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 (gl->gl_state != LM_ST_UNLOCKED &&
	    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);
		}
	}
}

/**
 * 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_xmote_bh = inode_go_xmote_bh,
	.go_inval = inode_go_inval,
	.go_demote_ok = inode_go_demote_ok,
	.go_lock = inode_go_lock,
	.go_type = LM_TYPE_INODE,
	.go_min_hold_time = HZ / 10,
};

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_type = LM_TYPE_RGRP,
	.go_min_hold_time = HZ / 10,
};

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