~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

TOMOYO Linux Cross Reference
Linux/net/ceph/debugfs.c

Version: ~ [ linux-5.12-rc7 ] ~ [ linux-5.11.13 ] ~ [ linux-5.10.29 ] ~ [ linux-5.9.16 ] ~ [ linux-5.8.18 ] ~ [ linux-5.7.19 ] ~ [ linux-5.6.19 ] ~ [ linux-5.5.19 ] ~ [ linux-5.4.111 ] ~ [ linux-5.3.18 ] ~ [ linux-5.2.21 ] ~ [ linux-5.1.21 ] ~ [ linux-5.0.21 ] ~ [ linux-4.20.17 ] ~ [ linux-4.19.186 ] ~ [ linux-4.18.20 ] ~ [ linux-4.17.19 ] ~ [ linux-4.16.18 ] ~ [ linux-4.15.18 ] ~ [ linux-4.14.230 ] ~ [ linux-4.13.16 ] ~ [ linux-4.12.14 ] ~ [ linux-4.11.12 ] ~ [ linux-4.10.17 ] ~ [ linux-4.9.266 ] ~ [ linux-4.8.17 ] ~ [ linux-4.7.10 ] ~ [ linux-4.6.7 ] ~ [ linux-4.5.7 ] ~ [ linux-4.4.266 ] ~ [ linux-4.3.6 ] ~ [ linux-4.2.8 ] ~ [ linux-4.1.52 ] ~ [ linux-4.0.9 ] ~ [ linux-3.18.140 ] ~ [ linux-3.16.85 ] ~ [ linux-3.14.79 ] ~ [ linux-3.12.74 ] ~ [ linux-3.10.108 ] ~ [ linux-2.6.32.71 ] ~ [ linux-2.6.0 ] ~ [ linux-2.4.37.11 ] ~ [ unix-v6-master ] ~ [ ccs-tools-1.8.5 ] ~ [ policy-sample ] ~
Architecture: ~ [ i386 ] ~ [ alpha ] ~ [ m68k ] ~ [ mips ] ~ [ ppc ] ~ [ sparc ] ~ [ sparc64 ] ~

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

~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

kernel.org | git.kernel.org | LWN.net | Project Home | Wiki (Japanese) | Wiki (English) | SVN repository | Mail admin

Linux® is a registered trademark of Linus Torvalds in the United States and other countries.
TOMOYO® is a registered trademark of NTT DATA CORPORATION.

osdn.jp