Linux Audio

Check our new training course

Loading...
v4.6
 
  1#include <linux/ceph/ceph_debug.h>
  2
  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>
 
 
  9
 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>
 14
 15#include "super.h"
 16
 17#ifdef CONFIG_DEBUG_FS
 18
 19#include "mds_client.h"
 
 20
 21static int mdsmap_show(struct seq_file *s, void *p)
 22{
 23	int i;
 24	struct ceph_fs_client *fsc = s->private;
 
 25
 26	if (fsc->mdsc == NULL || fsc->mdsc->mdsmap == NULL)
 27		return 0;
 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;
 38
 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));
 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;
 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 (req->r_got_unsafe)
 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			kfree(path);
 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			kfree(path);
112		} else if (req->r_path2) {
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(struct seq_file *s, void *p)
128{
129	struct ceph_fs_client *fsc = s->private;
130	int total, avail, used, reserved, min;
 
 
131
132	ceph_reservation_status(fsc, &total, &avail, &used, &reserved, &min);
133	seq_printf(s, "total\t\t%d\n"
134		   "avail\t\t%d\n"
135		   "used\t\t%d\n"
136		   "reserved\t%d\n"
137		   "min\t%d\n",
138		   total, avail, used, reserved, min);
139	return 0;
140}
141
142static int dentry_lru_show(struct seq_file *s, void *ptr)
143{
144	struct ceph_fs_client *fsc = s->private;
145	struct ceph_mds_client *mdsc = fsc->mdsc;
146	struct ceph_dentry_info *di;
 
 
 
 
 
 
 
 
 
 
147
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",
152			   di, dentry, dentry);
 
 
 
 
153	}
154	spin_unlock(&mdsc->dentry_lru_lock);
155
156	return 0;
157}
158
159static int mds_sessions_show(struct seq_file *s, void *ptr)
160{
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;
165	int mds = -1;
166
167	mutex_lock(&mdsc->mutex);
168
169	/* The 'num' portion of an 'entity name' */
170	seq_printf(s, "global_id %llu\n", ac->global_id);
171
172	/* The -o name mount argument */
173	seq_printf(s, "name \"%s\"\n", opt->name ? opt->name : "");
174
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);
179		if (!session) {
180			continue;
181		}
182		mutex_unlock(&mdsc->mutex);
183		seq_printf(s, "mds.%d %s\n",
184				session->s_mds,
185				ceph_session_state_name(session->s_state));
186
187		ceph_put_mds_session(session);
188		mutex_lock(&mdsc->mutex);
189	}
190	mutex_unlock(&mdsc->mutex);
191
192	return 0;
193}
194
195CEPH_DEFINE_SHOW_FUNC(mdsmap_show)
196CEPH_DEFINE_SHOW_FUNC(mdsc_show)
197CEPH_DEFINE_SHOW_FUNC(caps_show)
198CEPH_DEFINE_SHOW_FUNC(dentry_lru_show)
199CEPH_DEFINE_SHOW_FUNC(mds_sessions_show)
200
201
202/*
203 * debugfs
204 */
205static int congestion_kb_set(void *data, u64 val)
206{
207	struct ceph_fs_client *fsc = (struct ceph_fs_client *)data;
208
209	fsc->mount_options->congestion_kb = (int)val;
210	return 0;
211}
212
213static int congestion_kb_get(void *data, u64 *val)
214{
215	struct ceph_fs_client *fsc = (struct ceph_fs_client *)data;
216
217	*val = (u64)fsc->mount_options->congestion_kb;
218	return 0;
219}
220
221DEFINE_SIMPLE_ATTRIBUTE(congestion_kb_fops, congestion_kb_get,
222			congestion_kb_set, "%llu\n");
223
224
225void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc)
226{
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);
235}
236
237int ceph_fs_debugfs_init(struct ceph_fs_client *fsc)
238{
239	char name[100];
240	int err = -ENOMEM;
241
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",
246				    0600,
247				    fsc->client->debugfs_dir,
248				    fsc,
249				    &congestion_kb_fops);
250	if (!fsc->debugfs_congestion_kb)
251		goto out;
252
253	snprintf(name, sizeof(name), "../../bdi/%s",
254		 dev_name(fsc->backing_dev_info.dev));
255	fsc->debugfs_bdi =
256		debugfs_create_symlink("bdi",
257				       fsc->client->debugfs_dir,
258				       name);
259	if (!fsc->debugfs_bdi)
260		goto out;
261
262	fsc->debugfs_mdsmap = debugfs_create_file("mdsmap",
263					0600,
264					fsc->client->debugfs_dir,
265					fsc,
266					&mdsmap_show_fops);
267	if (!fsc->debugfs_mdsmap)
268		goto out;
269
270	fsc->debugfs_mds_sessions = debugfs_create_file("mds_sessions",
271					0600,
272					fsc->client->debugfs_dir,
273					fsc,
274					&mds_sessions_show_fops);
275	if (!fsc->debugfs_mds_sessions)
276		goto out;
277
278	fsc->debugfs_mdsc = debugfs_create_file("mdsc",
279						0600,
280						fsc->client->debugfs_dir,
281						fsc,
282						&mdsc_show_fops);
283	if (!fsc->debugfs_mdsc)
284		goto out;
285
286	fsc->debugfs_caps = debugfs_create_file("caps",
287						   0400,
288						   fsc->client->debugfs_dir,
289						   fsc,
290						   &caps_show_fops);
291	if (!fsc->debugfs_caps)
292		goto out;
293
294	fsc->debugfs_dentry_lru = debugfs_create_file("dentry_lru",
295					0600,
296					fsc->client->debugfs_dir,
297					fsc,
298					&dentry_lru_show_fops);
299	if (!fsc->debugfs_dentry_lru)
300		goto out;
301
302	return 0;
303
304out:
305	ceph_fs_debugfs_cleanup(fsc);
306	return err;
307}
308
309
310#else  /* CONFIG_DEBUG_FS */
311
312int ceph_fs_debugfs_init(struct ceph_fs_client *fsc)
313{
314	return 0;
315}
316
317void ceph_fs_debugfs_cleanup(struct ceph_fs_client *fsc)
318{
319}
320
321#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 */