[linux.git] / net / ceph / debugfs.c

// SPDX-License-Identifier: GPL-2.0
#include <linux/ceph/ceph_debug.h>

#include <linux/device.h>
#include <linux/slab.h>
#include <linux/module.h>
#include <linux/ctype.h>
#include <linux/debugfs.h>
#include <linux/seq_file.h>

#include <linux/ceph/libceph.h>
#include <linux/ceph/mon_client.h>
#include <linux/ceph/auth.h>
#include <linux/ceph/debugfs.h>

#ifdef CONFIG_DEBUG_FS

/*
 * Implement /sys/kernel/debug/ceph fun
 *
 * /sys/kernel/debug/ceph/client*  - an instance of the ceph client
 *      .../osdmap      - current osdmap
 *      .../monmap      - current monmap
 *      .../osdc        - active osd requests
 *      .../monc        - mon client state
 *      .../client_options - libceph-only (i.e. not rbd or cephfs) options
 *      .../dentry_lru  - dump contents of dentry lru
 *      .../caps        - expose cap (reservation) stats
 *      .../bdi         - symlink to ../../bdi/something
 */

static struct dentry *ceph_debugfs_dir;

static int monmap_show(struct seq_file *s, void *p)
{
	int i;
	struct ceph_client *client = s->private;

	if (client->monc.monmap == NULL)
		return 0;

	seq_printf(s, "epoch %d\n", client->monc.monmap->epoch);
	for (i = 0; i < client->monc.monmap->num_mon; i++) {
		struct ceph_entity_inst *inst =
			&client->monc.monmap->mon_inst[i];

		seq_printf(s, "\t%s%lld\t%s\n",
			   ENTITY_NAME(inst->name),
			   ceph_pr_addr(&inst->addr.in_addr));
	}
	return 0;
}

static int osdmap_show(struct seq_file *s, void *p)
{
	int i;
	struct ceph_client *client = s->private;
	struct ceph_osd_client *osdc = &client->osdc;
	struct ceph_osdmap *map = osdc->osdmap;
	struct rb_node *n;

	if (map == NULL)
		return 0;

	down_read(&osdc->lock);
	seq_printf(s, "epoch %u barrier %u flags 0x%x\n", map->epoch,
			osdc->epoch_barrier, map->flags);

	for (n = rb_first(&map->pg_pools); n; n = rb_next(n)) {
		struct ceph_pg_pool_info *pi =
			rb_entry(n, struct ceph_pg_pool_info, node);

		seq_printf(s, "pool %lld '%s' type %d size %d min_size %d pg_num %u pg_num_mask %d flags 0x%llx lfor %u read_tier %lld write_tier %lld\n",
			   pi->id, pi->name, pi->type, pi->size, pi->min_size,
			   pi->pg_num, pi->pg_num_mask, pi->flags,
			   pi->last_force_request_resend, pi->read_tier,
			   pi->write_tier);
	}
	for (i = 0; i < map->max_osd; i++) {
		struct ceph_entity_addr *addr = &map->osd_addr[i];
		u32 state = map->osd_state[i];
		char sb[64];

		seq_printf(s, "osd%d\t%s\t%3d%%\t(%s)\t%3d%%\n",
			   i, ceph_pr_addr(&addr->in_addr),
			   ((map->osd_weight[i]*100) >> 16),
			   ceph_osdmap_state_str(sb, sizeof(sb), state),
			   ((ceph_get_primary_affinity(map, i)*100) >> 16));
	}
	for (n = rb_first(&map->pg_temp); n; n = rb_next(n)) {
		struct ceph_pg_mapping *pg =
			rb_entry(n, struct ceph_pg_mapping, node);

		seq_printf(s, "pg_temp %llu.%x [", pg->pgid.pool,
			   pg->pgid.seed);
		for (i = 0; i < pg->pg_temp.len; i++)
			seq_printf(s, "%s%d", (i == 0 ? "" : ","),
				   pg->pg_temp.osds[i]);
		seq_printf(s, "]\n");
	}
	for (n = rb_first(&map->primary_temp); n; n = rb_next(n)) {
		struct ceph_pg_mapping *pg =
			rb_entry(n, struct ceph_pg_mapping, node);

		seq_printf(s, "primary_temp %llu.%x %d\n", pg->pgid.pool,
			   pg->pgid.seed, pg->primary_temp.osd);
	}
	for (n = rb_first(&map->pg_upmap); n; n = rb_next(n)) {
		struct ceph_pg_mapping *pg =
			rb_entry(n, struct ceph_pg_mapping, node);

		seq_printf(s, "pg_upmap %llu.%x [", pg->pgid.pool,
			   pg->pgid.seed);
		for (i = 0; i < pg->pg_upmap.len; i++)
			seq_printf(s, "%s%d", (i == 0 ? "" : ","),
				   pg->pg_upmap.osds[i]);
		seq_printf(s, "]\n");
	}
	for (n = rb_first(&map->pg_upmap_items); n; n = rb_next(n)) {
		struct ceph_pg_mapping *pg =
			rb_entry(n, struct ceph_pg_mapping, node);

		seq_printf(s, "pg_upmap_items %llu.%x [", pg->pgid.pool,
			   pg->pgid.seed);
		for (i = 0; i < pg->pg_upmap_items.len; i++)
			seq_printf(s, "%s%d->%d", (i == 0 ? "" : ","),
				   pg->pg_upmap_items.from_to[i][0],
				   pg->pg_upmap_items.from_to[i][1]);
		seq_printf(s, "]\n");
	}

	up_read(&osdc->lock);
	return 0;
}

