2 * debugfs interface for sunrpc
4 * (c) 2014 Jeff Layton <jlayton@primarydata.com>
7 #include <linux/debugfs.h>
8 #include <linux/sunrpc/sched.h>
9 #include <linux/sunrpc/clnt.h>
12 static struct dentry
*topdir
;
13 static struct dentry
*rpc_clnt_dir
;
14 static struct dentry
*rpc_xprt_dir
;
16 struct rpc_clnt_iter
{
17 struct rpc_clnt
*clnt
;
22 tasks_show(struct seq_file
*f
, void *v
)
25 struct rpc_task
*task
= v
;
26 struct rpc_clnt
*clnt
= task
->tk_client
;
27 const char *rpc_waitq
= "none";
29 if (RPC_IS_QUEUED(task
))
30 rpc_waitq
= rpc_qname(task
->tk_waitqueue
);
33 xid
= be32_to_cpu(task
->tk_rqstp
->rq_xid
);
35 seq_printf(f
, "%5u %04x %6d 0x%x 0x%x %8ld %ps %sv%u %s a:%ps q:%s\n",
36 task
->tk_pid
, task
->tk_flags
, task
->tk_status
,
37 clnt
->cl_clid
, xid
, task
->tk_timeout
, task
->tk_ops
,
38 clnt
->cl_program
->name
, clnt
->cl_vers
, rpc_proc_name(task
),
39 task
->tk_action
, rpc_waitq
);
44 tasks_start(struct seq_file
*f
, loff_t
*ppos
)
45 __acquires(&clnt
->cl_lock
)
47 struct rpc_clnt_iter
*iter
= f
->private;
49 struct rpc_clnt
*clnt
= iter
->clnt
;
50 struct rpc_task
*task
;
53 spin_lock(&clnt
->cl_lock
);
54 list_for_each_entry(task
, &clnt
->cl_tasks
, tk_task
)
61 tasks_next(struct seq_file
*f
, void *v
, loff_t
*pos
)
63 struct rpc_clnt_iter
*iter
= f
->private;
64 struct rpc_clnt
*clnt
= iter
->clnt
;
65 struct rpc_task
*task
= v
;
66 struct list_head
*next
= task
->tk_task
.next
;
71 /* If there's another task on list, return it */
72 if (next
== &clnt
->cl_tasks
)
74 return list_entry(next
, struct rpc_task
, tk_task
);
78 tasks_stop(struct seq_file
*f
, void *v
)
79 __releases(&clnt
->cl_lock
)
81 struct rpc_clnt_iter
*iter
= f
->private;
82 struct rpc_clnt
*clnt
= iter
->clnt
;
84 spin_unlock(&clnt
->cl_lock
);
87 static const struct seq_operations tasks_seq_operations
= {
94 static int tasks_open(struct inode
*inode
, struct file
*filp
)
96 int ret
= seq_open_private(filp
, &tasks_seq_operations
,
97 sizeof(struct rpc_clnt_iter
));
100 struct seq_file
*seq
= filp
->private_data
;
101 struct rpc_clnt_iter
*iter
= seq
->private;
103 iter
->clnt
= inode
->i_private
;
105 if (!atomic_inc_not_zero(&iter
->clnt
->cl_count
)) {
106 seq_release_private(inode
, filp
);
115 tasks_release(struct inode
*inode
, struct file
*filp
)
117 struct seq_file
*seq
= filp
->private_data
;
118 struct rpc_clnt_iter
*iter
= seq
->private;
120 rpc_release_client(iter
->clnt
);
121 return seq_release_private(inode
, filp
);
124 static const struct file_operations tasks_fops
= {
125 .owner
= THIS_MODULE
,
129 .release
= tasks_release
,
133 rpc_clnt_debugfs_register(struct rpc_clnt
*clnt
)
136 char name
[24]; /* enough for "../../rpc_xprt/ + 8 hex digits + NULL */
138 /* Already registered? */
139 if (clnt
->cl_debugfs
)
142 len
= snprintf(name
, sizeof(name
), "%x", clnt
->cl_clid
);
143 if (len
>= sizeof(name
))
146 /* make the per-client dir */
147 clnt
->cl_debugfs
= debugfs_create_dir(name
, rpc_clnt_dir
);
148 if (!clnt
->cl_debugfs
)
151 /* make tasks file */
153 if (!debugfs_create_file("tasks", S_IFREG
| S_IRUSR
, clnt
->cl_debugfs
,
159 len
= snprintf(name
, sizeof(name
), "../../rpc_xprt/%s",
160 rcu_dereference(clnt
->cl_xprt
)->debugfs
->d_name
.name
);
162 if (len
>= sizeof(name
))
166 if (!debugfs_create_symlink("xprt", clnt
->cl_debugfs
, name
))
171 debugfs_remove_recursive(clnt
->cl_debugfs
);
172 clnt
->cl_debugfs
= NULL
;
177 rpc_clnt_debugfs_unregister(struct rpc_clnt
*clnt
)
179 debugfs_remove_recursive(clnt
->cl_debugfs
);
180 clnt
->cl_debugfs
= NULL
;
184 xprt_info_show(struct seq_file
*f
, void *v
)
186 struct rpc_xprt
*xprt
= f
->private;
188 seq_printf(f
, "netid: %s\n", xprt
->address_strings
[RPC_DISPLAY_NETID
]);
189 seq_printf(f
, "addr: %s\n", xprt
->address_strings
[RPC_DISPLAY_ADDR
]);
190 seq_printf(f
, "port: %s\n", xprt
->address_strings
[RPC_DISPLAY_PORT
]);
191 seq_printf(f
, "state: 0x%lx\n", xprt
->state
);
196 xprt_info_open(struct inode
*inode
, struct file
*filp
)
199 struct rpc_xprt
*xprt
= inode
->i_private
;
201 ret
= single_open(filp
, xprt_info_show
, xprt
);
204 if (!xprt_get(xprt
)) {
205 single_release(inode
, filp
);
213 xprt_info_release(struct inode
*inode
, struct file
*filp
)
215 struct rpc_xprt
*xprt
= inode
->i_private
;
218 return single_release(inode
, filp
);
221 static const struct file_operations xprt_info_fops
= {
222 .owner
= THIS_MODULE
,
223 .open
= xprt_info_open
,
226 .release
= xprt_info_release
,
230 rpc_xprt_debugfs_register(struct rpc_xprt
*xprt
)
233 static atomic_t cur_id
;
234 char name
[9]; /* 8 hex digits + NULL term */
236 id
= (unsigned int)atomic_inc_return(&cur_id
);
238 len
= snprintf(name
, sizeof(name
), "%x", id
);
239 if (len
>= sizeof(name
))
242 /* make the per-client dir */
243 xprt
->debugfs
= debugfs_create_dir(name
, rpc_xprt_dir
);
247 /* make tasks file */
248 if (!debugfs_create_file("info", S_IFREG
| S_IRUSR
, xprt
->debugfs
,
249 xprt
, &xprt_info_fops
)) {
250 debugfs_remove_recursive(xprt
->debugfs
);
251 xprt
->debugfs
= NULL
;
259 rpc_xprt_debugfs_unregister(struct rpc_xprt
*xprt
)
261 debugfs_remove_recursive(xprt
->debugfs
);
262 xprt
->debugfs
= NULL
;
266 sunrpc_debugfs_exit(void)
268 debugfs_remove_recursive(topdir
);
272 sunrpc_debugfs_init(void)
274 topdir
= debugfs_create_dir("sunrpc", NULL
);
278 rpc_clnt_dir
= debugfs_create_dir("rpc_clnt", topdir
);
282 rpc_xprt_dir
= debugfs_create_dir("rpc_xprt", topdir
);
288 debugfs_remove_recursive(topdir
);