Home
last modified time | relevance | path

Searched refs:rpc_task (Results 1 – 25 of 56) sorted by relevance

123

/Linux-v5.4/include/linux/sunrpc/
Dsched.h43 struct rpc_task { struct
52 void (*tk_callback)(struct rpc_task *); argument
53 void (*tk_action)(struct rpc_task *); argument
97 typedef void (*rpc_action)(struct rpc_task *); argument
100 void (*rpc_call_prepare)(struct rpc_task *, void *);
101 void (*rpc_call_done)(struct rpc_task *, void *);
102 void (*rpc_count_stats)(struct rpc_task *, void *);
107 struct rpc_task *task;
217 struct rpc_task *rpc_new_task(const struct rpc_task_setup *);
218 struct rpc_task *rpc_run_task(const struct rpc_task_setup *);
[all …]
Dxprt.h56 struct rpc_task;
76 struct rpc_task * rq_task; /* RPC task data */
134 int (*reserve_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
135 void (*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
136 void (*alloc_slot)(struct rpc_xprt *xprt, struct rpc_task *task);
139 void (*rpcbind)(struct rpc_task *task);
141 void (*connect)(struct rpc_xprt *xprt, struct rpc_task *task);
142 int (*buf_alloc)(struct rpc_task *task);
143 void (*buf_free)(struct rpc_task *task);
146 void (*wait_for_reply_request)(struct rpc_task *task);
[all …]
Dauth.h132 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 *task,
[all …]
Dmetrics.h76 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()
Dclnt.h165 void rpc_task_release_transport(struct rpc_task *);
166 void rpc_task_release_client(struct rpc_task *);
177 void rpcb_getport_async(struct rpc_task *);
182 void rpc_call_start(struct rpc_task *);
189 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred,
191 int rpc_restart_call_prepare(struct rpc_task *);
192 int rpc_restart_call(struct rpc_task *);
226 const char *rpc_proc_name(const struct rpc_task *task);
234 static inline int rpc_reply_expected(struct rpc_task *task) in rpc_reply_expected()
/Linux-v5.4/net/sunrpc/
Dsched.c49 static void rpc_release_task(struct rpc_task *task);
65 rpc_task_timeout(const struct rpc_task *task) in rpc_task_timeout()
84 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer()
111 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task, in __rpc_add_timer()
140 __rpc_list_enqueue_task(struct list_head *q, struct rpc_task *task) in __rpc_list_enqueue_task()
142 struct rpc_task *t; in __rpc_list_enqueue_task()
162 __rpc_list_dequeue_task(struct rpc_task *task) in __rpc_list_dequeue_task()
165 struct rpc_task *t; in __rpc_list_dequeue_task()
173 struct rpc_task, in __rpc_list_dequeue_task()
187 struct rpc_task *task, in __rpc_add_wait_queue_priority()
[all …]
Dclnt.c61 static void call_start(struct rpc_task *task);
62 static void call_reserve(struct rpc_task *task);
63 static void call_reserveresult(struct rpc_task *task);
64 static void call_allocate(struct rpc_task *task);
65 static void call_encode(struct rpc_task *task);
66 static void call_decode(struct rpc_task *task);
67 static void call_bind(struct rpc_task *task);
68 static void call_bind_status(struct rpc_task *task);
69 static void call_transmit(struct rpc_task *task);
70 static void call_status(struct rpc_task *task);
[all …]
Dxprt.c202 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt()
266 int xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt_cong()
299 static inline int xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_lock_write()
311 static bool __xprt_lock_write_func(struct rpc_task *task, void *data) in __xprt_lock_write_func()
354 void xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt()
371 void xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt_cong()
380 static inline void xprt_release_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_write()
451 void xprt_release_rqst_cong(struct rpc_task *task) in xprt_release_rqst_cong()
495 void xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result) in xprt_adjust_cwnd()
606 static void xprt_init_majortimeo(struct rpc_task *task, struct rpc_rqst *req) in xprt_init_majortimeo()
[all …]
Dauth.c659 rpcauth_bind_root_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_root_cred()
673 rpcauth_bind_machine_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_machine_cred()
687 rpcauth_bind_new_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_new_cred()
695 rpcauth_bindcred(struct rpc_task *task, const struct cred *cred, int flags) in rpcauth_bindcred()
772 int rpcauth_marshcred(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_marshcred()
787 int rpcauth_wrap_req_encode(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_wrap_req_encode()
805 int rpcauth_wrap_req(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_wrap_req()
822 rpcauth_checkverf(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_checkverf()
837 rpcauth_unwrap_resp_decode(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_unwrap_resp_decode()
853 rpcauth_unwrap_resp(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_unwrap_resp()
[all …]
Dauth_null.c63 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()
Ddebugfs.c23 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()
Dauth_unix.c103 unx_marshal(struct rpc_task *task, struct xdr_stream *xdr) in unx_marshal()
158 unx_refresh(struct rpc_task *task) in unx_refresh()
165 unx_validate(struct rpc_task *task, struct xdr_stream *xdr) in unx_validate()
/Linux-v5.4/fs/nfs/
Dunlink.c46 static void nfs_async_unlink_done(struct rpc_task *task, void *calldata) in nfs_async_unlink_done()
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()
258 static void nfs_async_rename_done(struct rpc_task *task, void *calldata) in nfs_async_rename_done()
310 static void nfs_rename_prepare(struct rpc_task *task, void *calldata) in nfs_rename_prepare()
332 struct rpc_task *
335 void (*complete)(struct rpc_task *, struct nfs_renamedata *)) in nfs_async_rename() argument
391 nfs_complete_sillyrename(struct rpc_task *task, struct nfs_renamedata *data) in nfs_complete_sillyrename()
438 struct rpc_task *task; in nfs_sillyrename()
Dproc.c332 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()
610 static int nfs_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs_proc_pgio_rpc_prepare()
617 static int nfs_write_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs_write_done()
635 static void nfs_proc_commit_rpc_prepare(struct rpc_task *task, struct nfs_commit_data *data) in nfs_proc_commit_rpc_prepare()
Dnfs4_fs.h91 struct rpc_task *task;
284 extern int nfs4_async_handle_error(struct rpc_task *task,
318 extern int nfs41_sequence_done(struct rpc_task *, struct nfs4_sequence_res *);
498 extern int nfs_wait_on_sequence(struct nfs_seqid *seqid, struct rpc_task *task);
506 struct rpc_task *task);
507 extern int nfs4_sequence_done(struct rpc_task *task,
Dnfs3proc.c48 nfs3_async_handle_jukebox(struct rpc_task *task, struct inode *inode) in nfs3_async_handle_jukebox()
434 static void nfs3_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs3_proc_unlink_rpc_prepare()
440 nfs3_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs3_proc_unlink_done()
458 static void nfs3_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs3_proc_rename_rpc_prepare()
464 nfs3_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs3_proc_rename_done()
813 static int nfs3_read_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs3_read_done()
839 static int nfs3_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs3_proc_pgio_rpc_prepare()
846 static int nfs3_write_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs3_write_done()
867 static void nfs3_proc_commit_rpc_prepare(struct rpc_task *task, struct nfs_commit_data *data) in nfs3_proc_commit_rpc_prepare()
872 static int nfs3_commit_done(struct rpc_task *task, struct nfs_commit_data *data) in nfs3_commit_done()
[all …]
Dnfs4proc.c101 static struct rpc_task *_nfs41_proc_sequence(struct nfs_client *clp,
599 nfs4_async_handle_exception(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_exception()
633 nfs4_async_handle_error(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_error()
711 static int nfs40_sequence_done(struct rpc_task *task, in nfs40_sequence_done()
779 static int nfs41_sequence_process(struct rpc_task *task, in nfs41_sequence_process()
897 int nfs41_sequence_done(struct rpc_task *task, struct nfs4_sequence_res *res) in nfs41_sequence_done()
908 static int nfs4_sequence_process(struct rpc_task *task, struct nfs4_sequence_res *res) in nfs4_sequence_process()
927 int nfs4_sequence_done(struct rpc_task *task, struct nfs4_sequence_res *res) in nfs4_sequence_done()
937 static void nfs41_call_sync_prepare(struct rpc_task *task, void *calldata) in nfs41_call_sync_prepare()
947 static void nfs41_call_sync_done(struct rpc_task *task, void *calldata) in nfs41_call_sync_done()
[all …]
Dnfs42proc.c385 static void nfs42_offload_cancel_prepare(struct rpc_task *task, void *calldata) in nfs42_offload_cancel_prepare()
394 static void nfs42_offload_cancel_done(struct rpc_task *task, void *calldata) in nfs42_offload_cancel_done()
422 struct rpc_task *task; in nfs42_do_offload_cancel_async()
535 nfs42_layoutstat_prepare(struct rpc_task *task, void *calldata) in nfs42_layoutstat_prepare()
556 nfs42_layoutstat_done(struct rpc_task *task, void *calldata) in nfs42_layoutstat_done()
657 struct rpc_task *task; in nfs42_proc_layoutstats_generic()
701 nfs42_layouterror_prepare(struct rpc_task *task, void *calldata) in nfs42_layouterror_prepare()
724 nfs42_layouterror_done(struct rpc_task *task, void *calldata) in nfs42_layouterror_done()
800 struct rpc_task *task; in nfs42_proc_layouterror()
/Linux-v5.4/include/trace/events/
Drpcgss.h73 const struct rpc_task *task,
101 const struct rpc_task *task, \
136 const struct rpc_task *task
156 const struct rpc_task *task,
184 const struct rpc_task *task
212 const struct rpc_task *task,
Dsunrpc.h19 TP_PROTO(const struct rpc_task *task),
42 const struct rpc_task *task \
51 TP_PROTO(const struct rpc_task *task),
126 TP_PROTO(const struct rpc_task *task, const void *action),
160 const struct rpc_task *task, \
171 TP_PROTO(const struct rpc_task *task, const struct rpc_wait_queue *q),
208 const struct rpc_task *task, \
218 TP_PROTO(const struct rpc_task *task),
239 const struct rpc_task *task \
249 const struct rpc_task *task
[all …]
/Linux-v5.4/include/linux/lockd/
Dbind.h22 struct rpc_task;
72 bool (*nlmclnt_unlock_prepare)(struct rpc_task*, void *);
/Linux-v5.4/fs/nfs/flexfilelayout/
Dflexfilelayout.c35 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task,
702 nfs4_ff_layout_stat_io_end_read(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_read()
733 nfs4_ff_layout_stat_io_end_write(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_write()
1071 struct rpc_task *task = &hdr->task; in ff_layout_reset_write()
1107 struct rpc_task *task = &hdr->task; in ff_layout_reset_read()
1128 static int ff_layout_async_handle_error_v4(struct rpc_task *task, in ff_layout_async_handle_error_v4()
1204 static int ff_layout_async_handle_error_v3(struct rpc_task *task, in ff_layout_async_handle_error_v3()
1237 static int ff_layout_async_handle_error(struct rpc_task *task, in ff_layout_async_handle_error()
1318 static int ff_layout_read_done_cb(struct rpc_task *task, in ff_layout_read_done_cb()
1389 static void ff_layout_read_record_layoutstats_start(struct rpc_task *task, in ff_layout_read_record_layoutstats_start()
[all …]
/Linux-v5.4/include/linux/
Dnfs_page.h72 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 *);
Dnfs_xdr.h309 struct rpc_task task;
1529 struct rpc_task task;
1534 int (*pgio_done_cb)(struct rpc_task *, struct nfs_pgio_header *);
1565 struct rpc_task task;
1582 int (*commit_done_cb) (struct rpc_task *task, struct nfs_commit_data *data);
1613 void (*complete)(struct rpc_task *, struct nfs_renamedata *);
1660 void (*unlink_rpc_prepare) (struct rpc_task *, struct nfs_unlinkdata *);
1661 int (*unlink_done) (struct rpc_task *, struct inode *);
1665 void (*rename_rpc_prepare)(struct rpc_task *task, struct nfs_renamedata *);
1666 int (*rename_done) (struct rpc_task *task, struct inode *old_dir, struct inode *new_dir);
[all …]
/Linux-v5.4/fs/nfs/filelayout/
Dfilelayout.c90 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 …]

123