static int monc_show(struct seq_file *s, void *p)
{
	struct ceph_client *client = s->private;
	struct ceph_mon_generic_request *req;
	struct ceph_mon_client *monc = &client->monc;
	struct rb_node *rp;
	int i;

	mutex_lock(&monc->mutex);

	for (i = 0; i < ARRAY_SIZE(monc->subs); i++) {
		seq_printf(s, "have %s %u", ceph_sub_str[i],
			   monc->subs[i].have);
		if (monc->subs[i].want)
			seq_printf(s, " want %llu%s",
				   le64_to_cpu(monc->subs[i].item.start),
				   (monc->subs[i].item.flags &
					CEPH_SUBSCRIBE_ONETIME ?  "" : "+"));
		seq_putc(s, '\n');
	}
	seq_printf(s, "fs_cluster_id %d\n", monc->fs_cluster_id);

	for (rp = rb_first(&monc->generic_request_tree); rp; rp = rb_next(rp)) {
		__u16 op;
		req = rb_entry(rp, struct ceph_mon_generic_request, node);
		op = le16_to_cpu(req->request->hdr.type);
		if (op == CEPH_MSG_STATFS)
			seq_printf(s, "%llu statfs\n", req->tid);
		else if (op == CEPH_MSG_MON_GET_VERSION)
			seq_printf(s, "%llu mon_get_version", req->tid);
		else
			seq_printf(s, "%llu unknown\n", req->tid);
	}

	mutex_unlock(&monc->mutex);
	return 0;
}

static void dump_spgid(struct seq_file *s, const struct ceph_spg *spgid)
{
	seq_printf(s, "%llu.%x", spgid->pgid.pool, spgid->pgid.seed);
	if (spgid->shard != CEPH_SPG_NOSHARD)
		seq_printf(s, "s%d", spgid->shard);
}

static void dump_target(struct seq_file *s, struct ceph_osd_request_target *t)
{
	int i;

	seq_printf(s, "osd%d\t%llu.%x\t", t->osd, t->pgid.pool, t->pgid.seed);
	dump_spgid(s, &t->spgid);
	seq_puts(s, "\t[");
	for (i = 0; i < t->up.size; i++)
		seq_printf(s, "%s%d", (!i ? "" : ","), t->up.osds[i]);
	seq_printf(s, "]/%d\t[", t->up.primary);
	for (i = 0; i < t->acting.size; i++)
		seq_printf(s, "%s%d", (!i ? "" : ","), t->acting.osds[i]);
	seq_printf(s, "]/%d\te%u\t", t->acting.primary, t->epoch);
	if (t->target_oloc.pool_ns) {
		seq_printf(s, "%*pE/%*pE\t0x%x",
			(int)t->target_oloc.pool_ns->len,
			t->target_oloc.pool_ns->str,
			t->target_oid.name_len, t->target_oid.name, t->flags);
	} else {
		seq_printf(s, "%*pE\t0x%x", t->target_oid.name_len,
			t->target_oid.name, t->flags);
	}
	if (t->paused)
		seq_puts(s, "\tP");
}

static void dump_request(struct seq_file *s, struct ceph_osd_request *req)
{
	int i;

	seq_printf(s, "%llu\t", req->r_tid);
	dump_target(s, &req->r_t);

	seq_printf(s, "\t%d", req->r_attempts);

	for (i = 0; i < req->r_num_ops; i++) {
		struct ceph_osd_req_op *op = &req->r_ops[i];

		seq_printf(s, "%s%s", (i == 0 ? "\t" : ","),
			   ceph_osd_op_name(op->op));
		if (op->op == CEPH_OSD_OP_WATCH)
			seq_printf(s, "-%s",
				   ceph_osd_watch_op_name(op->watch.op));
	}

	seq_putc(s, '\n');
}

static void dump_requests(struct seq_file *s, struct ceph_osd *osd)
{
	struct rb_node *n;

	mutex_lock(&osd->lock);
	for (n = rb_first(&osd->o_requests); n; n = rb_next(n)) {
		struct ceph_osd_request *req =
		    rb_entry(n, struct ceph_osd_request, r_node);

		dump_request(s, req);
	}

	mutex_unlock(&osd->lock);
}

static void dump_linger_request(struct seq_file *s,
				struct ceph_osd_linger_request *lreq)
{
	seq_printf(s, "%llu\t", lreq->linger_id);
	dump_target(s, &lreq->t);

