Linux Audio

Check our new training course

Loading...
v5.4
  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
 22static 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),
 41			       ceph_mds_state_name(state));
 42	}
 43	return 0;
 44}
 45
 46/*
 47 * mdsc debugfs
 48 */
 49static 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 = 0;
 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			ceph_mdsc_free_path(path, pathlen);
 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			ceph_mdsc_free_path(path, pathlen);
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
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
127static int caps_show_cb(struct inode *inode, struct ceph_cap *cap, void *p)
128{
129	struct seq_file *s = p;
130
131	seq_printf(s, "0x%-17lx%-17s%-17s\n", inode->i_ino,
132		   ceph_cap_string(cap->issued),
133		   ceph_cap_string(cap->implemented));
134	return 0;
135}
136
137static int caps_show(struct seq_file *s, void *p)
138{
139	struct ceph_fs_client *fsc = s->private;
140	struct ceph_mds_client *mdsc = fsc->mdsc;
141	int total, avail, used, reserved, min, i;
 
142
143	ceph_reservation_status(fsc, &total, &avail, &used, &reserved, &min);
144	seq_printf(s, "total\t\t%d\n"
145		   "avail\t\t%d\n"
146		   "used\t\t%d\n"
147		   "reserved\t%d\n"
148		   "min\t\t%d\n\n",
149		   total, avail, used, reserved, min);
150	seq_printf(s, "ino                issued           implemented\n");
151	seq_printf(s, "-----------------------------------------------\n");
152
153	mutex_lock(&mdsc->mutex);
154	for (i = 0; i < mdsc->max_sessions; i++) {
155		struct ceph_mds_session *session;
156
157		session = __ceph_lookup_mds_session(mdsc, i);
158		if (!session)
159			continue;
160		mutex_unlock(&mdsc->mutex);
161		mutex_lock(&session->s_mutex);
162		ceph_iterate_session_caps(session, caps_show_cb, s);
163		mutex_unlock(&session->s_mutex);
164		ceph_put_mds_session(session);
165		mutex_lock(&mdsc->mutex);
166	}
167	mutex_unlock(&mdsc->mutex);
168
 
 
 
 
 
 
 
 
 
 
 
 
169	return 0;
170}
171
172static int mds_sessions_show(struct seq_file *s, void *ptr)
173{
174	struct ceph_fs_client *fsc = s->private;
175	struct ceph_mds_client *mdsc = fsc->mdsc;
176	struct ceph_auth_client *ac = fsc->client->monc.auth;
177	struct ceph_options *opt = fsc->client->options;
178	int mds = -1;
179
180	mutex_lock(&mdsc->mutex);
181
182	/* The 'num' portion of an 'entity name' */
183	seq_printf(s, "global_id %llu\n", ac->global_id);
184
185	/* The -o name mount argument */
186	seq_printf(s, "name \"%s\"\n", opt->name ? opt->name : "");
187
188	/* The list of MDS session rank+state */
189	for (mds = 0; mds < mdsc->max_sessions; mds++) {
190		struct ceph_mds_session *session =
191			__ceph_lookup_mds_session(mdsc, mds);
192		if (!session) {
193			continue;
194		}
195		mutex_unlock(&mdsc->mutex);
196		seq_printf(s, "mds.%d %s\n",
197				session->s_mds,
198				ceph_session_state_name(session->s_state));
199
200		ceph_put_mds_session(session);
201		mutex_lock(&mdsc->mutex);
202	}
203	mutex_unlock(&mdsc->mutex);
204
205	return 0;
206}
207
208CEPH_DEFINE_SHOW_FUNC(mdsmap_show)
209CEPH_DEFINE_SHOW_FUNC(mdsc_show)
210CEPH_DEFINE_SHOW_FUNC(caps_show)
211CEPH_DEFINE_SHOW_FUNC(mds_sessions_show)
 
