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 (test_bit(CEPH_MDS_R_GOT_UNSAFE
, &req
->r_req_flags
))
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/%pd (%s)",
87 ceph_ino(d_inode(req
->r_dentry
->d_parent
)),
90 spin_unlock(&req
->r_dentry
->d_lock
);
92 } else if (req
->r_path1
) {
93 seq_printf(s
, " #%llx/%s", req
->r_ino1
.ino
,
96 seq_printf(s
, " #%llx", req
->r_ino1
.ino
);
99 if (req
->r_old_dentry
) {
100 path
= ceph_mdsc_build_path(req
->r_old_dentry
, &pathlen
,
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,
110 spin_unlock(&req
->r_old_dentry
->d_lock
);
112 } else if (req
->r_path2
&& req
->r_op
!= CEPH_MDS_OP_SYMLINK
) {
114 seq_printf(s
, " #%llx/%s", req
->r_ino2
.ino
,
117 seq_printf(s
, " %s", req
->r_path2
);
122 mutex_unlock(&mdsc
->mutex
);
127 static int caps_show(struct seq_file
*s
, void *p
)
129 struct ceph_fs_client
*fsc
= s
->private;
130 int total
, avail
, used
, reserved
, min
;
132 ceph_reservation_status(fsc
, &total
, &avail
, &used
, &reserved
, &min
);
133 seq_printf(s
, "total\t\t%d\n"
138 total
, avail
, used
, reserved
, min
);
142 static int dentry_lru_show(struct seq_file
*s
, void *ptr
)
144 struct ceph_fs_client
*fsc
= s
->private;
145 struct ceph_mds_client
*mdsc
= fsc
->mdsc
;
146 struct ceph_dentry_info
*di
;
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",
154 spin_unlock(&mdsc
->dentry_lru_lock
);
159 static int mds_sessions_show(struct seq_file
*s
, void *ptr
)
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
;
167 mutex_lock(&mdsc
->mutex
);
169 /* The 'num' portion of an 'entity name' */
170 seq_printf(s
, "global_id %llu\n", ac
->global_id
);
172 /* The -o name mount argument */
173 seq_printf(s
, "name \"%s\"\n", opt
->name
? opt
->name
: "");
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
);
182 mutex_unlock(&mdsc
->mutex
);
183 seq_printf(s
, "mds.%d %s\n",
185 ceph_session_state_name(session
->s_state
));
187 ceph_put_mds_session(session
);
188 mutex_lock(&mdsc
->mutex
);
190 mutex_unlock(&mdsc
->mutex
);
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
)
205 static int congestion_kb_set(void *data
, u64 val
)
207 struct ceph_fs_client
*fsc
= (struct ceph_fs_client
*)data
;
209 fsc
->mount_options
->congestion_kb
= (int)val
;
213 static int congestion_kb_get(void *data
, u64
*val
)
215 struct ceph_fs_client
*fsc
= (struct ceph_fs_client
*)data
;
217 *val
= (u64
)fsc
->mount_options
->congestion_kb
;
221 DEFINE_SIMPLE_ATTRIBUTE(congestion_kb_fops
, congestion_kb_get
,
222 congestion_kb_set
, "%llu\n");
225 void ceph_fs_debugfs_cleanup(struct ceph_fs_client
*fsc
)
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
);
237 int ceph_fs_debugfs_init(struct ceph_fs_client
*fsc
)
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",
247 fsc
->client
->debugfs_dir
,
249 &congestion_kb_fops
);
250 if (!fsc
->debugfs_congestion_kb
)
253 snprintf(name
, sizeof(name
), "../../bdi/%s",
254 dev_name(fsc
->backing_dev_info
.dev
));
256 debugfs_create_symlink("bdi",
257 fsc
->client
->debugfs_dir
,
259 if (!fsc
->debugfs_bdi
)
262 fsc
->debugfs_mdsmap
= debugfs_create_file("mdsmap",
264 fsc
->client
->debugfs_dir
,
267 if (!fsc
->debugfs_mdsmap
)
270 fsc
->debugfs_mds_sessions
= debugfs_create_file("mds_sessions",
272 fsc
->client
->debugfs_dir
,
274 &mds_sessions_show_fops
);
275 if (!fsc
->debugfs_mds_sessions
)
278 fsc
->debugfs_mdsc
= debugfs_create_file("mdsc",
280 fsc
->client
->debugfs_dir
,
283 if (!fsc
->debugfs_mdsc
)
286 fsc
->debugfs_caps
= debugfs_create_file("caps",
288 fsc
->client
->debugfs_dir
,
291 if (!fsc
->debugfs_caps
)
294 fsc
->debugfs_dentry_lru
= debugfs_create_file("dentry_lru",
296 fsc
->client
->debugfs_dir
,
298 &dentry_lru_show_fops
);
299 if (!fsc
->debugfs_dentry_lru
)
305 ceph_fs_debugfs_cleanup(fsc
);
310 #else /* CONFIG_DEBUG_FS */
312 int ceph_fs_debugfs_init(struct ceph_fs_client
*fsc
)
317 void ceph_fs_debugfs_cleanup(struct ceph_fs_client
*fsc
)
321 #endif /* CONFIG_DEBUG_FS */