| /Linux-v4.19/include/linux/sunrpc/ |
| D | sched.h | 44 struct rpc_task { struct
53 void (*tk_callback)(struct rpc_task *); argument
54 void (*tk_action)(struct rpc_task *); argument
95 typedef void (*rpc_action)(struct rpc_task *); argument
98 void (*rpc_call_prepare)(struct rpc_task *, void *);
99 void (*rpc_call_done)(struct rpc_task *, void *);
100 void (*rpc_count_stats)(struct rpc_task *, void *);
105 struct rpc_task *task;
213 struct rpc_task *rpc_new_task(const struct rpc_task_setup *);
214 struct rpc_task *rpc_run_task(const struct rpc_task_setup *);
[all …]
|
| D | xprt.h | 56 struct rpc_task;
76 struct rpc_task * rq_task; /* RPC task data */
126 int (*reserve_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
127 void (*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
128 void (*alloc_slot)(struct rpc_xprt *xprt, struct rpc_task *task);
131 void (*rpcbind)(struct rpc_task *task);
133 void (*connect)(struct rpc_xprt *xprt, struct rpc_task *task);
134 int (*buf_alloc)(struct rpc_task *task);
135 void (*buf_free)(struct rpc_task *task);
136 int (*send_request)(struct rpc_task *task);
[all …]
|
| D | auth.h | 149 struct rpc_cred * (*crbind)(struct rpc_task *, struct rpc_cred *, int);
150 __be32 * (*crmarshal)(struct rpc_task *, __be32 *);
151 int (*crrefresh)(struct rpc_task *);
152 __be32 * (*crvalidate)(struct rpc_task *, __be32 *);
153 int (*crwrap_req)(struct rpc_task *, kxdreproc_t,
155 int (*crunwrap_resp)(struct rpc_task *, kxdrdproc_t,
189 struct rpc_cred * rpcauth_generic_bind_cred(struct rpc_task *, struct rpc_cred *, int);
191 __be32 * rpcauth_marshcred(struct rpc_task *, __be32 *);
192 __be32 * rpcauth_checkverf(struct rpc_task *, __be32 *);
193 int rpcauth_wrap_req(struct rpc_task *task, kxdreproc_t encode, void *rqstp, __be32 *data, void *…
[all …]
|
| D | metrics.h | 71 struct rpc_task;
81 void rpc_count_iostats(const struct rpc_task *,
83 void rpc_count_iostats_metrics(const struct rpc_task *,
91 static inline void rpc_count_iostats(const struct rpc_task *task, in rpc_count_iostats()
93 static inline void rpc_count_iostats_metrics(const struct rpc_task *task, in rpc_count_iostats_metrics()
|
| D | clnt.h | 159 void rpc_task_release_transport(struct rpc_task *);
160 void rpc_task_release_client(struct rpc_task *);
169 void rpcb_getport_async(struct rpc_task *);
171 void rpc_call_start(struct rpc_task *);
178 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred,
180 int rpc_restart_call_prepare(struct rpc_task *);
181 int rpc_restart_call(struct rpc_task *);
214 const char *rpc_proc_name(const struct rpc_task *task);
222 static inline int rpc_reply_expected(struct rpc_task *task) in rpc_reply_expected()
|
| /Linux-v4.19/net/sunrpc/ |
| D | sched.c | 46 static void rpc_release_task(struct rpc_task *task);
66 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer()
88 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_add_timer()
105 struct rpc_task *task; in rpc_rotate_queue_owner()
108 task = list_first_entry(q, struct rpc_task, u.tk_wait.list); in rpc_rotate_queue_owner()
139 struct rpc_task *task, in __rpc_add_wait_queue_priority()
143 struct rpc_task *t; in __rpc_add_wait_queue_priority()
169 struct rpc_task *task, in __rpc_add_wait_queue()
195 static void __rpc_remove_wait_queue_priority(struct rpc_task *task) in __rpc_remove_wait_queue_priority()
197 struct rpc_task *t; in __rpc_remove_wait_queue_priority()
[all …]
|
| D | clnt.c | 60 static void call_start(struct rpc_task *task);
61 static void call_reserve(struct rpc_task *task);
62 static void call_reserveresult(struct rpc_task *task);
63 static void call_allocate(struct rpc_task *task);
64 static void call_decode(struct rpc_task *task);
65 static void call_bind(struct rpc_task *task);
66 static void call_bind_status(struct rpc_task *task);
67 static void call_transmit(struct rpc_task *task);
69 static void call_bc_transmit(struct rpc_task *task);
71 static void call_status(struct rpc_task *task);
[all …]
|
| D | xprt.c | 70 static void xprt_connect_status(struct rpc_task *task);
71 static int __xprt_get_cong(struct rpc_xprt *, struct rpc_task *);
183 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt()
234 int xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt_cong()
271 static inline int xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_lock_write()
281 static bool __xprt_lock_write_func(struct rpc_task *task, void *data) in __xprt_lock_write_func()
304 static bool __xprt_lock_write_cong_func(struct rpc_task *task, void *data) in __xprt_lock_write_cong_func()
335 static void xprt_task_clear_bytes_sent(struct rpc_task *task) in xprt_task_clear_bytes_sent()
351 void xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt()
369 void xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt_cong()
[all …]
|
| D | auth_null.c | 65 nul_marshal(struct rpc_task *task, __be32 *p) in nul_marshal()
79 nul_refresh(struct rpc_task *task) in nul_refresh()
86 nul_validate(struct rpc_task *task, __be32 *p) in nul_validate()
|
| D | auth.c | 657 rpcauth_generic_bind_cred(struct rpc_task *task, struct rpc_cred *cred, int lookupflags) in rpcauth_generic_bind_cred()
666 rpcauth_bind_root_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_root_cred()
680 rpcauth_bind_new_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_new_cred()
690 rpcauth_bindcred(struct rpc_task *task, struct rpc_cred *cred, int flags) in rpcauth_bindcred()
750 rpcauth_marshcred(struct rpc_task *task, __be32 *p) in rpcauth_marshcred()
761 rpcauth_checkverf(struct rpc_task *task, __be32 *p) in rpcauth_checkverf()
781 rpcauth_wrap_req(struct rpc_task *task, kxdreproc_t encode, void *rqstp, in rpcauth_wrap_req()
806 rpcauth_unwrap_resp(struct rpc_task *task, kxdrdproc_t decode, void *rqstp, in rpcauth_unwrap_resp()
821 rpcauth_refreshcred(struct rpc_task *task) in rpcauth_refreshcred()
844 rpcauth_invalcred(struct rpc_task *task) in rpcauth_invalcred()
[all …]
|
| D | debugfs.c | 24 struct rpc_task *task = v; in tasks_show()
48 struct rpc_task *task; in tasks_start()
61 struct rpc_task *task = v; in tasks_next()
69 return list_entry(next, struct rpc_task, tk_task); in tasks_next()
|
| D | auth_unix.c | 149 unx_marshal(struct rpc_task *task, __be32 *p) in unx_marshal()
183 unx_refresh(struct rpc_task *task) in unx_refresh()
190 unx_validate(struct rpc_task *task, __be32 *p) in unx_validate()
|
| /Linux-v4.19/fs/nfs/ |
| D | unlink.c | 45 static void nfs_async_unlink_done(struct rpc_task *task, void *calldata) in nfs_async_unlink_done()
75 static void nfs_unlink_prepare(struct rpc_task *task, void *calldata) in nfs_unlink_prepare()
102 struct rpc_task *task; in nfs_do_call_unlink()
262 static void nfs_async_rename_done(struct rpc_task *task, void *calldata) in nfs_async_rename_done()
314 static void nfs_rename_prepare(struct rpc_task *task, void *calldata) in nfs_rename_prepare()
335 struct rpc_task *
338 void (*complete)(struct rpc_task *, struct nfs_renamedata *)) in nfs_async_rename() argument
357 struct rpc_task *task = ERR_CAST(data->cred); in nfs_async_rename()
399 nfs_complete_sillyrename(struct rpc_task *task, struct nfs_renamedata *data) in nfs_complete_sillyrename()
452 struct rpc_task *task; in nfs_sillyrename()
|
| D | nfs3proc.c | 48 nfs3_async_handle_jukebox(struct rpc_task *task, struct inode *inode) in nfs3_async_handle_jukebox()
425 static void nfs3_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs3_proc_unlink_rpc_prepare()
431 nfs3_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs3_proc_unlink_done()
449 static void nfs3_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs3_proc_rename_rpc_prepare()
455 nfs3_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs3_proc_rename_done()
786 static int nfs3_read_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs3_read_done()
807 static int nfs3_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs3_proc_pgio_rpc_prepare()
814 static int nfs3_write_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs3_write_done()
835 static void nfs3_proc_commit_rpc_prepare(struct rpc_task *task, struct nfs_commit_data *data) in nfs3_proc_commit_rpc_prepare()
840 static int nfs3_commit_done(struct rpc_task *task, struct nfs_commit_data *data) in nfs3_commit_done()
[all …]
|
| D | proc.c | 332 static void nfs_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs_proc_unlink_rpc_prepare()
337 static int nfs_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs_proc_unlink_done()
351 static void nfs_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs_proc_rename_rpc_prepare()
357 nfs_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs_proc_rename_done()
587 static int nfs_read_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs_read_done()
609 static int nfs_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs_proc_pgio_rpc_prepare()
616 static int nfs_write_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs_write_done()
632 static void nfs_proc_commit_rpc_prepare(struct rpc_task *task, struct nfs_commit_data *data) in nfs_proc_commit_rpc_prepare()
|
| D | nfs4_fs.h | 88 struct rpc_task *task;
279 extern int nfs4_async_handle_error(struct rpc_task *task,
311 extern int nfs41_sequence_done(struct rpc_task *, struct nfs4_sequence_res *);
501 extern int nfs_wait_on_sequence(struct nfs_seqid *seqid, struct rpc_task *task);
509 struct rpc_task *task);
510 extern int nfs4_sequence_done(struct rpc_task *task,
|
| D | nfs4proc.c | 101 static struct rpc_task *_nfs41_proc_sequence(struct nfs_client *clp,
566 nfs4_async_handle_exception(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_exception()
600 nfs4_async_handle_error(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_error()
678 static int nfs40_sequence_done(struct rpc_task *task, in nfs40_sequence_done()
733 static int nfs41_sequence_process(struct rpc_task *task, in nfs41_sequence_process()
847 int nfs41_sequence_done(struct rpc_task *task, struct nfs4_sequence_res *res) in nfs41_sequence_done()
858 static int nfs4_sequence_process(struct rpc_task *task, struct nfs4_sequence_res *res) in nfs4_sequence_process()
877 int nfs4_sequence_done(struct rpc_task *task, struct nfs4_sequence_res *res) in nfs4_sequence_done()
887 static void nfs41_call_sync_prepare(struct rpc_task *task, void *calldata) in nfs41_call_sync_prepare()
897 static void nfs41_call_sync_done(struct rpc_task *task, void *calldata) in nfs41_call_sync_done()
[all …]
|
| /Linux-v4.19/include/linux/lockd/ |
| D | bind.h | 22 struct rpc_task;
71 bool (*nlmclnt_unlock_prepare)(struct rpc_task*, void *);
|
| /Linux-v4.19/fs/nfs/flexfilelayout/ |
| D | flexfilelayout.c | 33 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()
990 struct rpc_task *task = &hdr->task; in ff_layout_reset_write()
1022 struct rpc_task *task = &hdr->task; in ff_layout_reset_read()
1039 static int ff_layout_async_handle_error_v4(struct rpc_task *task, in ff_layout_async_handle_error_v4()
1115 static int ff_layout_async_handle_error_v3(struct rpc_task *task, in ff_layout_async_handle_error_v3()
1148 static int ff_layout_async_handle_error(struct rpc_task *task, in ff_layout_async_handle_error()
1225 static int ff_layout_read_done_cb(struct rpc_task *task, in ff_layout_read_done_cb()
1300 static void ff_layout_read_record_layoutstats_start(struct rpc_task *task, in ff_layout_read_record_layoutstats_start()
[all …]
|
| /Linux-v4.19/include/trace/events/ |
| D | sunrpc.h | 19 TP_PROTO(struct rpc_task *task),
41 TP_PROTO(struct rpc_task *task),
47 TP_PROTO(struct rpc_task *task),
53 TP_PROTO(const struct rpc_task *task),
75 TP_PROTO(const struct rpc_task *task),
106 TP_PROTO(const struct rpc_task *task, const void *action),
140 TP_PROTO(const struct rpc_task *task, const void *action),
148 TP_PROTO(const struct rpc_task *task, const void *action),
156 TP_PROTO(const struct rpc_task *task, const void *action),
164 TP_PROTO(const struct rpc_task *task, const struct rpc_wait_queue *q),
[all …]
|
| /Linux-v4.19/include/linux/ |
| D | nfs_page.h | 72 int (*rw_done)(struct rpc_task *, struct nfs_pgio_header *,
74 void (*rw_result)(struct rpc_task *, struct nfs_pgio_header *);
145 extern bool nfs_async_iocounter_wait(struct rpc_task *, struct nfs_lock_context *);
|
| D | nfs_xdr.h | 309 struct rpc_task task;
1484 struct rpc_task task;
1489 int (*pgio_done_cb)(struct rpc_task *, struct nfs_pgio_header *);
1520 struct rpc_task task;
1537 int (*commit_done_cb) (struct rpc_task *task, struct nfs_commit_data *data);
1568 void (*complete)(struct rpc_task *, struct nfs_renamedata *);
1615 void (*unlink_rpc_prepare) (struct rpc_task *, struct nfs_unlinkdata *);
1616 int (*unlink_done) (struct rpc_task *, struct inode *);
1620 void (*rename_rpc_prepare)(struct rpc_task *task, struct nfs_renamedata *);
1621 int (*rename_done) (struct rpc_task *task, struct inode *old_dir, struct inode *new_dir);
[all …]
|
| /Linux-v4.19/fs/nfs/filelayout/ |
| D | filelayout.c | 90 struct rpc_task *task = &hdr->task; in filelayout_reset_write()
107 struct rpc_task *task = &hdr->task; in filelayout_reset_read()
122 static int filelayout_async_handle_error(struct rpc_task *task, in filelayout_async_handle_error()
202 static int filelayout_read_done_cb(struct rpc_task *task, in filelayout_read_done_cb()
265 static void filelayout_read_prepare(struct rpc_task *task, void *data) in filelayout_read_prepare()
291 static void filelayout_read_call_done(struct rpc_task *task, void *data) in filelayout_read_call_done()
307 static void filelayout_read_count_stats(struct rpc_task *task, void *data) in filelayout_read_count_stats()
314 static int filelayout_write_done_cb(struct rpc_task *task, in filelayout_write_done_cb()
342 static int filelayout_commit_done_cb(struct rpc_task *task, in filelayout_commit_done_cb()
365 static void filelayout_write_prepare(struct rpc_task *task, void *data) in filelayout_write_prepare()
[all …]
|
| /Linux-v4.19/net/sunrpc/xprtrdma/ |
| D | transport.c | 517 xprt_rdma_timer(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_rdma_timer()
523 xprt_rdma_connect(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_rdma_connect()
553 xprt_rdma_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_rdma_alloc_slot()
650 xprt_rdma_allocate(struct rpc_task *task) in xprt_rdma_allocate()
683 xprt_rdma_free(struct rpc_task *task) in xprt_rdma_free()
709 xprt_rdma_send_request(struct rpc_task *task) in xprt_rdma_send_request()
|
| D | svc_rdma_backchannel.c | 140 xprt_rdma_bc_allocate(struct rpc_task *task) in xprt_rdma_bc_allocate()
166 xprt_rdma_bc_free(struct rpc_task *task) in xprt_rdma_bc_free()
218 xprt_rdma_bc_send_request(struct rpc_task *task) in xprt_rdma_bc_send_request()
|