	seq_printf(s, "\t%u\t%s%s/%d\n", lreq->register_gen,
		   lreq->is_watch ? "W" : "N", lreq->committed ? "C" : "",
		   lreq->last_error);
}

static void dump_linger_requests(struct seq_file *s, struct ceph_osd *osd)
{
	struct rb_node *n;

	mutex_lock(&osd->lock);
	for (n = rb_first(&osd->o_linger_requests); n; n = rb_next(n)) {
		struct ceph_osd_linger_request *lreq =
		    rb_entry(n, struct ceph_osd_linger_request, node);

		dump_linger_request(s, lreq);
	}

	mutex_unlock(&osd->lock);
}

static void dump_snapid(struct seq_file *s, u64 snapid)
{
	if (snapid == CEPH_NOSNAP)
		seq_puts(s, "head");
	else if (snapid == CEPH_SNAPDIR)
		seq_puts(s, "snapdir");
	else
		seq_printf(s, "%llx", snapid);
}

static void dump_name_escaped(struct seq_file *s, unsigned char *name,
			      size_t len)
{
	size_t i;

	for (i = 0; i < len; i++) {
		if (name[i] == '%' || name[i] == ':' || name[i] == '/' ||
		    name[i] < 32 || name[i] >= 127) {
			seq_printf(s, "%%%02x", name[i]);
		} else {
			seq_putc(s, name[i]);
		}
	}
}

static void dump_hoid(struct seq_file *s, const struct ceph_hobject_id *hoid)
{
	if (hoid->snapid == 0 && hoid->hash == 0 && !hoid->is_max &&
	    hoid->pool == S64_MIN) {
		seq_puts(s, "MIN");
		return;
	}
	if (hoid->is_max) {
		seq_puts(s, "MAX");
		return;
	}
	seq_printf(s, "%lld:%08x:", hoid->pool, hoid->hash_reverse_bits);
	dump_name_escaped(s, hoid->nspace, hoid->nspace_len);
	seq_putc(s, ':');
	dump_name_escaped(s, hoid->key, hoid->key_len);
	seq_putc(s, ':');
	dump_name_escaped(s, hoid->oid, hoid->oid_len);
	seq_putc(s, ':');
	dump_snapid(s, hoid->snapid);
}

static void dump_backoffs(struct seq_file *s, struct ceph_osd *osd)
{
	struct rb_node *n;

	mutex_lock(&osd->lock);
	for (n = rb_first(&osd->o_backoffs_by_id); n; n = rb_next(n)) {
		struct ceph_osd_backoff *backoff =
		    rb_entry(n, struct ceph_osd_backoff, id_node);

		seq_printf(s, "osd%d\t", osd->o_osd);
		dump_spgid(s, &backoff->spgid);
		seq_printf(s, "\t%llu\t", backoff->id);
		dump_hoid(s, backoff->begin);
		seq_putc(s, '\t');
		dump_hoid(s, backoff->end);
		seq_putc(s, '\n');
	}

	mutex_unlock(&osd->lock);
}

static int osdc_show(struct seq_file *s, void *pp)
{
	struct ceph_client *client = s->private;
	struct ceph_osd_client *osdc = &client->osdc;
	struct rb_node *n;

	down_read(&osdc->lock);
	seq_printf(s, "REQUESTS %d homeless %d\n",
		   atomic_read(&osdc->num_requests),
		   atomic_read(&osdc->num_homeless));
	for (n = rb_first(&osdc->osds); n; n = rb_next(n)) {
		struct ceph_osd *osd = rb_entry(n, struct ceph_osd, o_node);

		dump_requests(s, osd);
	}
	dump_requests(s, &osdc->homeless_osd);

	seq_puts(s, "LINGER REQUESTS\n");
	for (n = rb_first(&osdc->osds); n; n = rb_next(n)) {
		struct ceph_osd *osd = rb_entry(n, struct ceph_osd, o_node);

		dump_linger_requests(s, osd);
	}
	dump_linger_requests(s, &osdc->homeless_osd);

	seq_puts(s, "BACKOFFS\n");
	for (n = rb_first(&osdc->osds); n; n = rb_next(n)) {
		struct ceph_osd *osd = rb_entry(n, struct ceph_osd, o_node);

		dump_backoffs(s, osd);
	}

	up_read(&osdc->lock);
	return 0;
}

static int client_options_show(struct seq_file *s, void *p)
{
	struct ceph_client *client = s->private;
	int ret;

	ret = ceph_print_client_options(s, client);
	if (ret)
		return ret;

	seq_putc(s, '\n');
	return 0;
}

CEPH_DEFINE_SHOW_FUNC(monmap_show)
CEPH_DEFINE_SHOW_FUNC(osdmap_show)
CEPH_DEFINE_SHOW_FUNC(monc_show)
CEPH_DEFINE_SHOW_FUNC(osdc_show)
CEPH_DEFINE_SHOW_FUNC(client_options_show)

int ceph_debugfs_init(void)
{
	ceph_debugfs_dir = debugfs_create_dir("ceph", NULL);
	if (!ceph_debugfs_dir)
		return -ENOMEM;
	return 0;
}

