Commit 892c4467 authored by David Teigland's avatar David Teigland
Browse files

dlm: fix seq_file usage in debugfs lock dump 



The old code would leak iterators and leave reference counts on
rsbs because it was ignoring the "stop" seq callback.  The code
followed an example that used the seq operations differently.
This new code is based on actually understanding how the seq
operations work.  It also improves things by saving the hash bucket
in the position to avoid cycling through completed buckets in start.

Siged-off-by: default avatarDavd Teigland <teigland@redhat.com>
parent 238c6d54

fs/dlm/debug_fs.c

+337 −359
Original line number Diff line number Diff line 
/******************************************************************************

*******************************************************************************

**

**  Copyright (C) 2005-2008 Red Hat, Inc.  All rights reserved.

**  Copyright (C) 2005-2009 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
@@ -25,19 +25,6 @@ static struct mutex debug_buf_lock; 


static struct dentry *dlm_root;



struct rsb_iter {

	int entry;

	int format;

	int header;

	struct dlm_ls *ls;

	struct list_head *next;

	struct dlm_rsb *rsb;

};



/*

 * dump all rsb's in the lockspace hash table

 */



static char *print_lockmode(int mode)

{

	switch (mode) {
@@ -60,13 +47,13 @@ static char *print_lockmode(int mode) 
	}

}



