Merge tag 'ceph-for-4.17-rc1' of git://github.com/ceph/ceph-client
[sfrench/cifs-2.6.git] / fs / ceph / debugfs.c
1 // SPDX-License-Identifier: GPL-2.0
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 #include "super.h"
17
18 #ifdef CONFIG_DEBUG_FS
19
20 #include "mds_client.h"
21
22 static int mdsmap_show(struct seq_file *s, void *p)
23 {
24         int i;
25         struct ceph_fs_client *fsc = s->private;
26         struct ceph_mdsmap *mdsmap;
27
28         if (!fsc->mdsc || !fsc->mdsc->mdsmap)
29                 return 0;
30         mdsmap = fsc->mdsc->mdsmap;
31         seq_printf(s, "epoch %d\n", mdsmap->m_epoch);
32         seq_printf(s, "root %d\n", mdsmap->m_root);
33         seq_printf(s, "max_mds %d\n", mdsmap->m_max_mds);
34         seq_printf(s, "session_timeout %d\n", mdsmap->m_session_timeout);
35         seq_printf(s, "session_autoclose %d\n", mdsmap->m_session_autoclose);
36         for (i = 0; i < mdsmap->m_num_mds; i++) {
37                 struct ceph_entity_addr *addr = &mdsmap->m_info[i].addr;
38                 int state = mdsmap->m_info[i].state;
39                 seq_printf(s, "\tmds%d\t%s\t(%s)\n", i,
40                                ceph_pr_addr(&addr->in_addr),
41                                ceph_mds_state_name(state));
42         }
43         return 0;
44 }
45
46 /*
47  * mdsc debugfs
48  */
49 static int mdsc_show(struct seq_file *s, void *p)
50 {
51         struct ceph_fs_client *fsc = s->private;
52         struct ceph_mds_client *mdsc = fsc->mdsc;
53         struct ceph_mds_request *req;
54         struct rb_node *rp;
55         int pathlen;
56         u64 pathbase;
57         char *path;
58
59         mutex_lock(&mdsc->mutex);
60         for (rp = rb_first(&mdsc->request_tree); rp; rp = rb_next(rp)) {
61                 req = rb_entry(rp, struct ceph_mds_request, r_node);
62
63                 if (req->r_request && req->r_session)
64                         seq_printf(s, "%lld\tmds%d\t", req->r_tid,
65                                    req->r_session->s_mds);
66                 else if (!req->r_request)
67                         seq_printf(s, "%lld\t(no request)\t", req->r_tid);
68                 else
69                         seq_printf(s, "%lld\t(no session)\t", req->r_tid);
70
71                 seq_printf(s, "%s", ceph_mds_op_name(req->r_op));
72
73                 if (test_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags))
74                         seq_puts(s, "\t(unsafe)");
75                 else
76                         seq_puts(s, "\t");
77
78                 if (req->r_inode) {
79                         seq_printf(s, " #%llx", ceph_ino(req->r_inode));
80                 } else if (req->r_dentry) {
81                         path = ceph_mdsc_build_path(req->r_dentry, &pathlen,
82                                                     &pathbase, 0);
83                         if (IS_ERR(path))
84                                 path = NULL;
85                         spin_lock(&req->r_dentry->d_lock);
86                         seq_printf(s, " #%llx/%pd (%s)",
87                                    ceph_ino(d_inode(req->r_dentry->d_parent)),
88                                    req->r_dentry,
89                                    path ? path : "");
90                         spin_unlock(&req->r_dentry->d_lock);
91                         kfree(path);
92                 } else if (req->r_path1) {
93                         seq_printf(s, " #%llx/%s", req->r_ino1.ino,
94                                    req->r_path1);
95                 } else {
96                         seq_printf(s, " #%llx", req->r_ino1.ino);
97                 }
98
99                 if (req->r_old_dentry) {
100                         path = ceph_mdsc_build_path(req->r_old_dentry, &pathlen,
101                                                     &pathbase, 0);
102                         if (IS_ERR(path))
103                                 path = NULL;
104                         spin_lock(&req->r_old_dentry->d_lock);
105                         seq_printf(s, " #%llx/%pd (%s)",
106                                    req->r_old_dentry_dir ?
107                                    ceph_ino(req->r_old_dentry_dir) : 0,
108                                    req->r_old_dentry,
109                                    path ? path : "");
110                         spin_unlock(&req->r_old_dentry->d_lock);
111                         kfree(path);
112                 } else if (req->r_path2 && req->r_op != CEPH_MDS_OP_SYMLINK) {
113                         if (req->r_ino2.ino)
114                                 seq_printf(s, " #%llx/%s", req->r_ino2.ino,
115                                            req->r_path2);
116                         else
117                                 seq_printf(s, " %s", req->r_path2);
118                 }
119
120                 seq_puts(s, "\n");
121         }
122         mutex_unlock(&mdsc->mutex);
123
124         return 0;
125 }
126
127 static int caps_show(struct seq_file *s, void *p)
128 {
129         struct ceph_fs_client *fsc = s->private;
130         int total, avail, used, reserved, min;
131
132         ceph_reservation_status(fsc, &total, &avail, &used, &reserved, &min);
133         seq_printf(s, "total\t\t%d\n"
134                    "avail\t\t%d\n"
135                    "used\t\t%d\n"
136                    "reserved\t%d\n"
137                    "min\t%d\n",
138                    total, avail, used, reserved, min);
139         return 0;
140 }
141
142 static int dentry_lru_show(struct seq_file *s, void *ptr)
143 {
144         struct ceph_fs_client *fsc = s->private;
145         struct ceph_mds_client *mdsc = fsc->mdsc;
146         struct ceph_dentry_info *di;
147
148         spin_lock(&mdsc->dentry_lru_lock);
149         list_for_each_entry(di, &mdsc->dentry_lru, lru) {
150                 struct dentry *dentry = di->dentry;
151                 seq_printf(s, "%p %p\t%pd\n",
152                            di, dentry, dentry);
153         }
154         spin_unlock(&mdsc->dentry_lru_lock);
155
156         return 0;
157 }
158
159 static int mds_sessions_show(struct seq_file *s, void *ptr)
160 {
161         struct ceph_fs_client *fsc = s->private;
162         struct ceph_mds_client *mdsc = fsc->mdsc;
163         struct ceph_auth_client *ac = fsc->client->monc.auth;
164         struct ceph_options *opt = fsc->client->options;
165         int mds = -1;
166
167         mutex_lock(&mdsc->mutex);
168
169         /* The 'num' portion of an 'entity name' */
170         seq_printf(s, "global_id %llu\n", ac->global_id);
171
172         /* The -o name mount argument */
173         seq_printf(s, "name \"%s\"\n", opt->name ? opt->name : "");
174
175         /* The list of MDS session rank+state */
176         for (mds = 0; mds < mdsc->max_sessions; mds++) {
177                 struct ceph_mds_session *session =
178                         __ceph_lookup_mds_session(mdsc, mds);
179                 if (!session) {
180                         continue;
181                 }
182                 mutex_unlock(&mdsc->mutex);
183                 seq_printf(s, "mds.%d %s\n",
184                                 session->s_mds,
185                                 ceph_session_state_name(session->s_state));
186
187                 ceph_put_mds_session(session);
188                 mutex_lock(&mdsc->mutex);
189         }
190         mutex_unlock(&mdsc->mutex);
191
192         return 0;
193 }
194
195 CEPH_DEFINE_SHOW_FUNC(mdsmap_show)
196 CEPH_DEFINE_SHOW_FUNC(mdsc_show)
197 CEPH_DEFINE_SHOW_FUNC(caps_show)
198 CEPH_DEFINE_SHOW_FUNC(dentry_lru_show)
199 CEPH_DEFINE_SHOW_FUNC(mds_sessions_show)
200
201
202 /*
203  * debugfs
204  */
205 static int congestion_kb_set(void *data, u64 val)
206 {
207         struct ceph_fs_client *fsc = (struct ceph_fs_client *)data;
208
209         fsc->mount_options->congestion_kb = (int)val;
210         return 0;
211 }
212
213 static int congestion_kb_get(void *data, u64 *val)
214 {
215         struct ceph_fs_client *fsc = (struct ceph_fs_client *)data;
216
217         *val = (u64)fsc->mount_options->congestion_kb;
218         return 0;
219 }
220
221 DEFINE_SIMPLE_ATTRIBUTE(congestion_kb_fops, congestion_kb_get,
222                         congestion_kb_set, "%llu\n");
223
224
225 void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc)
226 {
227         dout("ceph_fs_debugfs_cleanup\n");
228         debugfs_remove(fsc->debugfs_bdi);
229         debugfs_remove(fsc->debugfs_congestion_kb);
230         debugfs_remove(fsc->debugfs_mdsmap);
231         debugfs_remove(fsc->debugfs_mds_sessions);
232         debugfs_remove(fsc->debugfs_caps);
233         debugfs_remove(fsc->debugfs_mdsc);
234         debugfs_remove(fsc->debugfs_dentry_lru);
235 }
236
237 int ceph_fs_debugfs_init(struct ceph_fs_client *fsc)
238 {
239         char name[100];
240         int err = -ENOMEM;
241
242         dout("ceph_fs_debugfs_init\n");
243         BUG_ON(!fsc->client->debugfs_dir);
244         fsc->debugfs_congestion_kb =
245                 debugfs_create_file("writeback_congestion_kb",
246                                     0600,
247                                     fsc->client->debugfs_dir,
248                                     fsc,
249                                     &congestion_kb_fops);
250         if (!fsc->debugfs_congestion_kb)
251                 goto out;
252
253         snprintf(name, sizeof(name), "../../bdi/%s",
254                  dev_name(fsc->sb->s_bdi->dev));
255         fsc->debugfs_bdi =
256                 debugfs_create_symlink("bdi",
257                                        fsc->client->debugfs_dir,
258                                        name);
259         if (!fsc->debugfs_bdi)
260                 goto out;
261
262         fsc->debugfs_mdsmap = debugfs_create_file("mdsmap",
263                                         0400,
264                                         fsc->client->debugfs_dir,
265                                         fsc,
266                                         &mdsmap_show_fops);
267         if (!fsc->debugfs_mdsmap)
268                 goto out;
269
270         fsc->debugfs_mds_sessions = debugfs_create_file("mds_sessions",
271                                         0400,
272                                         fsc->client->debugfs_dir,
273                                         fsc,
274                                         &mds_sessions_show_fops);
275         if (!fsc->debugfs_mds_sessions)
276                 goto out;
277
278         fsc->debugfs_mdsc = debugfs_create_file("mdsc",
279                                                 0400,
280                                                 fsc->client->debugfs_dir,
281                                                 fsc,
282                                                 &mdsc_show_fops);
283         if (!fsc->debugfs_mdsc)
284                 goto out;
285
286         fsc->debugfs_caps = debugfs_create_file("caps",
287                                                    0400,
288                                                    fsc->client->debugfs_dir,
289                                                    fsc,
290                                                    &caps_show_fops);
291         if (!fsc->debugfs_caps)
292                 goto out;
293
294         fsc->debugfs_dentry_lru = debugfs_create_file("dentry_lru",
295                                         0400,
296                                         fsc->client->debugfs_dir,
297                                         fsc,
298                                         &dentry_lru_show_fops);
299         if (!fsc->debugfs_dentry_lru)
300                 goto out;
301
302         return 0;
303
304 out:
305         ceph_fs_debugfs_cleanup(fsc);
306         return err;
307 }
308
309
310 #else  /* CONFIG_DEBUG_FS */
311
312 int ceph_fs_debugfs_init(struct ceph_fs_client *fsc)
313 {
314         return 0;
315 }
316
317 void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc)
318 {
319 }
320
321 #endif  /* CONFIG_DEBUG_FS */