void ceph_debugfs_cleanup(void)
{
	debugfs_remove(ceph_debugfs_dir);
}

int ceph_debugfs_client_init(struct ceph_client *client)
{
	int ret = -ENOMEM;
	char name[80];

	snprintf(name, sizeof(name), "%pU.client%lld", &client->fsid,
		 client->monc.auth->global_id);

	dout("ceph_debugfs_client_init %p %s\n", client, name);

	BUG_ON(client->debugfs_dir);
	client->debugfs_dir = debugfs_create_dir(name, ceph_debugfs_dir);
	if (!client->debugfs_dir)
		goto out;

	client->monc.debugfs_file = debugfs_create_file("monc",
						      0600,
						      client->debugfs_dir,
						      client,
						      &monc_show_fops);
	if (!client->monc.debugfs_file)
		goto out;

	client->osdc.debugfs_file = debugfs_create_file("osdc",
						      0600,
						      client->debugfs_dir,
						      client,
						      &osdc_show_fops);
	if (!client->osdc.debugfs_file)
		goto out;

	client->debugfs_monmap = debugfs_create_file("monmap",
					0600,
					client->debugfs_dir,
					client,
					&monmap_show_fops);
	if (!client->debugfs_monmap)
		goto out;

	client->debugfs_osdmap = debugfs_create_file("osdmap",
					0600,
					client->debugfs_dir,
					client,
					&osdmap_show_fops);
	if (!client->debugfs_osdmap)
		goto out;

	client->debugfs_options = debugfs_create_file("client_options",
					0600,
					client->debugfs_dir,
					client,
					&client_options_show_fops);
	if (!client->debugfs_options)
		goto out;

	return 0;

out:
	ceph_debugfs_client_cleanup(client);
	return ret;
}

void ceph_debugfs_client_cleanup(struct ceph_client *client)
{
	dout("ceph_debugfs_client_cleanup %p\n", client);
	debugfs_remove(client->debugfs_options);
	debugfs_remove(client->debugfs_osdmap);
	debugfs_remove(client->debugfs_monmap);
	debugfs_remove(client->osdc.debugfs_file);
	debugfs_remove(client->monc.debugfs_file);
	debugfs_remove(client->debugfs_dir);
}

#else  /* CONFIG_DEBUG_FS */

int ceph_debugfs_init(void)
{
	return 0;
}

void ceph_debugfs_cleanup(void)
{
}

int ceph_debugfs_client_init(struct ceph_client *client)
{
	return 0;
}

void ceph_debugfs_client_cleanup(struct ceph_client *client)
{
}

#endif  /* CONFIG_DEBUG_FS */