212
213
214/*
215 * debugfs
216 */
217static int congestion_kb_set(void *data, u64 val)
218{
219	struct ceph_fs_client *fsc = (struct ceph_fs_client *)data;
220
221	fsc->mount_options->congestion_kb = (int)val;
222	return 0;
223}
224
225static int congestion_kb_get(void *data, u64 *val)
226{
227	struct ceph_fs_client *fsc = (struct ceph_fs_client *)data;
228
229	*val = (u64)fsc->mount_options->congestion_kb;
230	return 0;
231}
232
233DEFINE_SIMPLE_ATTRIBUTE(congestion_kb_fops, congestion_kb_get,
234			congestion_kb_set, "%llu\n");
235
236
237void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc)
238{
239	dout("ceph_fs_debugfs_cleanup\n");
240	debugfs_remove(fsc->debugfs_bdi);
241	debugfs_remove(fsc->debugfs_congestion_kb);
242	debugfs_remove(fsc->debugfs_mdsmap);
243	debugfs_remove(fsc->debugfs_mds_sessions);
244	debugfs_remove(fsc->debugfs_caps);
 
245	debugfs_remove(fsc->debugfs_mdsc);
246}
247
248void ceph_fs_debugfs_init(struct ceph_fs_client *fsc)
249{
250	char name[100];
251
252	dout("ceph_fs_debugfs_init\n");
253	fsc->debugfs_congestion_kb =
254		debugfs_create_file("writeback_congestion_kb",
255				    0600,
256				    fsc->client->debugfs_dir,
257				    fsc,
258				    &congestion_kb_fops);
259
260	snprintf(name, sizeof(name), "../../bdi/%s",
261		 dev_name(fsc->sb->s_bdi->dev));
262	fsc->debugfs_bdi =
263		debugfs_create_symlink("bdi",
264				       fsc->client->debugfs_dir,
265				       name);
266
267	fsc->debugfs_mdsmap = debugfs_create_file("mdsmap",
268					0400,
269					fsc->client->debugfs_dir,
270					fsc,
271					&mdsmap_show_fops);
272
273	fsc->debugfs_mds_sessions = debugfs_create_file("mds_sessions",
274					0400,
275					fsc->client->debugfs_dir,
276					fsc,
277					&mds_sessions_show_fops);
278
279	fsc->debugfs_mdsc = debugfs_create_file("mdsc",
280						0400,
281						fsc->client->debugfs_dir,
282						fsc,
283						&mdsc_show_fops);
 
 
 
 
 
 
284
285	fsc->debugfs_caps = debugfs_create_file("caps",
286						   0400,
287						   fsc->client->debugfs_dir,
288						   fsc,
289						   &caps_show_fops);
290}
291
292
293#else  /* CONFIG_DEBUG_FS */
294
295void ceph_fs_debugfs_init(struct ceph_fs_client *fsc)
296{
297}
298
299void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc)
300{
301}
302
303#endif  /* CONFIG_DEBUG_FS */
v5.9
  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#include <linux/math64.h>
 11#include <linux/ktime.h>
 12
 13#include <linux/ceph/libceph.h>
 14#include <linux/ceph/mon_client.h>
 15#include <linux/ceph/auth.h>
 16#include <linux/ceph/debugfs.h>
 17
 18#include "super.h"
 19
 20#ifdef CONFIG_DEBUG_FS
 21
 22#include "mds_client.h"
 23#include "metric.h"
 24
 25static int mdsmap_show(struct seq_file *s, void *p)
 26{
 27	int i;
 28	struct ceph_fs_client *fsc = s->private;
 29	struct ceph_mdsmap *mdsmap;
 30
 31	if (!fsc->mdsc || !fsc->mdsc->mdsmap)
 32		return 0;
 33	mdsmap = fsc->mdsc->mdsmap;
 34	seq_printf(s, "epoch %d\n", mdsmap->m_epoch);
 35	seq_printf(s, "root %d\n", mdsmap->m_root);
 36	seq_printf(s, "max_mds %d\n", mdsmap->m_max_mds);
 37	seq_printf(s, "session_timeout %d\n", mdsmap->m_session_timeout);
 38	seq_printf(s, "session_autoclose %d\n", mdsmap->m_session_autoclose);
 39	for (i = 0; i < mdsmap->possible_max_rank; i++) {
 40		struct ceph_entity_addr *addr = &mdsmap->m_info[i].addr;
 41		int state = mdsmap->m_info[i].state;
 42		seq_printf(s, "\tmds%d\t%s\t(%s)\n", i,
 43			       ceph_pr_addr(addr),
 44			       ceph_mds_state_name(state));
 45	}
 46	return 0;
 47}
 48
 49/*
 50 * mdsc debugfs
 51 */
 52static int mdsc_show(struct seq_file *s, void *p)
 53{
 54	struct ceph_fs_client *fsc = s->private;
 55	struct ceph_mds_client *mdsc = fsc->mdsc;
 56	struct ceph_mds_request *req;
 57	struct rb_node *rp;
 58	int pathlen = 0;
 59	u64 pathbase;
 60	char *path;
 61
 62	mutex_lock(&mdsc->mutex);
 63	for (rp = rb_first(&mdsc->request_tree); rp; rp = rb_next(rp)) {
 64		req = rb_entry(rp, struct ceph_mds_request, r_node);
 65
 66		if (req->r_request && req->r_session)
 67			seq_printf(s, "%lld\tmds%d\t", req->r_tid,
 68				   req->r_session->s_mds);
 69		else if (!req->r_request)
 70			seq_printf(s, "%lld\t(no request)\t", req->r_tid);
 71		else
 72			seq_printf(s, "%lld\t(no session)\t", req->r_tid);
 73
 74		seq_printf(s, "%s", ceph_mds_op_name(req->r_op));
 75
 76		if (test_bit(CEPH_MDS_R_GOT_UNSAFE, &req->r_req_flags))
 77			seq_puts(s, "\t(unsafe)");
 78		else
 79			seq_puts(s, "\t");
 80
 81		if (req->r_inode) {
 82			seq_printf(s, " #%llx", ceph_ino(req->r_inode));
 83		} else if (req->r_dentry) {
 84			path = ceph_mdsc_build_path(req->r_dentry, &pathlen,
 85						    &pathbase, 0);
 86			if (IS_ERR(path))
 87				path = NULL;
 88			spin_lock(&req->r_dentry->d_lock);
 89			seq_printf(s, " #%llx/%pd (%s)",
 90				   ceph_ino(d_inode(req->r_dentry->d_parent)),
 91				   req->r_dentry,
 92				   path ? path : "");
 93			spin_unlock(&req->r_dentry->d_lock);
 94			ceph_mdsc_free_path(path, pathlen);
 95		} else if (req->r_path1) {
 96			seq_printf(s, " #%llx/%s", req->r_ino1.ino,
 97				   req->r_path1);
 98		} else {
 99			seq_printf(s, " #%llx", req->r_ino1.ino);
100		}
101
102		if (req->r_old_dentry) {
103			path = ceph_mdsc_build_path(req->r_old_dentry, &pathlen,
104						    &pathbase, 0);
105			if (IS_ERR(path))
106				path = NULL;
107			spin_lock(&req->r_old_dentry->d_lock);
108			seq_printf(s, " #%llx/%pd (%s)",
109				   req->r_old_dentry_dir ?
110				   ceph_ino(req->r_old_dentry_dir) : 0,
111				   req->r_old_dentry,
112				   path ? path : "");
113			spin_unlock(&req->r_old_dentry->d_lock);
114			ceph_mdsc_free_path(path, pathlen);
115		} else if (req->r_path2 && req->r_op != CEPH_MDS_OP_SYMLINK) {
116			if (req->r_ino2.ino)
117				seq_printf(s, " #%llx/%s", req->r_ino2.ino,
118					   req->r_path2);
119			else
120				seq_printf(s, " %s", req->r_path2);
121		}
122
123		seq_puts(s, "\n");
124	}
125	mutex_unlock(&mdsc->mutex);
126
127	return 0;
128}
129
130#define CEPH_METRIC_SHOW(name, total, avg, min, max, sq) {		\
131	s64 _total, _avg, _min, _max, _sq, _st;				\
132	_avg = ktime_to_us(avg);					\
133	_min = ktime_to_us(min == KTIME_MAX ? 0 : min);			\
134	_max = ktime_to_us(max);					\
135	_total = total - 1;						\
136	_sq = _total > 0 ? DIV64_U64_ROUND_CLOSEST(sq, _total) : 0;	\
137	_st = int_sqrt64(_sq);						\
138	_st = ktime_to_us(_st);						\
139	seq_printf(s, "%-14s%-12lld%-16lld%-16lld%-16lld%lld\n",	\
140		   name, total, _avg, _min, _max, _st);			\
141}
142
143static int metric_show(struct seq_file *s, void *p)
144{
145	struct ceph_fs_client *fsc = s->private;
146	struct ceph_mds_client *mdsc = fsc->mdsc;
147	struct ceph_client_metric *m = &mdsc->metric;
148	int nr_caps = 0;
149	s64 total, sum, avg, min, max, sq;
150
151	seq_printf(s, "item          total       avg_lat(us)     min_lat(us)     max_lat(us)     stdev(us)\n");
152	seq_printf(s, "-----------------------------------------------------------------------------------\n");
153
154	spin_lock(&m->read_latency_lock);
155	total = m->total_reads;
156	sum = m->read_latency_sum;
157	avg = total > 0 ? DIV64_U64_ROUND_CLOSEST(sum, total) : 0;
158	min = m->read_latency_min;
159	max = m->read_latency_max;
160	sq = m->read_latency_sq_sum;
161	spin_unlock(&m->read_latency_lock);
162	CEPH_METRIC_SHOW("read", total, avg, min, max, sq);
163
164	spin_lock(&m->write_latency_lock);
165	total = m->total_writes;
166	sum = m->write_latency_sum;
167	avg = total > 0 ? DIV64_U64_ROUND_CLOSEST(sum, total) : 0;
168	min = m->write_latency_min;
169	max = m->write_latency_max;
170	sq = m->write_latency_sq_sum;
171	spin_unlock(&m->write_latency_lock);
172	CEPH_METRIC_SHOW("write", total, avg, min, max, sq);
173
174	spin_lock(&m->metadata_latency_lock);
175	total = m->total_metadatas;
176	sum = m->metadata_latency_sum;
177	avg = total > 0 ? DIV64_U64_ROUND_CLOSEST(sum, total) : 0;
178	min = m->metadata_latency_min;
179	max = m->metadata_latency_max;
180	sq = m->metadata_latency_sq_sum;
181	spin_unlock(&m->metadata_latency_lock);
182	CEPH_METRIC_SHOW("metadata", total, avg, min, max, sq);
183
184	seq_printf(s, "\n");
185	seq_printf(s, "item          total           miss            hit\n");
186	seq_printf(s, "-------------------------------------------------\n");
187
188	seq_printf(s, "%-14s%-16lld%-16lld%lld\n", "d_lease",
189		   atomic64_read(&m->total_dentries),
190		   percpu_counter_sum(&m->d_lease_mis),
191		   percpu_counter_sum(&m->d_lease_hit));
192
193	nr_caps = atomic64_read(&m->total_caps);
194	seq_printf(s, "%-14s%-16d%-16lld%lld\n", "caps", nr_caps,
195		   percpu_counter_sum(&m->i_caps_mis),
196		   percpu_counter_sum(&m->i_caps_hit));
197
198	return 0;
199}
200
201static int caps_show_cb(struct inode *inode, struct ceph_cap *cap, void *p)
202{
203	struct seq_file *s = p;
204
205	seq_printf(s, "0x%-17llx%-17s%-17s\n", ceph_ino(inode),
206		   ceph_cap_string(cap->issued),
207		   ceph_cap_string(cap->implemented));
208	return 0;
209}
210
211static int caps_show(struct seq_file *s, void *p)
212{
213	struct ceph_fs_client *fsc = s->private;
214	struct ceph_mds_client *mdsc = fsc->mdsc;
215	int total, avail, used, reserved, min, i;
216	struct cap_wait	*cw;
217
218	ceph_reservation_status(fsc, &total, &avail, &used, &reserved, &min);
219	seq_printf(s, "total\t\t%d\n"
220		   "avail\t\t%d\n"
221		   "used\t\t%d\n"
222		   "reserved\t%d\n"
223		   "min\t\t%d\n\n",
224		   total, avail, used, reserved, min);
225	seq_printf(s, "ino                issued           implemented\n");
226	seq_printf(s, "-----------------------------------------------\n");
227
228	mutex_lock(&mdsc->mutex);
229	for (i = 0; i < mdsc->max_sessions; i++) {
230		struct ceph_mds_session *session;
231
232		session = __ceph_lookup_mds_session(mdsc, i);
233		if (!session)
234			continue;
235		mutex_unlock(&mdsc->mutex);
236		mutex_lock(&session->s_mutex);
237		ceph_iterate_session_caps(session, caps_show_cb, s);
238		mutex_unlock(&session->s_mutex);
239		ceph_put_mds_session(session);
240		mutex_lock(&mdsc->mutex);
241	}
242	mutex_unlock(&mdsc->mutex);
243
244	seq_printf(s, "\n\nWaiters:\n--------\n");
245	seq_printf(s, "tgid         ino                need             want\n");
246	seq_printf(s, "-----------------------------------------------------\n");
247
248	spin_lock(&mdsc->caps_list_lock);
249	list_for_each_entry(cw, &mdsc->cap_wait_list, list) {
250		seq_printf(s, "%-13d0x%-17llx%-17s%-17s\n", cw->tgid, cw->ino,
251				ceph_cap_string(cw->need),
252				ceph_cap_string(cw->want));
253	}
254	spin_unlock(&mdsc->caps_list_lock);
255
256	return 0;
257}
258
259static int mds_sessions_show(struct seq_file *s, void *ptr)
260{
261	struct ceph_fs_client *fsc = s->private;
262	struct ceph_mds_client *mdsc = fsc->mdsc;
263	struct ceph_auth_client *ac = fsc->client->monc.auth;
264	struct ceph_options *opt = fsc->client->options;
265	int mds;
266
267	mutex_lock(&mdsc->mutex);
268
269	/* The 'num' portion of an 'entity name' */
270	seq_printf(s, "global_id %llu\n", ac->global_id);
271
272	/* The -o name mount argument */
273	seq_printf(s, "name \"%s\"\n", opt->name ? opt->name : "");
274
275	/* The list of MDS session rank+state */
276	for (mds = 0; mds < mdsc->max_sessions; mds++) {
277		struct ceph_mds_session *session =
278			__ceph_lookup_mds_session(mdsc, mds);
279		if (!session) {
280			continue;
281		}
282		mutex_unlock(&mdsc->mutex);
283		seq_printf(s, "mds.%d %s\n",
284				session->s_mds,
285				ceph_session_state_name(session->s_state));
286
287		ceph_put_mds_session(session);
288		mutex_lock(&mdsc->mutex);
289	}
290	mutex_unlock(&mdsc->mutex);
291
292	return 0;
293}
294
295DEFINE_SHOW_ATTRIBUTE(mdsmap);
296DEFINE_SHOW_ATTRIBUTE(mdsc);
297DEFINE_SHOW_ATTRIBUTE(caps);
298DEFINE_SHOW_ATTRIBUTE(mds_sessions);
299DEFINE_SHOW_ATTRIBUTE(metric);
300
301
302/*
303 * debugfs
304 */
305static int congestion_kb_set(void *data, u64 val)
306{
307	struct ceph_fs_client *fsc = (struct ceph_fs_client *)data;
308
309	fsc->mount_options->congestion_kb = (int)val;
310	return 0;
311}
312
313static int congestion_kb_get(void *data, u64 *val)
314{
315	struct ceph_fs_client *fsc = (struct ceph_fs_client *)data;
316
317	*val = (u64)fsc->mount_options->congestion_kb;
318	return 0;
319}
320
321DEFINE_SIMPLE_ATTRIBUTE(congestion_kb_fops, congestion_kb_get,
322			congestion_kb_set, "%llu\n");
323
324
325void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc)
326{
327	dout("ceph_fs_debugfs_cleanup\n");
328	debugfs_remove(fsc->debugfs_bdi);
329	debugfs_remove(fsc->debugfs_congestion_kb);
330	debugfs_remove(fsc->debugfs_mdsmap);
331	debugfs_remove(fsc->debugfs_mds_sessions);
332	debugfs_remove(fsc->debugfs_caps);
333	debugfs_remove(fsc->debugfs_metric);
334	debugfs_remove(fsc->debugfs_mdsc);
335}
336
337void ceph_fs_debugfs_init(struct ceph_fs_client *fsc)
338{
339	char name[100];
340
341	dout("ceph_fs_debugfs_init\n");
342	fsc->debugfs_congestion_kb =
343		debugfs_create_file("writeback_congestion_kb",
344				    0600,
345				    fsc->client->debugfs_dir,
346				    fsc,
347				    &congestion_kb_fops);
348
349	snprintf(name, sizeof(name), "../../bdi/%s",
350		 bdi_dev_name(fsc->sb->s_bdi));
351	fsc->debugfs_bdi =
352		debugfs_create_symlink("bdi",
353				       fsc->client->debugfs_dir,
354				       name);
355
356	fsc->debugfs_mdsmap = debugfs_create_file("mdsmap",
357					0400,
358					fsc->client->debugfs_dir,
359					fsc,
360					&mdsmap_fops);
361
362	fsc->debugfs_mds_sessions = debugfs_create_file("mds_sessions",
363					0400,
364					fsc->client->debugfs_dir,
365					fsc,
366					&mds_sessions_fops);
367
368	fsc->debugfs_mdsc = debugfs_create_file("mdsc",
369						0400,
370						fsc->client->debugfs_dir,
371						fsc,
372						&mdsc_fops);
373
374	fsc->debugfs_metric = debugfs_create_file("metrics",
375						  0400,
376						  fsc->client->debugfs_dir,
377						  fsc,
378						  &metric_fops);
379
380	fsc->debugfs_caps = debugfs_create_file("caps",
381						0400,
382						fsc->client->debugfs_dir,
383						fsc,
384						&caps_fops);
385}
386
387
388#else  /* CONFIG_DEBUG_FS */
389
390void ceph_fs_debugfs_init(struct ceph_fs_client *fsc)
391{
392}
393
394void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc)
395{
396}
397
398#endif  /* CONFIG_DEBUG_FS */