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
25 *      .../dentry_lru  - dump contents of dentry lru
26 *      .../caps        - expose cap (reservation) stats
27 *      .../bdi         - symlink to ../../bdi/something
28 */
29
30static struct dentry *ceph_debugfs_dir;
31
32static int monmap_show(struct seq_file *s, void *p)
33{
34	int i;
35	struct ceph_client *client = s->private;
36
37	if (client->monc.monmap == NULL)
38		return 0;
39
40	seq_printf(s, "epoch %d\n", client->monc.monmap->epoch);
41	for (i = 0; i < client->monc.monmap->num_mon; i++) {
42		struct ceph_entity_inst *inst =
43			&client->monc.monmap->mon_inst[i];
44
45		seq_printf(s, "\t%s%lld\t%s\n",
46			   ENTITY_NAME(inst->name),
47			   ceph_pr_addr(&inst->addr.in_addr));
48	}
49	return 0;
50}
51
52static int osdmap_show(struct seq_file *s, void *p)
53{
54	int i;
55	struct ceph_client *client = s->private;
56	struct ceph_osdmap *map = client->osdc.osdmap;
57	struct rb_node *n;
58
59	if (map == NULL)
60		return 0;
61
62	seq_printf(s, "epoch %d\n", map->epoch);
63	seq_printf(s, "flags%s%s\n",
64		   (map->flags & CEPH_OSDMAP_NEARFULL) ?  " NEARFULL" : "",
65		   (map->flags & CEPH_OSDMAP_FULL) ?  " FULL" : "");
66
67	for (n = rb_first(&map->pg_pools); n; n = rb_next(n)) {
68		struct ceph_pg_pool_info *pool =
69			rb_entry(n, struct ceph_pg_pool_info, node);
70
71		seq_printf(s, "pool %lld pg_num %u (%d) read_tier %lld write_tier %lld\n",
72			   pool->id, pool->pg_num, pool->pg_num_mask,
73			   pool->read_tier, pool->write_tier);
74	}
75	for (i = 0; i < map->max_osd; i++) {
76		struct ceph_entity_addr *addr = &map->osd_addr[i];
77		int state = map->osd_state[i];
78		char sb[64];
79
80		seq_printf(s, "osd%d\t%s\t%3d%%\t(%s)\t%3d%%\n",
81			   i, ceph_pr_addr(&addr->in_addr),
82			   ((map->osd_weight[i]*100) >> 16),
83			   ceph_osdmap_state_str(sb, sizeof(sb), state),
84			   ((ceph_get_primary_affinity(map, i)*100) >> 16));
85	}
86	for (n = rb_first(&map->pg_temp); n; n = rb_next(n)) {
87		struct ceph_pg_mapping *pg =
88			rb_entry(n, struct ceph_pg_mapping, node);
89
90		seq_printf(s, "pg_temp %llu.%x [", pg->pgid.pool,
91			   pg->pgid.seed);
92		for (i = 0; i < pg->pg_temp.len; i++)
93			seq_printf(s, "%s%d", (i == 0 ? "" : ","),
94				   pg->pg_temp.osds[i]);
95		seq_printf(s, "]\n");
96	}
97	for (n = rb_first(&map->primary_temp); n; n = rb_next(n)) {
98		struct ceph_pg_mapping *pg =
99			rb_entry(n, struct ceph_pg_mapping, node);
100
101		seq_printf(s, "primary_temp %llu.%x %d\n", pg->pgid.pool,
102			   pg->pgid.seed, pg->primary_temp.osd);
103	}
104
105	return 0;
106}
107
108static int monc_show(struct seq_file *s, void *p)
109{
110	struct ceph_client *client = s->private;
111	struct ceph_mon_generic_request *req;
112	struct ceph_mon_client *monc = &client->monc;
113	struct rb_node *rp;
114
115	mutex_lock(&monc->mutex);
116
117	if (monc->have_mdsmap)
118		seq_printf(s, "have mdsmap %u\n", (unsigned int)monc->have_mdsmap);
119	if (monc->have_osdmap)
120		seq_printf(s, "have osdmap %u\n", (unsigned int)monc->have_osdmap);
121	if (monc->want_next_osdmap)
122		seq_printf(s, "want next osdmap\n");
123
124	for (rp = rb_first(&monc->generic_request_tree); rp; rp = rb_next(rp)) {
125		__u16 op;
126		req = rb_entry(rp, struct ceph_mon_generic_request, node);
127		op = le16_to_cpu(req->request->hdr.type);
128		if (op == CEPH_MSG_STATFS)
129			seq_printf(s, "%llu statfs\n", req->tid);
130		else if (op == CEPH_MSG_POOLOP)
131			seq_printf(s, "%llu poolop\n", req->tid);
132		else if (op == CEPH_MSG_MON_GET_VERSION)
133			seq_printf(s, "%llu mon_get_version", req->tid);
134		else
135			seq_printf(s, "%llu unknown\n", req->tid);
136	}
137
138	mutex_unlock(&monc->mutex);
139	return 0;
140}
141
142static int osdc_show(struct seq_file *s, void *pp)
143{
144	struct ceph_client *client = s->private;
145	struct ceph_osd_client *osdc = &client->osdc;
146	struct rb_node *p;
147
148	mutex_lock(&osdc->request_mutex);
149	for (p = rb_first(&osdc->requests); p; p = rb_next(p)) {
150		struct ceph_osd_request *req;
151		unsigned int i;
152		int opcode;
153
154		req = rb_entry(p, struct ceph_osd_request, r_node);
155
156		seq_printf(s, "%lld\tosd%d\t%lld.%x\t", req->r_tid,
157			   req->r_osd ? req->r_osd->o_osd : -1,
158			   req->r_pgid.pool, req->r_pgid.seed);
159
160		seq_printf(s, "%.*s", req->r_base_oid.name_len,
161			   req->r_base_oid.name);
162
163		if (req->r_reassert_version.epoch)
164			seq_printf(s, "\t%u'%llu",
165			   (unsigned int)le32_to_cpu(req->r_reassert_version.epoch),
166			   le64_to_cpu(req->r_reassert_version.version));
167		else
168			seq_printf(s, "\t");
169
170		for (i = 0; i < req->r_num_ops; i++) {
171			opcode = req->r_ops[i].op;
172			seq_printf(s, "%s%s", (i == 0 ? "\t" : ","),
173				   ceph_osd_op_name(opcode));
174		}
175
176		seq_printf(s, "\n");
177	}
178	mutex_unlock(&osdc->request_mutex);
179	return 0;
180}
181
182CEPH_DEFINE_SHOW_FUNC(monmap_show)
183CEPH_DEFINE_SHOW_FUNC(osdmap_show)
184CEPH_DEFINE_SHOW_FUNC(monc_show)
185CEPH_DEFINE_SHOW_FUNC(osdc_show)
186
187int ceph_debugfs_init(void)
188{
189	ceph_debugfs_dir = debugfs_create_dir("ceph", NULL);
190	if (!ceph_debugfs_dir)
191		return -ENOMEM;
192	return 0;
193}
194
195void ceph_debugfs_cleanup(void)
196{
197	debugfs_remove(ceph_debugfs_dir);
198}
199
200int ceph_debugfs_client_init(struct ceph_client *client)
201{
202	int ret = -ENOMEM;
203	char name[80];
204
205	snprintf(name, sizeof(name), "%pU.client%lld", &client->fsid,
206		 client->monc.auth->global_id);
207
208	dout("ceph_debugfs_client_init %p %s\n", client, name);
209
210	BUG_ON(client->debugfs_dir);
211	client->debugfs_dir = debugfs_create_dir(name, ceph_debugfs_dir);
212	if (!client->debugfs_dir)
213		goto out;
214
215	client->monc.debugfs_file = debugfs_create_file("monc",
216						      0600,
217						      client->debugfs_dir,
218						      client,
219						      &monc_show_fops);
220	if (!client->monc.debugfs_file)
221		goto out;
222
223	client->osdc.debugfs_file = debugfs_create_file("osdc",
224						      0600,
225						      client->debugfs_dir,
226						      client,
227						      &osdc_show_fops);
228	if (!client->osdc.debugfs_file)
229		goto out;
230
231	client->debugfs_monmap = debugfs_create_file("monmap",
232					0600,
233					client->debugfs_dir,
234					client,
235					&monmap_show_fops);
236	if (!client->debugfs_monmap)
237		goto out;
238
239	client->debugfs_osdmap = debugfs_create_file("osdmap",
240					0600,
241					client->debugfs_dir,
242					client,
243					&osdmap_show_fops);
244	if (!client->debugfs_osdmap)
245		goto out;
246
247	return 0;
248
249out:
250	ceph_debugfs_client_cleanup(client);
251	return ret;
252}
253
254void ceph_debugfs_client_cleanup(struct ceph_client *client)
255{
256	dout("ceph_debugfs_client_cleanup %p\n", client);
257	debugfs_remove(client->debugfs_osdmap);
258	debugfs_remove(client->debugfs_monmap);
259	debugfs_remove(client->osdc.debugfs_file);
260	debugfs_remove(client->monc.debugfs_file);
261	debugfs_remove(client->debugfs_dir);
262}
263
264#else  /* CONFIG_DEBUG_FS */
265
266int ceph_debugfs_init(void)
267{
268	return 0;
269}
270
271void ceph_debugfs_cleanup(void)
272{
273}
274
275int ceph_debugfs_client_init(struct ceph_client *client)
276{
277	return 0;
278}
279
280void ceph_debugfs_client_cleanup(struct ceph_client *client)
281{
282}
283
284#endif  /* CONFIG_DEBUG_FS */
285
286EXPORT_SYMBOL(ceph_debugfs_init);
287EXPORT_SYMBOL(ceph_debugfs_cleanup);
288