EXPORT_SYMBOL(ceph_debugfs_init);
EXPORT_SYMBOL(ceph_debugfs_cleanup);
Commit	Line	Data
b2441318	1	// SPDX-License-Identifier: GPL-2.0
3d14c5d2 YS	2	#include <linux/ceph/ceph_debug.h>
	3
	4	#include <linux/device.h>
	5	#include <linux/slab.h>
	6	#include <linux/module.h>
	7	#include <linux/ctype.h>
	8	#include <linux/debugfs.h>
	9	#include <linux/seq_file.h>
	10
	11	#include <linux/ceph/libceph.h>
	12	#include <linux/ceph/mon_client.h>
	13	#include <linux/ceph/auth.h>
	14	#include <linux/ceph/debugfs.h>
	15
	16	#ifdef CONFIG_DEBUG_FS
	17
	18	/*
	19	* Implement /sys/kernel/debug/ceph fun
	20	*
	21	* /sys/kernel/debug/ceph/client* - an instance of the ceph client
	22	* .../osdmap - current osdmap
	23	* .../monmap - current monmap
	24	* .../osdc - active osd requests
	25	* .../monc - mon client state
5cf7bd30	26	* .../client_options - libceph-only (i.e. not rbd or cephfs) options
3d14c5d2 YS	27	* .../dentry_lru - dump contents of dentry lru
	28	* .../caps - expose cap (reservation) stats
	29	* .../bdi - symlink to ../../bdi/something
	30	*/
	31
	32	static struct dentry *ceph_debugfs_dir;
	33
	34	static int monmap_show(struct seq_file s, void p)
	35	{
	36	int i;
	37	struct ceph_client *client = s->private;
	38
	39	if (client->monc.monmap == NULL)
	40	return 0;
	41
	42	seq_printf(s, "epoch %d\n", client->monc.monmap->epoch);
	43	for (i = 0; i < client->monc.monmap->num_mon; i++) {
	44	struct ceph_entity_inst *inst =
	45	&client->monc.monmap->mon_inst[i];
	46
	47	seq_printf(s, "\t%s%lld\t%s\n",
	48	ENTITY_NAME(inst->name),
	49	ceph_pr_addr(&inst->addr.in_addr));
	50	}
	51	return 0;
	52	}
	53
	54	static int osdmap_show(struct seq_file s, void p)
	55	{
	56	int i;
	57	struct ceph_client *client = s->private;
b4f34795 ID	58	struct ceph_osd_client *osdc = &client->osdc;
b4f34795 ID	59	struct ceph_osdmap *map = osdc->osdmap;
3d14c5d2 YS	60	struct rb_node *n;
3d14c5d2 YS	61
35fea3a1	62	if (map == NULL)
3d14c5d2	63	return 0;
35fea3a1	64
b4f34795	65	down_read(&osdc->lock);
58eb7932 JL	66	seq_printf(s, "epoch %u barrier %u flags 0x%x\n", map->epoch,
58eb7932 JL	67	osdc->epoch_barrier, map->flags);
35fea3a1 ID	68
35fea3a1 ID	69	for (n = rb_first(&map->pg_pools); n; n = rb_next(n)) {
04812acf	70	struct ceph_pg_pool_info *pi =
3d14c5d2	71	rb_entry(n, struct ceph_pg_pool_info, node);
35fea3a1	72
04812acf ID	73	seq_printf(s, "pool %lld '%s' type %d size %d min_size %d pg_num %u pg_num_mask %d flags 0x%llx lfor %u read_tier %lld write_tier %lld\n",
	74	pi->id, pi->name, pi->type, pi->size, pi->min_size,
	75	pi->pg_num, pi->pg_num_mask, pi->flags,
	76	pi->last_force_request_resend, pi->read_tier,
	77	pi->write_tier);
3d14c5d2	78	}
35fea3a1 ID	79	for (i = 0; i < map->max_osd; i++) {
35fea3a1 ID	80	struct ceph_entity_addr *addr = &map->osd_addr[i];
0bb05da2	81	u32 state = map->osd_state[i];
3d14c5d2 YS	82	char sb[64];
3d14c5d2 YS	83
2cfa34f2	84	seq_printf(s, "osd%d\t%s\t%3d%%\t(%s)\t%3d%%\n",
3d14c5d2	85	i, ceph_pr_addr(&addr->in_addr),
35fea3a1	86	((map->osd_weight[i]*100) >> 16),
2cfa34f2 ID	87	ceph_osdmap_state_str(sb, sizeof(sb), state),
2cfa34f2 ID	88	((ceph_get_primary_affinity(map, i)*100) >> 16));
3d14c5d2	89	}
1c00240e ID	90	for (n = rb_first(&map->pg_temp); n; n = rb_next(n)) {
	91	struct ceph_pg_mapping *pg =
	92	rb_entry(n, struct ceph_pg_mapping, node);
	93
	94	seq_printf(s, "pg_temp %llu.%x [", pg->pgid.pool,
	95	pg->pgid.seed);
35a935d7	96	for (i = 0; i < pg->pg_temp.len; i++)
1c00240e	97	seq_printf(s, "%s%d", (i == 0 ? "" : ","),
35a935d7	98	pg->pg_temp.osds[i]);
1c00240e ID	99	seq_printf(s, "]\n");
1c00240e ID	100	}
9686f94c ID	101	for (n = rb_first(&map->primary_temp); n; n = rb_next(n)) {
	102	struct ceph_pg_mapping *pg =
	103	rb_entry(n, struct ceph_pg_mapping, node);
	104
	105	seq_printf(s, "primary_temp %llu.%x %d\n", pg->pgid.pool,
	106	pg->pgid.seed, pg->primary_temp.osd);
	107	}
6f428df4 ID	108	for (n = rb_first(&map->pg_upmap); n; n = rb_next(n)) {
	109	struct ceph_pg_mapping *pg =
	110	rb_entry(n, struct ceph_pg_mapping, node);
	111
	112	seq_printf(s, "pg_upmap %llu.%x [", pg->pgid.pool,
	113	pg->pgid.seed);
	114	for (i = 0; i < pg->pg_upmap.len; i++)
	115	seq_printf(s, "%s%d", (i == 0 ? "" : ","),
	116	pg->pg_upmap.osds[i]);
	117	seq_printf(s, "]\n");
	118	}
	119	for (n = rb_first(&map->pg_upmap_items); n; n = rb_next(n)) {
	120	struct ceph_pg_mapping *pg =
	121	rb_entry(n, struct ceph_pg_mapping, node);
	122
	123	seq_printf(s, "pg_upmap_items %llu.%x [", pg->pgid.pool,
	124	pg->pgid.seed);
	125	for (i = 0; i < pg->pg_upmap_items.len; i++)
	126	seq_printf(s, "%s%d->%d", (i == 0 ? "" : ","),
	127	pg->pg_upmap_items.from_to[i][0],
	128	pg->pg_upmap_items.from_to[i][1]);
	129	seq_printf(s, "]\n");
	130	}
35fea3a1	131
b4f34795	132	up_read(&osdc->lock);
3d14c5d2 YS	133	return 0;
	134	}
	135
	136	static int monc_show(struct seq_file s, void p)
	137	{
	138	struct ceph_client *client = s->private;
	139	struct ceph_mon_generic_request *req;
	140	struct ceph_mon_client *monc = &client->monc;
	141	struct rb_node *rp;
82dcabad	142	int i;
3d14c5d2 YS	143
	144	mutex_lock(&monc->mutex);
	145
82dcabad ID	146	for (i = 0; i < ARRAY_SIZE(monc->subs); i++) {
	147	seq_printf(s, "have %s %u", ceph_sub_str[i],
	148	monc->subs[i].have);
	149	if (monc->subs[i].want)
	150	seq_printf(s, " want %llu%s",
	151	le64_to_cpu(monc->subs[i].item.start),
	152	(monc->subs[i].item.flags &
	153	CEPH_SUBSCRIBE_ONETIME ? "" : "+"));
	154	seq_putc(s, '\n');
	155	}
737cc81e	156	seq_printf(s, "fs_cluster_id %d\n", monc->fs_cluster_id);
3d14c5d2 YS	157
	158	for (rp = rb_first(&monc->generic_request_tree); rp; rp = rb_next(rp)) {
	159	__u16 op;
	160	req = rb_entry(rp, struct ceph_mon_generic_request, node);
	161	op = le16_to_cpu(req->request->hdr.type);
	162	if (op == CEPH_MSG_STATFS)
002b36ba	163	seq_printf(s, "%llu statfs\n", req->tid);
513a8243 ID	164	else if (op == CEPH_MSG_MON_GET_VERSION)
513a8243 ID	165	seq_printf(s, "%llu mon_get_version", req->tid);
3d14c5d2	166	else
002b36ba	167	seq_printf(s, "%llu unknown\n", req->tid);
3d14c5d2 YS	168	}
	169
	170	mutex_unlock(&monc->mutex);
	171	return 0;
	172	}
	173
