1 #include <linux/ceph/ceph_debug.h>
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>
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>
17 #ifdef CONFIG_DEBUG_FS
19 #include "mds_client.h"
21 static int mdsmap_show(struct seq_file
*s
, void *p
)
24 struct ceph_fs_client
*fsc
= s
->private;
26 if (fsc
->mdsc
== NULL
|| fsc
->mdsc
->mdsmap
== NULL
)
28 seq_printf(s
, "epoch %d\n", fsc
->mdsc
->mdsmap
->m_epoch
);
29 seq_printf(s
, "root %d\n", fsc
->mdsc
->mdsmap
->m_root
);
30 seq_printf(s
, "session_timeout %d\n",
31 fsc
->mdsc
->mdsmap
->m_session_timeout
);
32 seq_printf(s
, "session_autoclose %d\n",
33 fsc
->mdsc
->mdsmap
->m_session_autoclose
);
34 for (i
= 0; i
< fsc
->mdsc
->mdsmap
->m_max_mds
; i
++) {
35 struct ceph_entity_addr
*addr
=
36 &fsc
->mdsc
->mdsmap
->m_info
[i
].addr
;
37 int state
= fsc
->mdsc
->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
));
49 static int mdsc_show(struct seq_file
*s
, void *p
)
51 struct ceph_fs_client
*fsc
= s
->private;
52 struct ceph_mds_client
*mdsc
= fsc
->mdsc
;
53 struct ceph_mds_request
*req
;
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
);
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
);
69 seq_printf(s
, "%lld\t(no session)\t", req
->r_tid
);
71 seq_printf(s
, "%s", ceph_mds_op_name(req
->r_op
));
73 if (req
->r_got_unsafe
)
74 seq_puts(s
, "\t(unsafe)");
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
,
85 spin_lock(&req
->r_dentry
->d_lock
);
86 seq_printf(s
, " #%llx/%.*s (%s)",
87 ceph_ino(req
->r_dentry
->d_parent
->d_inode
),
88 req
->r_dentry
->d_name
.len
,
89 req
->r_dentry
->d_name
.name
,
91 spin_unlock(&req
->r_dentry
->d_lock
);
93 } else if (req
->r_path1
) {
94 seq_printf(s
, " #%llx/%s", req
->r_ino1
.ino
,
97 seq_printf(s
, " #%llx", req
->r_ino1
.ino
);
100 if (req
->r_old_dentry
) {
101 path
= ceph_mdsc_build_path(req
->r_old_dentry
, &pathlen
,
105 spin_lock(&req
->r_old_dentry
->d_lock
);
106 seq_printf(s
, " #%llx/%.*s (%s)",
107 req
->r_old_dentry_dir
?
108 ceph_ino(req
->r_old_dentry_dir
) : 0,
109 req
->r_old_dentry
->d_name
.len
,
110 req
->r_old_dentry
->d_name
.name
,
112 spin_unlock(&req
->r_old_dentry
->d_lock
);
114 } else if (req
->r_path2
) {
116 seq_printf(s
, " #%llx/%s", req
->r_ino2
.ino
,
119 seq_printf(s
, " %s", req
->r_path2
);
124 mutex_unlock(&mdsc
->mutex
);
129 static int caps_show(struct seq_file
*s
, void *p
)
131 struct ceph_fs_client
*fsc
= s
->private;
132 int total
, avail
, used
, reserved
, min
;
134 ceph_reservation_status(fsc
, &total
, &avail
, &used
, &reserved
, &min
);
135 seq_printf(s
, "total\t\t%d\n"
140 total
, avail
, used
, reserved
, min
);
144 static int dentry_lru_show(struct seq_file
*s
, void *ptr
)
146 struct ceph_fs_client
*fsc
= s
->private;
147 struct ceph_mds_client
*mdsc
= fsc
->mdsc
;
148 struct ceph_dentry_info
*di
;
150 spin_lock(&mdsc
->dentry_lru_lock
);
151 list_for_each_entry(di
, &mdsc
->dentry_lru
, lru
) {
152 struct dentry
*dentry
= di
->dentry
;
153 seq_printf(s
, "%p %p\t%.*s\n",
154 di
, dentry
, dentry
->d_name
.len
, dentry
->d_name
.name
);
156 spin_unlock(&mdsc
->dentry_lru_lock
);
161 static int mds_sessions_show(struct seq_file
*s
, void *ptr
)
163 struct ceph_fs_client
*fsc
= s
->private;
164 struct ceph_mds_client
*mdsc
= fsc
->mdsc
;
165 struct ceph_auth_client
*ac
= fsc
->client
->monc
.auth
;
166 struct ceph_options
*opt
= fsc
->client
->options
;
169 mutex_lock(&mdsc
->mutex
);
171 /* The 'num' portion of an 'entity name' */
172 seq_printf(s
, "global_id %llu\n", ac
->global_id
);
174 /* The -o name mount argument */
175 seq_printf(s
, "name \"%s\"\n", opt
->name
? opt
->name
: "");
177 /* The list of MDS session rank+state */
178 for (mds
= 0; mds
< mdsc
->max_sessions
; mds
++) {
179 struct ceph_mds_session
*session
=
180 __ceph_lookup_mds_session(mdsc
, mds
);
184 mutex_unlock(&mdsc
->mutex
);
185 seq_printf(s
, "mds.%d %s\n",
187 ceph_session_state_name(session
->s_state
));
189 ceph_put_mds_session(session
);
190 mutex_lock(&mdsc
->mutex
);
192 mutex_unlock(&mdsc
->mutex
);
197 CEPH_DEFINE_SHOW_FUNC(mdsmap_show
)
198 CEPH_DEFINE_SHOW_FUNC(mdsc_show
)
199 CEPH_DEFINE_SHOW_FUNC(caps_show
)
200 CEPH_DEFINE_SHOW_FUNC(dentry_lru_show
)
201 CEPH_DEFINE_SHOW_FUNC(mds_sessions_show
)
207 static int congestion_kb_set(void *data
, u64 val
)
209 struct ceph_fs_client
*fsc
= (struct ceph_fs_client
*)data
;
211 fsc
->mount_options
->congestion_kb
= (int)val
;
215 static int congestion_kb_get(void *data
, u64
*val
)
217 struct ceph_fs_client
*fsc
= (struct ceph_fs_client
*)data
;
219 *val
= (u64
)fsc
->mount_options
->congestion_kb
;
223 DEFINE_SIMPLE_ATTRIBUTE(congestion_kb_fops
, congestion_kb_get
,
224 congestion_kb_set
, "%llu\n");
227 void ceph_fs_debugfs_cleanup(struct ceph_fs_client
*fsc
)
229 dout("ceph_fs_debugfs_cleanup\n");
230 debugfs_remove(fsc
->debugfs_bdi
);
231 debugfs_remove(fsc
->debugfs_congestion_kb
);
232 debugfs_remove(fsc
->debugfs_mdsmap
);
233 debugfs_remove(fsc
->debugfs_mds_sessions
);
234 debugfs_remove(fsc
->debugfs_caps
);
235 debugfs_remove(fsc
->debugfs_mdsc
);
236 debugfs_remove(fsc
->debugfs_dentry_lru
);
239 int ceph_fs_debugfs_init(struct ceph_fs_client
*fsc
)
244 dout("ceph_fs_debugfs_init\n");
245 BUG_ON(!fsc
->client
->debugfs_dir
);
246 fsc
->debugfs_congestion_kb
=
247 debugfs_create_file("writeback_congestion_kb",
249 fsc
->client
->debugfs_dir
,
251 &congestion_kb_fops
);
252 if (!fsc
->debugfs_congestion_kb
)
255 snprintf(name
, sizeof(name
), "../../bdi/%s",
256 dev_name(fsc
->backing_dev_info
.dev
));
258 debugfs_create_symlink("bdi",
259 fsc
->client
->debugfs_dir
,
261 if (!fsc
->debugfs_bdi
)
264 fsc
->debugfs_mdsmap
= debugfs_create_file("mdsmap",
266 fsc
->client
->debugfs_dir
,
269 if (!fsc
->debugfs_mdsmap
)
272 fsc
->debugfs_mds_sessions
= debugfs_create_file("mds_sessions",
274 fsc
->client
->debugfs_dir
,
276 &mds_sessions_show_fops
);
277 if (!fsc
->debugfs_mds_sessions
)
280 fsc
->debugfs_mdsc
= debugfs_create_file("mdsc",
282 fsc
->client
->debugfs_dir
,
285 if (!fsc
->debugfs_mdsc
)
288 fsc
->debugfs_caps
= debugfs_create_file("caps",
290 fsc
->client
->debugfs_dir
,
293 if (!fsc
->debugfs_caps
)
296 fsc
->debugfs_dentry_lru
= debugfs_create_file("dentry_lru",
298 fsc
->client
->debugfs_dir
,
300 &dentry_lru_show_fops
);
301 if (!fsc
->debugfs_dentry_lru
)
307 ceph_fs_debugfs_cleanup(fsc
);
312 #else /* CONFIG_DEBUG_FS */
314 int ceph_fs_debugfs_init(struct ceph_fs_client
*fsc
)
319 void ceph_fs_debugfs_cleanup(struct ceph_fs_client
*fsc
)
323 #endif /* CONFIG_DEBUG_FS */