[linux-2.6-block.git] / net / ceph / debugfs.c

#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];
		int 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);
	}

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