dc98ff72 ID	174	static void dump_spgid(struct seq_file s, const struct ceph_spg spgid)
	175	{
	176	seq_printf(s, "%llu.%x", spgid->pgid.pool, spgid->pgid.seed);
	177	if (spgid->shard != CEPH_SPG_NOSHARD)
	178	seq_printf(s, "s%d", spgid->shard);
	179	}
	180
bb873b53 ID	181	static void dump_target(struct seq_file s, struct ceph_osd_request_target t)
	182	{
	183	int i;
	184
dc98ff72 ID	185	seq_printf(s, "osd%d\t%llu.%x\t", t->osd, t->pgid.pool, t->pgid.seed);
	186	dump_spgid(s, &t->spgid);
	187	seq_puts(s, "\t[");
bb873b53 ID	188	for (i = 0; i < t->up.size; i++)
	189	seq_printf(s, "%s%d", (!i ? "" : ","), t->up.osds[i]);
	190	seq_printf(s, "]/%d\t[", t->up.primary);
	191	for (i = 0; i < t->acting.size; i++)
	192	seq_printf(s, "%s%d", (!i ? "" : ","), t->acting.osds[i]);
04c7d789	193	seq_printf(s, "]/%d\te%u\t", t->acting.primary, t->epoch);
30c156d9 YZ	194	if (t->target_oloc.pool_ns) {
	195	seq_printf(s, "%pE/%pE\t0x%x",
	196	(int)t->target_oloc.pool_ns->len,
	197	t->target_oloc.pool_ns->str,
	198	t->target_oid.name_len, t->target_oid.name, t->flags);
	199	} else {
	200	seq_printf(s, "%*pE\t0x%x", t->target_oid.name_len,
	201	t->target_oid.name, t->flags);
	202	}
bb873b53 ID	203	if (t->paused)
	204	seq_puts(s, "\tP");
	205	}
	206
	207	static void dump_request(struct seq_file s, struct ceph_osd_request req)
	208	{
	209	int i;
	210
	211	seq_printf(s, "%llu\t", req->r_tid);
	212	dump_target(s, &req->r_t);
	213
aa26d662	214	seq_printf(s, "\t%d", req->r_attempts);
bb873b53 ID	215
	216	for (i = 0; i < req->r_num_ops; i++) {
	217	struct ceph_osd_req_op *op = &req->r_ops[i];
	218
	219	seq_printf(s, "%s%s", (i == 0 ? "\t" : ","),
	220	ceph_osd_op_name(op->op));
922dab61 ID	221	if (op->op == CEPH_OSD_OP_WATCH)
	222	seq_printf(s, "-%s",
	223	ceph_osd_watch_op_name(op->watch.op));
bb873b53 ID	224	}
	225
	226	seq_putc(s, '\n');
	227	}
	228
5aea3dcd ID	229	static void dump_requests(struct seq_file s, struct ceph_osd osd)
	230	{
	231	struct rb_node *n;
	232
	233	mutex_lock(&osd->lock);
	234	for (n = rb_first(&osd->o_requests); n; n = rb_next(n)) {
	235	struct ceph_osd_request *req =
	236	rb_entry(n, struct ceph_osd_request, r_node);
	237
	238	dump_request(s, req);
	239	}
	240
	241	mutex_unlock(&osd->lock);
	242	}
	243
