| /linux/include/linux/sunrpc/ |
| H A D | sched.h | 54 struct rpc_task { struct
63 void (*tk_callback)(struct rpc_task *); argument
64 void (*tk_action)(struct rpc_task *); argument
107 typedef void (*rpc_action)(struct rpc_task *); argument
110 void (*rpc_call_prepare)(struct rpc_task *, void *);
111 void (*rpc_call_done)(struct rpc_task *, void *);
112 void (*rpc_count_stats)(struct rpc_task *, void *);
117 struct rpc_task *task;
219 struct rpc_task *rpc_new_task(const struct rpc_task_setup *);
220 struct rpc_task *rpc_run_tas
66 tk_timeoutrpc_task global() argument
67 tk_runstaterpc_task global() argument
69 tk_waitqueuerpc_task global() argument
70 __anon8fcffb37010arpc_task global() argument
73 urpc_task global() argument
78 tk_msgrpc_task global() argument
79 tk_calldatarpc_task global() argument
80 tk_opsrpc_task global() argument
82 tk_clientrpc_task global() argument
83 tk_xprtrpc_task global() argument
[all...] |
| H A D | xprt.h | 45 struct rpc_task;
67 struct rpc_task * rq_task; /* RPC task data */
154 int (*reserve_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
155 void (*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
156 void (*alloc_slot)(struct rpc_xprt *xprt, struct rpc_task *task);
159 void (*rpcbind)(struct rpc_task *task);
161 void (*connect)(struct rpc_xprt *xprt, struct rpc_task *task);
165 int (*buf_alloc)(struct rpc_task *task);
166 void (*buf_free)(struct rpc_task *task);
171 void (*wait_for_reply_request)(struct rpc_task *tas
[all...] |
| H A D | auth.h | 132 int (*crmarshal)(struct rpc_task *task,
134 int (*crrefresh)(struct rpc_task *);
135 int (*crvalidate)(struct rpc_task *task,
137 int (*crwrap_req)(struct rpc_task *task,
139 int (*crunwrap_resp)(struct rpc_task *task,
143 bool (*crneed_reencode)(struct rpc_task *);
168 int rpcauth_marshcred(struct rpc_task *task,
170 int rpcauth_checkverf(struct rpc_task *task,
172 int rpcauth_wrap_req_encode(struct rpc_task *task,
174 int rpcauth_wrap_req(struct rpc_task *tas
[all...] |
| H A D | metrics.h | 76 struct rpc_task;
86 void rpc_count_iostats(const struct rpc_task *,
88 void rpc_count_iostats_metrics(const struct rpc_task *,
96 static inline void rpc_count_iostats(const struct rpc_task *task, in rpc_count_iostats()
98 static inline void rpc_count_iostats_metrics(const struct rpc_task *task, in rpc_count_iostats_metrics()
|
| H A D | clnt.h | 194 void rpc_task_release_transport(struct rpc_task *);
195 void rpc_task_release_client(struct rpc_task *);
206 void rpcb_getport_async(struct rpc_task *);
211 void rpc_call_start(struct rpc_task *);
218 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred,
220 int rpc_restart_call_prepare(struct rpc_task *);
221 int rpc_restart_call(struct rpc_task *);
258 const char *rpc_proc_name(const struct rpc_task *task);
268 static inline int rpc_reply_expected(struct rpc_task *task) in rpc_reply_expected()
274 static inline void rpc_task_close_connection(struct rpc_task *tas
[all...] |
| H A D | bc_xprt.h | 23 void xprt_init_bc_request(struct rpc_rqst *req, struct rpc_task *task,
|
| /linux/net/sunrpc/ |
| H A D | sched.c | 45 static void rpc_release_task(struct rpc_task *task);
68 bool rpc_task_set_rpc_status(struct rpc_task *task, int rpc_status) in rpc_task_set_rpc_status()
76 rpc_task_timeout(const struct rpc_task *task) in rpc_task_timeout()
95 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer()
121 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task, in __rpc_add_timer()
147 __rpc_list_enqueue_task(struct list_head *q, struct rpc_task *task) in __rpc_list_enqueue_task()
149 struct rpc_task *t; in __rpc_list_enqueue_task()
169 __rpc_list_dequeue_task(struct rpc_task *task) in __rpc_list_dequeue_task()
172 struct rpc_task *t; in __rpc_list_dequeue_task()
180 struct rpc_task, in __rpc_list_dequeue_task()
533 rpc_wake_up_task_on_wq_queue_action_locked(struct workqueue_struct * wq,struct rpc_wait_queue * queue,struct rpc_task * task,bool (* action)(struct rpc_task *,void *),void * data) rpc_wake_up_task_on_wq_queue_action_locked() argument
668 rpc_wake_up_first_on_wq(struct workqueue_struct * wq,struct rpc_wait_queue * queue,bool (* func)(struct rpc_task *,void *),void * data) rpc_wake_up_first_on_wq() argument
686 rpc_wake_up_first(struct rpc_wait_queue * queue,bool (* func)(struct rpc_task *,void *),void * data) rpc_wake_up_first() argument
[all...] |
| H A D | clnt.c | 53 static void call_start(struct rpc_task *task);
54 static void call_reserve(struct rpc_task *task);
55 static void call_reserveresult(struct rpc_task *task);
56 static void call_allocate(struct rpc_task *task);
57 static void call_encode(struct rpc_task *task);
58 static void call_decode(struct rpc_task *task);
59 static void call_bind(struct rpc_task *task);
60 static void call_bind_status(struct rpc_task *task);
61 static void call_transmit(struct rpc_task *task);
62 static void call_status(struct rpc_task *tas
903 rpc_cancel_tasks(struct rpc_clnt * clnt,int error,bool (* fnmatch)(const struct rpc_task *,const void *),const void * data) rpc_cancel_tasks() argument
1671 __rpc_restart_call(struct rpc_task * task,void (* action)(struct rpc_task *)) __rpc_restart_call() argument
[all...] |
| H A D | xprt.c | 75 static void xprt_request_init(struct rpc_task *task);
265 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt()
329 int xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt_cong()
364 static inline int xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_lock_write()
376 static bool __xprt_lock_write_func(struct rpc_task *task, void *data) in __xprt_lock_write_func()
419 void xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt()
437 void xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt_cong()
447 void xprt_release_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_write()
518 void xprt_release_rqst_cong(struct rpc_task *task) in xprt_release_rqst_cong()
562 void xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *tas
[all...] |
| H A D | auth_tls.c | 35 static void rpc_tls_probe_call_prepare(struct rpc_task *task, void *data) in rpc_tls_probe_call_prepare()
41 static void rpc_tls_probe_call_done(struct rpc_task *task, void *data) in rpc_tls_probe_call_done()
62 struct rpc_task *task; in tls_probe()
99 static int tls_marshal(struct rpc_task *task, struct xdr_stream *xdr) in tls_marshal()
115 static int tls_refresh(struct rpc_task *task) in tls_refresh()
121 static int tls_validate(struct rpc_task *task, struct xdr_stream *xdr) in tls_validate()
|
| H A D | auth_null.c | 63 nul_marshal(struct rpc_task *task, struct xdr_stream *xdr) in nul_marshal()
83 nul_refresh(struct rpc_task *task) in nul_refresh()
90 nul_validate(struct rpc_task *task, struct xdr_stream *xdr) in nul_validate()
|
| H A D | debugfs.c | 23 struct rpc_task *task = v; in tasks_show()
47 struct rpc_task *task; in tasks_start()
60 struct rpc_task *task = v; in tasks_next()
68 return list_entry(next, struct rpc_task, tk_task); in tasks_next()
|
| H A D | auth_unix.c | 111 unx_marshal(struct rpc_task *task, struct xdr_stream *xdr) in unx_marshal()
166 unx_refresh(struct rpc_task *task) in unx_refresh()
173 unx_validate(struct rpc_task *task, struct xdr_stream *xdr) in unx_validate()
|
| /linux/fs/nfs/ |
| H A D | unlink.c | 41 * @task: rpc_task of the sillydelete
46 static void nfs_async_unlink_done(struct rpc_task *task, void *calldata) in nfs_async_unlink_done()
61 * rpc_task would be freed too.
76 static void nfs_unlink_prepare(struct rpc_task *task, void *calldata) in nfs_unlink_prepare()
103 struct rpc_task *task; in nfs_do_call_unlink()
260 * @task: rpc_task of the sillyrename
265 static void nfs_async_rename_done(struct rpc_task *task, void *calldata) in nfs_async_rename_done()
317 static void nfs_rename_prepare(struct rpc_task *task, void *calldata) in nfs_rename_prepare()
339 struct rpc_task *
342 void (*complete)(struct rpc_task *, struc in nfs_async_rename() argument
[all...] |
| H A D | nfs3proc.c | 49 nfs3_async_handle_jukebox(struct rpc_task *task, struct inode *inode) in nfs3_async_handle_jukebox()
467 static void nfs3_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs3_proc_unlink_rpc_prepare()
473 nfs3_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs3_proc_unlink_done()
491 static void nfs3_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs3_proc_rename_rpc_prepare()
497 nfs3_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs3_proc_rename_done()
884 static int nfs3_read_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs3_read_done()
913 static int nfs3_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs3_proc_pgio_rpc_prepare()
920 static int nfs3_write_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs3_write_done()
943 static void nfs3_proc_commit_rpc_prepare(struct rpc_task *task, struct nfs_commit_data *data) in nfs3_proc_commit_rpc_prepare()
948 static int nfs3_commit_done(struct rpc_task *tas
[all...] |
| H A D | nfs4_fs.h | 96 struct rpc_task *task;
290 extern int nfs4_async_handle_error(struct rpc_task *task,
344 extern int nfs41_sequence_done(struct rpc_task *, struct nfs4_sequence_res *);
525 extern int nfs_wait_on_sequence(struct nfs_seqid *seqid, struct rpc_task *task);
533 struct rpc_task *task);
534 extern int nfs4_sequence_done(struct rpc_task *task,
|
| H A D | nfs4proc.c | 102 static struct rpc_task *_nfs41_proc_sequence(struct nfs_client *clp,
673 nfs4_async_handle_exception(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_exception()
723 nfs4_async_handle_error(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_error()
801 static int nfs40_sequence_done(struct rpc_task *task, in nfs40_sequence_done()
871 struct rpc_task *task = _nfs41_proc_sequence(client, cred, slot, true); in nfs4_probe_sequence()
876 static int nfs41_sequence_process(struct rpc_task *task, in nfs41_sequence_process()
1014 int nfs41_sequence_done(struct rpc_task *task, struct nfs4_sequence_res *res) in nfs41_sequence_done()
1025 static int nfs4_sequence_process(struct rpc_task *task, struct nfs4_sequence_res *res) in nfs4_sequence_process()
1044 int nfs4_sequence_done(struct rpc_task *task, struct nfs4_sequence_res *res) in nfs4_sequence_done()
1054 static void nfs41_call_sync_prepare(struct rpc_task *tas
[all...] |
| H A D | pnfs.h | 310 int pnfs_roc_done(struct rpc_task *task, struct nfs4_layoutreturn_args **argpp,
315 bool pnfs_wait_on_layoutreturn(struct inode *ino, struct rpc_task *task);
417 void pnfs_generic_write_commit_done(struct rpc_task *task, void *data);
787 pnfs_roc_done(struct rpc_task *task, in pnfs_roc_done()
803 pnfs_wait_on_layoutreturn(struct inode *ino, struct rpc_task *task) in pnfs_wait_on_layoutreturn()
|
| /linux/fs/nfs/flexfilelayout/ |
| H A D | flexfilelayout.c | 42 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task,
693 nfs4_ff_layout_stat_io_end_read(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_read()
724 nfs4_ff_layout_stat_io_end_write(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_write()
1037 struct rpc_task *task = &hdr->task; in ff_layout_reset_write()
1085 struct rpc_task *task = &hdr->task; in ff_layout_reset_read()
1107 static int ff_layout_async_handle_error_v4(struct rpc_task *task, in ff_layout_async_handle_error_v4()
1209 static int ff_layout_async_handle_error_v3(struct rpc_task *task, in ff_layout_async_handle_error_v3()
1274 static int ff_layout_async_handle_error(struct rpc_task *task, in ff_layout_async_handle_error()
1371 static int ff_layout_read_done_cb(struct rpc_task *task, in ff_layout_read_done_cb()
1440 static void ff_layout_read_record_layoutstats_start(struct rpc_task *tas
[all...] |
| /linux/include/linux/lockd/ |
| H A D | bind.h | 22 struct rpc_task;
75 bool (*nlmclnt_unlock_prepare)(struct rpc_task*, void *);
|
| /linux/fs/nfs/filelayout/ |
| H A D | filelayout.c | 91 struct rpc_task *task = &hdr->task; in filelayout_reset_write()
108 struct rpc_task *task = &hdr->task; in filelayout_reset_read()
123 static int filelayout_async_handle_error(struct rpc_task *task, in filelayout_async_handle_error()
205 static int filelayout_read_done_cb(struct rpc_task *task, in filelayout_read_done_cb()
268 static void filelayout_read_prepare(struct rpc_task *task, void *data) in filelayout_read_prepare()
294 static void filelayout_read_call_done(struct rpc_task *task, void *data) in filelayout_read_call_done()
308 static void filelayout_read_count_stats(struct rpc_task *task, void *data) in filelayout_read_count_stats()
315 static int filelayout_write_done_cb(struct rpc_task *task, in filelayout_write_done_cb()
343 static int filelayout_commit_done_cb(struct rpc_task *task, in filelayout_commit_done_cb()
366 static void filelayout_write_prepare(struct rpc_task *tas
[all...] |
| /linux/include/linux/ |
| H A D | nfs_xdr.h | 319 struct rpc_task task;
1670 struct rpc_task task;
1675 int (*pgio_done_cb)(struct rpc_task *, struct nfs_pgio_header *);
1706 struct rpc_task task;
1723 int (*commit_done_cb) (struct rpc_task *task, struct nfs_commit_data *data);
1747 struct rpc_task task;
1755 void (*complete)(struct rpc_task *, struct nfs_renamedata *);
1799 void (*unlink_rpc_prepare) (struct rpc_task *, struct nfs_unlinkdata *);
1800 int (*unlink_done) (struct rpc_task *, struct inode *);
1804 void (*rename_rpc_prepare)(struct rpc_task *tas
[all...] |
| H A D | nfs_page.h | 80 int (*rw_done)(struct rpc_task *, struct nfs_pgio_header *,
82 void (*rw_result)(struct rpc_task *, struct nfs_pgio_header *);
165 extern bool nfs_async_iocounter_wait(struct rpc_task *, struct nfs_lock_context *);
|
| /linux/include/trace/events/ |
| H A D | rpcgss.h | 85 const struct rpc_task *task,
113 const struct rpc_task *task, \
344 const struct rpc_task *task
365 const struct rpc_task *task,
394 const struct rpc_task *task
422 const struct rpc_task *task,
456 const struct rpc_task *task,
|
| /linux/net/sunrpc/xprtrdma/ |
| H A D | svc_rdma_backchannel.c | 101 xprt_rdma_bc_allocate(struct rpc_task *task) in xprt_rdma_bc_allocate()
127 xprt_rdma_bc_free(struct rpc_task *task) in xprt_rdma_bc_free()
|