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 CEPH_DEFINE_SHOW_FUNC(mdsmap_show
)
162 CEPH_DEFINE_SHOW_FUNC(mdsc_show
)
163 CEPH_DEFINE_SHOW_FUNC(caps_show
)
164 CEPH_DEFINE_SHOW_FUNC(dentry_lru_show
)
170 static int congestion_kb_set(void *data
, u64 val
)
172 struct ceph_fs_client
*fsc
= (struct ceph_fs_client
*)data
;
174 fsc
->mount_options
->congestion_kb
= (int)val
;
178 static int congestion_kb_get(void *data
, u64
*val
)
180 struct ceph_fs_client
*fsc
= (struct ceph_fs_client
*)data
;
182 *val
= (u64
)fsc
->mount_options
->congestion_kb
;
186 DEFINE_SIMPLE_ATTRIBUTE(congestion_kb_fops
, congestion_kb_get
,
187 congestion_kb_set
, "%llu\n");
190 void ceph_fs_debugfs_cleanup(struct ceph_fs_client
*fsc
)
192 dout("ceph_fs_debugfs_cleanup\n");
193 debugfs_remove(fsc
->debugfs_bdi
);
194 debugfs_remove(fsc
->debugfs_congestion_kb
);
195 debugfs_remove(fsc
->debugfs_mdsmap
);
196 debugfs_remove(fsc
->debugfs_caps
);
197 debugfs_remove(fsc
->debugfs_mdsc
);
198 debugfs_remove(fsc
->debugfs_dentry_lru
);
201 int ceph_fs_debugfs_init(struct ceph_fs_client
*fsc
)
206 dout("ceph_fs_debugfs_init\n");
207 BUG_ON(!fsc
->client
->debugfs_dir
);
208 fsc
->debugfs_congestion_kb
=
209 debugfs_create_file("writeback_congestion_kb",
211 fsc
->client
->debugfs_dir
,
213 &congestion_kb_fops
);
214 if (!fsc
->debugfs_congestion_kb
)
217 snprintf(name
, sizeof(name
), "../../bdi/%s",
218 dev_name(fsc
->backing_dev_info
.dev
));
220 debugfs_create_symlink("bdi",
221 fsc
->client
->debugfs_dir
,
223 if (!fsc
->debugfs_bdi
)
226 fsc
->debugfs_mdsmap
= debugfs_create_file("mdsmap",
228 fsc
->client
->debugfs_dir
,
231 if (!fsc
->debugfs_mdsmap
)
234 fsc
->debugfs_mdsc
= debugfs_create_file("mdsc",
236 fsc
->client
->debugfs_dir
,
239 if (!fsc
->debugfs_mdsc
)
242 fsc
->debugfs_caps
= debugfs_create_file("caps",
244 fsc
->client
->debugfs_dir
,
247 if (!fsc
->debugfs_caps
)
250 fsc
->debugfs_dentry_lru
= debugfs_create_file("dentry_lru",
252 fsc
->client
->debugfs_dir
,
254 &dentry_lru_show_fops
);
255 if (!fsc
->debugfs_dentry_lru
)
261 ceph_fs_debugfs_cleanup(fsc
);
266 #else /* CONFIG_DEBUG_FS */
268 int ceph_fs_debugfs_init(struct ceph_fs_client
*fsc
)
273 void ceph_fs_debugfs_cleanup(struct ceph_fs_client
*fsc
)
277 #endif /* CONFIG_DEBUG_FS */
This page took 0.046786 seconds and 5 git commands to generate.