922dab61 ID	244	static void dump_linger_request(struct seq_file *s,
	245	struct ceph_osd_linger_request *lreq)
	246	{
	247	seq_printf(s, "%llu\t", lreq->linger_id);
	248	dump_target(s, &lreq->t);
	249
19079203 ID	250	seq_printf(s, "\t%u\t%s%s/%d\n", lreq->register_gen,
	251	lreq->is_watch ? "W" : "N", lreq->committed ? "C" : "",
	252	lreq->last_error);
922dab61 ID	253	}
	254
	255	static void dump_linger_requests(struct seq_file s, struct ceph_osd osd)
	256	{
	257	struct rb_node *n;
	258
	259	mutex_lock(&osd->lock);
	260	for (n = rb_first(&osd->o_linger_requests); n; n = rb_next(n)) {
	261	struct ceph_osd_linger_request *lreq =
	262	rb_entry(n, struct ceph_osd_linger_request, node);
	263
	264	dump_linger_request(s, lreq);
	265	}
	266
	267	mutex_unlock(&osd->lock);
	268	}
	269
a02a946d ID	270	static void dump_snapid(struct seq_file *s, u64 snapid)
	271	{
	272	if (snapid == CEPH_NOSNAP)
	273	seq_puts(s, "head");
	274	else if (snapid == CEPH_SNAPDIR)
	275	seq_puts(s, "snapdir");
	276	else
	277	seq_printf(s, "%llx", snapid);
	278	}
	279
	280	static void dump_name_escaped(struct seq_file s, unsigned char name,
	281	size_t len)
	282	{
	283	size_t i;
	284
	285	for (i = 0; i < len; i++) {
	286	if (name[i] == '%' \|\| name[i] == ':' \|\| name[i] == '/' \|\|
	287	name[i] < 32 \|\| name[i] >= 127) {
	288	seq_printf(s, "%%%02x", name[i]);
	289	} else {
	290	seq_putc(s, name[i]);
	291	}
	292	}
	293	}
	294
	295	static void dump_hoid(struct seq_file s, const struct ceph_hobject_id hoid)
	296	{
	297	if (hoid->snapid == 0 && hoid->hash == 0 && !hoid->is_max &&
	298	hoid->pool == S64_MIN) {
	299	seq_puts(s, "MIN");
	300	return;
	301	}
	302	if (hoid->is_max) {
	303	seq_puts(s, "MAX");
	304	return;
	305	}
	306	seq_printf(s, "%lld:%08x:", hoid->pool, hoid->hash_reverse_bits);
	307	dump_name_escaped(s, hoid->nspace, hoid->nspace_len);
	308	seq_putc(s, ':');
	309	dump_name_escaped(s, hoid->key, hoid->key_len);
	310	seq_putc(s, ':');
	311	dump_name_escaped(s, hoid->oid, hoid->oid_len);
	312	seq_putc(s, ':');
	313	dump_snapid(s, hoid->snapid);
	314	}
	315
	316	static void dump_backoffs(struct seq_file s, struct ceph_osd osd)
	317	{
	318	struct rb_node *n;
	319
	320	mutex_lock(&osd->lock);
	321	for (n = rb_first(&osd->o_backoffs_by_id); n; n = rb_next(n)) {
	322	struct ceph_osd_backoff *backoff =
	323	rb_entry(n, struct ceph_osd_backoff, id_node);
	324
	325	seq_printf(s, "osd%d\t", osd->o_osd);
	326	dump_spgid(s, &backoff->spgid);
	327	seq_printf(s, "\t%llu\t", backoff->id);
	328	dump_hoid(s, backoff->begin);
	329	seq_putc(s, '\t');
	330	dump_hoid(s, backoff->end);
	331	seq_putc(s, '\n');
	332	}
	333
334	mutex_unlock(&osd->lock);
335	}
336
3d14c5d2 YS	337	static int osdc_show(struct seq_file s, void pp)
	338	{
	339	struct ceph_client *client = s->private;
	340	struct ceph_osd_client *osdc = &client->osdc;
5aea3dcd	341	struct rb_node *n;
3d14c5d2	342
5aea3dcd ID	343	down_read(&osdc->lock);
	344	seq_printf(s, "REQUESTS %d homeless %d\n",
	345	atomic_read(&osdc->num_requests),
	346	atomic_read(&osdc->num_homeless));
	347	for (n = rb_first(&osdc->osds); n; n = rb_next(n)) {
	348	struct ceph_osd *osd = rb_entry(n, struct ceph_osd, o_node);
3d14c5d2	349
5aea3dcd	350	dump_requests(s, osd);
3d14c5d2	351	}
5aea3dcd ID	352	dump_requests(s, &osdc->homeless_osd);
5aea3dcd ID	353
922dab61 ID	354	seq_puts(s, "LINGER REQUESTS\n");
	355	for (n = rb_first(&osdc->osds); n; n = rb_next(n)) {
	356	struct ceph_osd *osd = rb_entry(n, struct ceph_osd, o_node);
	357
	358	dump_linger_requests(s, osd);
	359	}
	360	dump_linger_requests(s, &osdc->homeless_osd);
	361
a02a946d ID	362	seq_puts(s, "BACKOFFS\n");
	363	for (n = rb_first(&osdc->osds); n; n = rb_next(n)) {
	364	struct ceph_osd *osd = rb_entry(n, struct ceph_osd, o_node);
	365
	366	dump_backoffs(s, osd);
	367	}
	368
5aea3dcd	369	up_read(&osdc->lock);
3d14c5d2 YS	370	return 0;
	371	}
	372
