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_printf(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
,
98 if (req
->r_old_dentry
) {
99 path
= ceph_mdsc_build_path(req
->r_old_dentry
, &pathlen
,
103 spin_lock(&req
->r_old_dentry
->d_lock
);
104 seq_printf(s
, " #%llx/%.*s (%s)",
105 ceph_ino(req
->r_old_dentry_dir
),
106 req
->r_old_dentry
->d_name
.len
,
107 req
->r_old_dentry
->d_name
.name
,
109 spin_unlock(&req
->r_old_dentry
->d_lock
);
111 } else if (req
->r_path2
) {
113 seq_printf(s
, " #%llx/%s", req
->r_ino2
.ino
,
116 seq_printf(s
, " %s", req
->r_path2
);
121 mutex_unlock(&mdsc
->mutex
);
126 static int caps_show(struct seq_file
*s
, void *p
)
128 struct ceph_fs_client
*fsc
= s
->private;
129 int total
, avail
, used
, reserved
, min
;
131 ceph_reservation_status(fsc
, &total
, &avail
, &used
, &reserved
, &min
);
132 seq_printf(s
, "total\t\t%d\n"
137 total
, avail
, used
, reserved
, min
);
141 static int dentry_lru_show(struct seq_file
*s
, void *ptr
)
143 struct ceph_fs_client
*fsc
= s
->private;
144 struct ceph_mds_client
*mdsc
= fsc
->mdsc
;
145 struct ceph_dentry_info
*di
;
147 spin_lock(&mdsc
->dentry_lru_lock
);
148 list_for_each_entry(di
, &mdsc
->dentry_lru
, lru
) {
149 struct dentry
*dentry
= di
->dentry
;
150 seq_printf(s
, "%p %p\t%.*s\n",
151 di
, dentry
, dentry
->d_name
.len
, dentry
->d_name
.name
);
153 spin_unlock(&mdsc
->dentry_lru_lock
);
158 CEPH_DEFINE_SHOW_FUNC(mdsmap_show
)
159 CEPH_DEFINE_SHOW_FUNC(mdsc_show
)
160 CEPH_DEFINE_SHOW_FUNC(caps_show
)
161 CEPH_DEFINE_SHOW_FUNC(dentry_lru_show
)
167 static int congestion_kb_set(void *data
, u64 val
)
169 struct ceph_fs_client
*fsc
= (struct ceph_fs_client
*)data
;
171 fsc
->mount_options
->congestion_kb
= (int)val
;
175 static int congestion_kb_get(void *data
, u64
*val
)
177 struct ceph_fs_client
*fsc
= (struct ceph_fs_client
*)data
;
179 *val
= (u64
)fsc
->mount_options
->congestion_kb
;
183 DEFINE_SIMPLE_ATTRIBUTE(congestion_kb_fops
, congestion_kb_get
,
184 congestion_kb_set
, "%llu\n");
187 void ceph_fs_debugfs_cleanup(struct ceph_fs_client
*fsc
)
189 dout("ceph_fs_debugfs_cleanup\n");
190 debugfs_remove(fsc
->debugfs_bdi
);
191 debugfs_remove(fsc
->debugfs_congestion_kb
);
192 debugfs_remove(fsc
->debugfs_mdsmap
);
193 debugfs_remove(fsc
->debugfs_caps
);
194 debugfs_remove(fsc
->debugfs_mdsc
);
195 debugfs_remove(fsc
->debugfs_dentry_lru
);
198 int ceph_fs_debugfs_init(struct ceph_fs_client
*fsc
)
203 dout("ceph_fs_debugfs_init\n");
204 BUG_ON(!fsc
->client
->debugfs_dir
);
205 fsc
->debugfs_congestion_kb
=
206 debugfs_create_file("writeback_congestion_kb",
208 fsc
->client
->debugfs_dir
,
210 &congestion_kb_fops
);
211 if (!fsc
->debugfs_congestion_kb
)
214 snprintf(name
, sizeof(name
), "../../bdi/%s",
215 dev_name(fsc
->backing_dev_info
.dev
));
217 debugfs_create_symlink("bdi",
218 fsc
->client
->debugfs_dir
,
220 if (!fsc
->debugfs_bdi
)
223 fsc
->debugfs_mdsmap
= debugfs_create_file("mdsmap",
225 fsc
->client
->debugfs_dir
,
228 if (!fsc
->debugfs_mdsmap
)
231 fsc
->debugfs_mdsc
= debugfs_create_file("mdsc",
233 fsc
->client
->debugfs_dir
,
236 if (!fsc
->debugfs_mdsc
)
239 fsc
->debugfs_caps
= debugfs_create_file("caps",
241 fsc
->client
->debugfs_dir
,
244 if (!fsc
->debugfs_caps
)
247 fsc
->debugfs_dentry_lru
= debugfs_create_file("dentry_lru",
249 fsc
->client
->debugfs_dir
,
251 &dentry_lru_show_fops
);
252 if (!fsc
->debugfs_dentry_lru
)
258 ceph_fs_debugfs_cleanup(fsc
);
263 #else /* CONFIG_DEBUG_FS */
265 int ceph_fs_debugfs_init(struct ceph_fs_client
*fsc
)
270 void ceph_fs_debugfs_cleanup(struct ceph_fs_client
*fsc
)
274 #endif /* CONFIG_DEBUG_FS */
This page took 0.035043 seconds and 5 git commands to generate.