static void print_format1_lock(struct seq_file *s, struct dlm_lkb *lkb,

static int print_format1_lock(struct seq_file *s, struct dlm_lkb *lkb,

			      struct dlm_rsb *res)

{

	seq_printf(s, "%08x %s", lkb->lkb_id, print_lockmode(lkb->lkb_grmode));



	if (lkb->lkb_status == DLM_LKSTS_CONVERT

	    || lkb->lkb_status == DLM_LKSTS_WAITING)

	if (lkb->lkb_status == DLM_LKSTS_CONVERT ||

	    lkb->lkb_status == DLM_LKSTS_WAITING)

		seq_printf(s, " (%s)", print_lockmode(lkb->lkb_rqmode));



	if (lkb->lkb_nodeid) {
@@ -80,33 +67,42 @@ static void print_format1_lock(struct seq_file *s, struct dlm_lkb *lkb, 
	if (lkb->lkb_wait_type)

		seq_printf(s, " wait_type: %d", lkb->lkb_wait_type);



	seq_printf(s, "\n");

	return seq_printf(s, "\n");

}



static int print_format1(struct dlm_rsb *res, struct seq_file *s)

{

	struct dlm_lkb *lkb;

	int i, lvblen = res->res_ls->ls_lvblen, recover_list, root_list;

	int rv;



	lock_rsb(res);



	seq_printf(s, "\nResource %p Name (len=%d) \"", res, res->res_length);

	rv = seq_printf(s, "\nResource %p Name (len=%d) \"",

			res, res->res_length);

	if (rv)

		goto out;



	for (i = 0; i < res->res_length; i++) {

		if (isprint(res->res_name[i]))

			seq_printf(s, "%c", res->res_name[i]);

		else

			seq_printf(s, "%c", '.');

	}



	if (res->res_nodeid > 0)

		seq_printf(s, "\"  \nLocal Copy, Master is node %d\n",

		rv = seq_printf(s, "\"  \nLocal Copy, Master is node %d\n",

				res->res_nodeid);

	else if (res->res_nodeid == 0)

		seq_printf(s, "\"  \nMaster Copy\n");

		rv = seq_printf(s, "\"  \nMaster Copy\n");

	else if (res->res_nodeid == -1)

		seq_printf(s, "\"  \nLooking up master (lkid %x)\n",

		rv = seq_printf(s, "\"  \nLooking up master (lkid %x)\n",

			   	res->res_first_lkid);

	else

		seq_printf(s, "\"  \nInvalid master %d\n", res->res_nodeid);

		rv = seq_printf(s, "\"  \nInvalid master %d\n",

				res->res_nodeid);

	if (rv)

		goto out;



	/* Print the LVB: */

	if (res->res_lvbptr) {
@@ -119,52 +115,66 @@ static int print_format1(struct dlm_rsb *res, struct seq_file *s) 
		}

		if (rsb_flag(res, RSB_VALNOTVALID))

			seq_printf(s, " (INVALID)");

		seq_printf(s, "\n");

		rv = seq_printf(s, "\n");

		if (rv)

			goto out;

	}



	root_list = !list_empty(&res->res_root_list);

	recover_list = !list_empty(&res->res_recover_list);



	if (root_list || recover_list) {

		seq_printf(s, "Recovery: root %d recover %d flags %lx "

		rv = seq_printf(s, "Recovery: root %d recover %d flags %lx "

				"count %d\n", root_list, recover_list,

			   	res->res_flags, res->res_recover_locks_count);

		if (rv)

			goto out;

	}



	/* Print the locks attached to this resource */

	seq_printf(s, "Granted Queue\n");

	list_for_each_entry(lkb, &res->res_grantqueue, lkb_statequeue)

		print_format1_lock(s, lkb, res);

	list_for_each_entry(lkb, &res->res_grantqueue, lkb_statequeue) {

		rv = print_format1_lock(s, lkb, res);

		if (rv)

			goto out;

	}



	seq_printf(s, "Conversion Queue\n");

	list_for_each_entry(lkb, &res->res_convertqueue, lkb_statequeue)

		print_format1_lock(s, lkb, res);

	list_for_each_entry(lkb, &res->res_convertqueue, lkb_statequeue) {

		rv = print_format1_lock(s, lkb, res);

		if (rv)

			goto out;

	}



	seq_printf(s, "Waiting Queue\n");

	list_for_each_entry(lkb, &res->res_waitqueue, lkb_statequeue)

		print_format1_lock(s, lkb, res);

	list_for_each_entry(lkb, &res->res_waitqueue, lkb_statequeue) {

		rv = print_format1_lock(s, lkb, res);

		if (rv)

			goto out;

	}



	if (list_empty(&res->res_lookup))

		goto out;



	seq_printf(s, "Lookup Queue\n");

	list_for_each_entry(lkb, &res->res_lookup, lkb_rsb_lookup) {

		seq_printf(s, "%08x %s", lkb->lkb_id,

		rv = seq_printf(s, "%08x %s", lkb->lkb_id,

				print_lockmode(lkb->lkb_rqmode));

		if (lkb->lkb_wait_type)

			seq_printf(s, " wait_type: %d", lkb->lkb_wait_type);

		seq_printf(s, "\n");

		rv = seq_printf(s, "\n");

	}

 out:

	unlock_rsb(res);

	return 0;

	return rv;

}



static void print_format2_lock(struct seq_file *s, struct dlm_lkb *lkb,

static int print_format2_lock(struct seq_file *s, struct dlm_lkb *lkb,

			      struct dlm_rsb *r)

{

	u64 xid = 0;

	u64 us;

	int rv;



	if (lkb->lkb_flags & DLM_IFL_USER) {

		if (lkb->lkb_ua)
@@ -177,7 +187,7 @@ static void print_format2_lock(struct seq_file *s, struct dlm_lkb *lkb, 
	/* id nodeid remid pid xid exflags flags sts grmode rqmode time_us

	   r_nodeid r_len r_name */



	seq_printf(s, "%x %d %x %u %llu %x %x %d %d %d %llu %u %d \"%s\"\n",

	rv = seq_printf(s, "%x %d %x %u %llu %x %x %d %d %d %llu %u %d \"%s\"\n",

			lkb->lkb_id,

			lkb->lkb_nodeid,

			lkb->lkb_remid,
@@ -192,38 +202,50 @@ static void print_format2_lock(struct seq_file *s, struct dlm_lkb *lkb, 
			r->res_nodeid,

			r->res_length,

			r->res_name);

	return rv;

}



static int print_format2(struct dlm_rsb *r, struct seq_file *s)

{

	struct dlm_lkb *lkb;

	int rv = 0;



	lock_rsb(r);



	list_for_each_entry(lkb, &r->res_grantqueue, lkb_statequeue)

		print_format2_lock(s, lkb, r);



	list_for_each_entry(lkb, &r->res_convertqueue, lkb_statequeue)

		print_format2_lock(s, lkb, r);

	list_for_each_entry(lkb, &r->res_grantqueue, lkb_statequeue) {

		rv = print_format2_lock(s, lkb, r);

		if (rv)

			goto out;

	}



	list_for_each_entry(lkb, &r->res_waitqueue, lkb_statequeue)

		print_format2_lock(s, lkb, r);

	list_for_each_entry(lkb, &r->res_convertqueue, lkb_statequeue) {

		rv = print_format2_lock(s, lkb, r);

		if (rv)

			goto out;

	}



	list_for_each_entry(lkb, &r->res_waitqueue, lkb_statequeue) {

		rv = print_format2_lock(s, lkb, r);

		if (rv)

			goto out;

	}

 out:

	unlock_rsb(r);

	return 0;

	return rv;

}



static void print_format3_lock(struct seq_file *s, struct dlm_lkb *lkb,

static int print_format3_lock(struct seq_file *s, struct dlm_lkb *lkb,

			      int rsb_lookup)

{

	u64 xid = 0;

	int rv;



	if (lkb->lkb_flags & DLM_IFL_USER) {

		if (lkb->lkb_ua)

			xid = lkb->lkb_ua->xid;

	}



	seq_printf(s, "lkb %x %d %x %u %llu %x %x %d %d %d %d %d %d %u %llu %llu\n",

	rv = seq_printf(s, "lkb %x %d %x %u %llu %x %x %d %d %d %d %d %d %u %llu %llu\n",

			lkb->lkb_id,

			lkb->lkb_nodeid,

			lkb->lkb_remid,
@@ -240,6 +262,7 @@ static void print_format3_lock(struct seq_file *s, struct dlm_lkb *lkb, 
			lkb->lkb_lvbseq,

			(unsigned long long)ktime_to_ns(lkb->lkb_timestamp),

			(unsigned long long)ktime_to_ns(lkb->lkb_time_bast));

	return rv;

}



static int print_format3(struct dlm_rsb *r, struct seq_file *s)
@@ -247,10 +270,11 @@ static int print_format3(struct dlm_rsb *r, struct seq_file *s) 
	struct dlm_lkb *lkb;

	int i, lvblen = r->res_ls->ls_lvblen;

	int print_name = 1;

	int rv;



	lock_rsb(r);



	seq_printf(s, "rsb %p %d %x %lx %d %d %u %d ",

	rv = seq_printf(s, "rsb %p %d %x %lx %d %d %u %d ",

			r,

			r->res_nodeid,

			r->res_first_lkid,
@@ -259,6 +283,8 @@ static int print_format3(struct dlm_rsb *r, struct seq_file *s) 
			!list_empty(&r->res_recover_list),

			r->res_recover_locks_count,

			r->res_length);

	if (rv)

		goto out;



	for (i = 0; i < r->res_length; i++) {

		if (!isascii(r->res_name[i]) || !isprint(r->res_name[i]))
@@ -273,7 +299,9 @@ static int print_format3(struct dlm_rsb *r, struct seq_file *s) 
		else

			seq_printf(s, " %02x", (unsigned char)r->res_name[i]);

	}

	seq_printf(s, "\n");

	rv = seq_printf(s, "\n");

	if (rv)

		goto out;



	if (!r->res_lvbptr)

		goto do_locks;
@@ -282,344 +310,294 @@ static int print_format3(struct dlm_rsb *r, struct seq_file *s) 


	for (i = 0; i < lvblen; i++)

		seq_printf(s, " %02x", (unsigned char)r->res_lvbptr[i]);

	seq_printf(s, "\n");

	rv = seq_printf(s, "\n");

	if (rv)

		goto out;



 do_locks:

	list_for_each_entry(lkb, &r->res_grantqueue, lkb_statequeue)

		print_format3_lock(s, lkb, 0);



	list_for_each_entry(lkb, &r->res_convertqueue, lkb_statequeue)

		print_format3_lock(s, lkb, 0);



	list_for_each_entry(lkb, &r->res_waitqueue, lkb_statequeue)

		print_format3_lock(s, lkb, 0);



	list_for_each_entry(lkb, &r->res_lookup, lkb_rsb_lookup)

		print_format3_lock(s, lkb, 1);



	unlock_rsb(r);

	return 0;

}



static int rsb_iter_next(struct rsb_iter *ri)

{

	struct dlm_ls *ls = ri->ls;

	int i;



	if (!ri->next) {

 top:

		/* Find the next non-empty hash bucket */

		for (i = ri->entry; i < ls->ls_rsbtbl_size; i++) {

			read_lock(&ls->ls_rsbtbl[i].lock);

			if (!list_empty(&ls->ls_rsbtbl[i].list)) {

				ri->next = ls->ls_rsbtbl[i].list.next;

				ri->rsb = list_entry(ri->next, struct dlm_rsb,

							res_hashchain);

				dlm_hold_rsb(ri->rsb);

				read_unlock(&ls->ls_rsbtbl[i].lock);

				break;

			}

			read_unlock(&ls->ls_rsbtbl[i].lock);

		}

		ri->entry = i;



		if (ri->entry >= ls->ls_rsbtbl_size)

			return 1;

	} else {

		struct dlm_rsb *old = ri->rsb;

		i = ri->entry;

		read_lock(&ls->ls_rsbtbl[i].lock);

		ri->next = ri->next->next;

		if (ri->next->next == ls->ls_rsbtbl[i].list.next) {

			/* End of list - move to next bucket */

			ri->next = NULL;

			ri->entry++;

			read_unlock(&ls->ls_rsbtbl[i].lock);

			dlm_put_rsb(old);

			goto top;

		}

		ri->rsb = list_entry(ri->next, struct dlm_rsb, res_hashchain);

		dlm_hold_rsb(ri->rsb);

		read_unlock(&ls->ls_rsbtbl[i].lock);

		dlm_put_rsb(old);

	}



	return 0;

}



static void rsb_iter_free(struct rsb_iter *ri)

{

	kfree(ri);

}



static struct rsb_iter *rsb_iter_init(struct dlm_ls *ls)

{

	struct rsb_iter *ri;



	ri = kzalloc(sizeof *ri, GFP_KERNEL);

	if (!ri)

		return NULL;



	ri->ls = ls;

	ri->entry = 0;

	ri->next = NULL;

	ri->format = 1;



	if (rsb_iter_next(ri)) {

		rsb_iter_free(ri);

		return NULL;

	list_for_each_entry(lkb, &r->res_grantqueue, lkb_statequeue) {

		rv = print_format3_lock(s, lkb, 0);

		if (rv)

			goto out;

	}



	return ri;

	list_for_each_entry(lkb, &r->res_convertqueue, lkb_statequeue) {

		rv = print_format3_lock(s, lkb, 0);

		if (rv)

			goto out;

	}



static void *rsb_seq_start(struct seq_file *file, loff_t *pos)

{

	struct rsb_iter *ri;

	loff_t n = *pos;



	ri = rsb_iter_init(file->private);

	if (!ri)

		return NULL;



	while (n--) {

		if (rsb_iter_next(ri)) {

			rsb_iter_free(ri);

			return NULL;

		}

	list_for_each_entry(lkb, &r->res_waitqueue, lkb_statequeue) {

		rv = print_format3_lock(s, lkb, 0);

		if (rv)

			goto out;

	}



	return ri;

	list_for_each_entry(lkb, &r->res_lookup, lkb_rsb_lookup) {

		rv = print_format3_lock(s, lkb, 1);

		if (rv)

			goto out;

	}



static void *rsb_seq_next(struct seq_file *file, void *iter_ptr, loff_t *pos)

{

	struct rsb_iter *ri = iter_ptr;



	(*pos)++;



	if (rsb_iter_next(ri)) {

		rsb_iter_free(ri);

		return NULL;

 out:

	unlock_rsb(r);

	return rv;

}



	return ri;

}

struct rsbtbl_iter {

	struct dlm_rsb *rsb;

	unsigned bucket;

	int format;

	int header;

};



static void rsb_seq_stop(struct seq_file *file, void *iter_ptr)

{

	/* nothing for now */

}

/* seq_printf returns -1 if the buffer is full, and 0 otherwise.

   If the buffer is full, seq_printf can be called again, but it

   does nothing and just returns -1.  So, the these printing routines

   periodically check the return value to avoid wasting too much time

   trying to print to a full buffer. */



static int rsb_seq_show(struct seq_file *file, void *iter_ptr)

static int table_seq_show(struct seq_file *seq, void *iter_ptr)

{

	struct rsb_iter *ri = iter_ptr;

	struct rsbtbl_iter *ri = iter_ptr;

	int rv = 0;



	switch (ri->format) {

	case 1:

		print_format1(ri->rsb, file);

		rv = print_format1(ri->rsb, seq);

		break;

	case 2:

		if (ri->header) {

			seq_printf(file, "id nodeid remid pid xid exflags "

			seq_printf(seq, "id nodeid remid pid xid exflags "

					"flags sts grmode rqmode time_ms "

					"r_nodeid r_len r_name\n");

			ri->header = 0;

		}

		print_format2(ri->rsb, file);

		rv = print_format2(ri->rsb, seq);

		break;

	case 3:

		if (ri->header) {

			seq_printf(file, "version rsb 1.1 lvb 1.1 lkb 1.1\n");

			seq_printf(seq, "version rsb 1.1 lvb 1.1 lkb 1.1\n");

			ri->header = 0;

		}

		print_format3(ri->rsb, file);

		rv = print_format3(ri->rsb, seq);

		break;

	}



	return 0;

	return rv;

}



static struct seq_operations rsb_seq_ops = {

	.start = rsb_seq_start,

	.next  = rsb_seq_next,

	.stop  = rsb_seq_stop,

	.show  = rsb_seq_show,

};

static struct seq_operations format1_seq_ops;

static struct seq_operations format2_seq_ops;

static struct seq_operations format3_seq_ops;



static int rsb_open(struct inode *inode, struct file *file)

static void *table_seq_start(struct seq_file *seq, loff_t *pos)

{

	struct seq_file *seq;

	int ret;



	ret = seq_open(file, &rsb_seq_ops);

	if (ret)

		return ret;



	seq = file->private_data;

	seq->private = inode->i_private;



	return 0;

}



static const struct file_operations rsb_fops = {

	.owner   = THIS_MODULE,

	.open    = rsb_open,

	.read    = seq_read,

	.llseek  = seq_lseek,

	.release = seq_release

};

	struct dlm_ls *ls = seq->private;

	struct rsbtbl_iter *ri;

	struct dlm_rsb *r;

	loff_t n = *pos;

	unsigned bucket, entry;



/*

 * Dump state in compact per-lock listing

 */

	bucket = n >> 32;

	entry = n & ((1LL << 32) - 1);



static struct rsb_iter *locks_iter_init(struct dlm_ls *ls, loff_t *pos)

{

	struct rsb_iter *ri;

	if (bucket >= ls->ls_rsbtbl_size)

		return NULL;



	ri = kzalloc(sizeof *ri, GFP_KERNEL);

	ri = kzalloc(sizeof(struct rsbtbl_iter), GFP_KERNEL);

	if (!ri)

		return NULL;



	ri->ls = ls;

	ri->entry = 0;

	ri->next = NULL;

	ri->format = 2;



	if (*pos == 0)

	if (n == 0)

		ri->header = 1;

	if (seq->op == &format1_seq_ops)

		ri->format = 1;

	if (seq->op == &format2_seq_ops)

		ri->format = 2;

	if (seq->op == &format3_seq_ops)

		ri->format = 3;



	if (rsb_iter_next(ri)) {

		rsb_iter_free(ri);

		return NULL;

	}



	read_lock(&ls->ls_rsbtbl[bucket].lock);

	if (!list_empty(&ls->ls_rsbtbl[bucket].list)) {

		list_for_each_entry(r, &ls->ls_rsbtbl[bucket].list,

				    res_hashchain) {

			if (!entry--) {

				dlm_hold_rsb(r);

				ri->rsb = r;

				ri->bucket = bucket;

				read_unlock(&ls->ls_rsbtbl[bucket].lock);

				return ri;

			}

		}

	}

	read_unlock(&ls->ls_rsbtbl[bucket].lock);



static void *locks_seq_start(struct seq_file *file, loff_t *pos)

{

	struct rsb_iter *ri;

	loff_t n = *pos;

	/*

	 * move to the first rsb in the next non-empty bucket

	 */



	ri = locks_iter_init(file->private, pos);

	if (!ri)

		return NULL;

	/* zero the entry */

	n &= ~((1LL << 32) - 1);



	while (1) {

		bucket++;

		n += 1LL << 32;



	while (n--) {

		if (rsb_iter_next(ri)) {

			rsb_iter_free(ri);

		if (bucket >= ls->ls_rsbtbl_size) {

			kfree(ri);

			return NULL;

		}

	}



		read_lock(&ls->ls_rsbtbl[bucket].lock);

		if (!list_empty(&ls->ls_rsbtbl[bucket].list)) {

			r = list_first_entry(&ls->ls_rsbtbl[bucket].list,

					     struct dlm_rsb, res_hashchain);

			dlm_hold_rsb(r);

			ri->rsb = r;

			ri->bucket = bucket;

			read_unlock(&ls->ls_rsbtbl[bucket].lock);

			*pos = n;

			return ri;

		}

		read_unlock(&ls->ls_rsbtbl[bucket].lock);

	}

}



static struct seq_operations locks_seq_ops = {

	.start = locks_seq_start,

	.next  = rsb_seq_next,

	.stop  = rsb_seq_stop,

	.show  = rsb_seq_show,

};



static int locks_open(struct inode *inode, struct file *file)

static void *table_seq_next(struct seq_file *seq, void *iter_ptr, loff_t *pos)

{

	struct seq_file *seq;

	int ret;

	struct dlm_ls *ls = seq->private;

	struct rsbtbl_iter *ri = iter_ptr;

	struct list_head *next;

	struct dlm_rsb *r, *rp;

	loff_t n = *pos;

	unsigned bucket;



	ret = seq_open(file, &locks_seq_ops);

	if (ret)

		return ret;

	bucket = n >> 32;



	seq = file->private_data;

	seq->private = inode->i_private;

	/*

	 * move to the next rsb in the same bucket

	 */



	return 0;

	read_lock(&ls->ls_rsbtbl[bucket].lock);

	rp = ri->rsb;

	next = rp->res_hashchain.next;



	if (next != &ls->ls_rsbtbl[bucket].list) {

		r = list_entry(next, struct dlm_rsb, res_hashchain);

		dlm_hold_rsb(r);

		ri->rsb = r;

		read_unlock(&ls->ls_rsbtbl[bucket].lock);

		dlm_put_rsb(rp);

		++*pos;

		return ri;

	}



static const struct file_operations locks_fops = {

	.owner   = THIS_MODULE,

	.open    = locks_open,

	.read    = seq_read,

	.llseek  = seq_lseek,

	.release = seq_release

};

	read_unlock(&ls->ls_rsbtbl[bucket].lock);

	dlm_put_rsb(rp);



	/*

 * Dump all rsb/lvb/lkb state in compact listing, more complete than _locks

 * This can replace both formats 1 and 2 eventually.

	 * move to the first rsb in the next non-empty bucket

	 */



static struct rsb_iter *all_iter_init(struct dlm_ls *ls, loff_t *pos)

{

	struct rsb_iter *ri;

	/* zero the entry */

	n &= ~((1LL << 32) - 1);



	ri = kzalloc(sizeof *ri, GFP_KERNEL);

	if (!ri)

		return NULL;



	ri->ls = ls;

	ri->entry = 0;

	ri->next = NULL;

	ri->format = 3;

	while (1) {

		bucket++;

		n += 1LL << 32;



	if (*pos == 0)

		ri->header = 1;



	if (rsb_iter_next(ri)) {

		rsb_iter_free(ri);

		if (bucket >= ls->ls_rsbtbl_size) {

			kfree(ri);

			return NULL;

		}



		read_lock(&ls->ls_rsbtbl[bucket].lock);

		if (!list_empty(&ls->ls_rsbtbl[bucket].list)) {

			r = list_first_entry(&ls->ls_rsbtbl[bucket].list,

					     struct dlm_rsb, res_hashchain);

			dlm_hold_rsb(r);

			ri->rsb = r;

			ri->bucket = bucket;

			read_unlock(&ls->ls_rsbtbl[bucket].lock);

			*pos = n;

			return ri;

		}

		read_unlock(&ls->ls_rsbtbl[bucket].lock);

	}

}



static void *all_seq_start(struct seq_file *file, loff_t *pos)

static void table_seq_stop(struct seq_file *seq, void *iter_ptr)

{

	struct rsb_iter *ri;

	loff_t n = *pos;

	struct rsbtbl_iter *ri = iter_ptr;



	ri = all_iter_init(file->private, pos);

	if (!ri)

		return NULL;



	while (n--) {

		if (rsb_iter_next(ri)) {

			rsb_iter_free(ri);

			return NULL;

	if (ri) {

		dlm_put_rsb(ri->rsb);

		kfree(ri);

	}

}



	return ri;

}

static struct seq_operations format1_seq_ops = {

	.start = table_seq_start,

	.next  = table_seq_next,

	.stop  = table_seq_stop,

	.show  = table_seq_show,

};



static struct seq_operations format2_seq_ops = {

	.start = table_seq_start,

	.next  = table_seq_next,

	.stop  = table_seq_stop,

	.show  = table_seq_show,

};



static struct seq_operations all_seq_ops = {

	.start = all_seq_start,

	.next  = rsb_seq_next,

	.stop  = rsb_seq_stop,

	.show  = rsb_seq_show,

static struct seq_operations format3_seq_ops = {

	.start = table_seq_start,

	.next  = table_seq_next,

	.stop  = table_seq_stop,

	.show  = table_seq_show,

};



static int all_open(struct inode *inode, struct file *file)

static const struct file_operations format1_fops;

static const struct file_operations format2_fops;

static const struct file_operations format3_fops;



static int table_open(struct inode *inode, struct file *file)

{

	struct seq_file *seq;

	int ret;

	int ret = -1;



	if (file->f_op == &format1_fops)

		ret = seq_open(file, &format1_seq_ops);

	else if (file->f_op == &format2_fops)

		ret = seq_open(file, &format2_seq_ops);

	else if (file->f_op == &format3_fops)

		ret = seq_open(file, &format3_seq_ops);



	ret = seq_open(file, &all_seq_ops);

	if (ret)

		return ret;



	seq = file->private_data;

	seq->private = inode->i_private;



	seq->private = inode->i_private; /* the dlm_ls */

	return 0;

}



static const struct file_operations all_fops = {

static const struct file_operations format1_fops = {

	.owner   = THIS_MODULE,

	.open    = table_open,

	.read    = seq_read,

	.llseek  = seq_lseek,

	.release = seq_release

};



static const struct file_operations format2_fops = {

	.owner   = THIS_MODULE,

	.open    = table_open,

	.read    = seq_read,

	.llseek  = seq_lseek,

	.release = seq_release

};



static const struct file_operations format3_fops = {

	.owner   = THIS_MODULE,

	.open    = all_open,

	.open    = table_open,

	.read    = seq_read,

	.llseek  = seq_lseek,

	.release = seq_release
@@ -689,7 +667,7 @@ int dlm_create_debug_file(struct dlm_ls *ls) 
						      S_IFREG | S_IRUGO,

						      dlm_root,

						      ls,

						      &rsb_fops);

						      &format1_fops);

	if (!ls->ls_debug_rsb_dentry)

		goto fail;
@@ -702,7 +680,7 @@ int dlm_create_debug_file(struct dlm_ls *ls) 
							S_IFREG | S_IRUGO,

							dlm_root,

							ls,

							&locks_fops);

							&format2_fops);

	if (!ls->ls_debug_locks_dentry)

		goto fail;
@@ -715,7 +693,7 @@ int dlm_create_debug_file(struct dlm_ls *ls) 
						      S_IFREG | S_IRUGO,

						      dlm_root,

						      ls,

						      &all_fops);

						      &format3_fops);

	if (!ls->ls_debug_all_dentry)

		goto fail;

CRA Git | Maintained and supported by SUSTech CRA and CCSE