5cf7bd30 ID	373	static int client_options_show(struct seq_file s, void p)
	374	{
	375	struct ceph_client *client = s->private;
	376	int ret;
	377
	378	ret = ceph_print_client_options(s, client);
	379	if (ret)
	380	return ret;
	381
	382	seq_putc(s, '\n');
	383	return 0;
	384	}
	385
3d14c5d2 YS	386	CEPH_DEFINE_SHOW_FUNC(monmap_show)
	387	CEPH_DEFINE_SHOW_FUNC(osdmap_show)
	388	CEPH_DEFINE_SHOW_FUNC(monc_show)
	389	CEPH_DEFINE_SHOW_FUNC(osdc_show)
5cf7bd30	390	CEPH_DEFINE_SHOW_FUNC(client_options_show)
3d14c5d2 YS	391
	392	int ceph_debugfs_init(void)
	393	{
	394	ceph_debugfs_dir = debugfs_create_dir("ceph", NULL);
	395	if (!ceph_debugfs_dir)
	396	return -ENOMEM;
	397	return 0;
	398	}
	399
	400	void ceph_debugfs_cleanup(void)
	401	{
	402	debugfs_remove(ceph_debugfs_dir);
	403	}
	404
	405	int ceph_debugfs_client_init(struct ceph_client *client)
	406	{
	407	int ret = -ENOMEM;
	408	char name[80];
	409
	410	snprintf(name, sizeof(name), "%pU.client%lld", &client->fsid,
	411	client->monc.auth->global_id);
	412
d1c338a5 SW	413	dout("ceph_debugfs_client_init %p %s\n", client, name);
	414
	415	BUG_ON(client->debugfs_dir);
3d14c5d2 YS	416	client->debugfs_dir = debugfs_create_dir(name, ceph_debugfs_dir);
	417	if (!client->debugfs_dir)
	418	goto out;
	419
	420	client->monc.debugfs_file = debugfs_create_file("monc",
	421	0600,
	422	client->debugfs_dir,
	423	client,
	424	&monc_show_fops);
	425	if (!client->monc.debugfs_file)
	426	goto out;
	427
	428	client->osdc.debugfs_file = debugfs_create_file("osdc",
	429	0600,
	430	client->debugfs_dir,
	431	client,
	432	&osdc_show_fops);
	433	if (!client->osdc.debugfs_file)
	434	goto out;
	435
	436	client->debugfs_monmap = debugfs_create_file("monmap",
	437	0600,
	438	client->debugfs_dir,
	439	client,
	440	&monmap_show_fops);
	441	if (!client->debugfs_monmap)
	442	goto out;
	443
	444	client->debugfs_osdmap = debugfs_create_file("osdmap",
	445	0600,
	446	client->debugfs_dir,
	447	client,
	448	&osdmap_show_fops);
	449	if (!client->debugfs_osdmap)
	450	goto out;
	451
5cf7bd30 ID	452	client->debugfs_options = debugfs_create_file("client_options",
	453	0600,
	454	client->debugfs_dir,
	455	client,
	456	&client_options_show_fops);
	457	if (!client->debugfs_options)
	458	goto out;
	459
3d14c5d2 YS	460	return 0;
	461
	462	out:
	463	ceph_debugfs_client_cleanup(client);
	464	return ret;
	465	}
	466
	467	void ceph_debugfs_client_cleanup(struct ceph_client *client)
	468	{
d1c338a5	469	dout("ceph_debugfs_client_cleanup %p\n", client);
5cf7bd30	470	debugfs_remove(client->debugfs_options);
3d14c5d2 YS	471	debugfs_remove(client->debugfs_osdmap);
	472	debugfs_remove(client->debugfs_monmap);
	473	debugfs_remove(client->osdc.debugfs_file);
	474	debugfs_remove(client->monc.debugfs_file);
	475	debugfs_remove(client->debugfs_dir);
	476	}
	477
	478	#else /* CONFIG_DEBUG_FS */
	479
	480	int ceph_debugfs_init(void)
	481	{
	482	return 0;
	483	}
	484
	485	void ceph_debugfs_cleanup(void)
	486	{
	487	}
	488
602adf40	489	int ceph_debugfs_client_init(struct ceph_client *client)
3d14c5d2 YS	490	{
	491	return 0;
	492	}
	493
	494	void ceph_debugfs_client_cleanup(struct ceph_client *client)
	495	{
	496	}
	497
	498	#endif /* CONFIG_DEBUG_FS */
	499
	500	EXPORT_SYMBOL(ceph_debugfs_init);
	501	EXPORT_SYMBOL(ceph_debugfs_cleanup);