Home
last modified time | relevance | path

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

123

/linux-6.15/include/linux/sunrpc/
H A Dsched.h54 struct rpc_task { struct
64 void (*tk_action)(struct rpc_task *); argument
117 struct rpc_task *task;
236 void rpc_execute(struct rpc_task *);
242 struct rpc_task *task,
248 struct rpc_task *task,
252 struct rpc_task *,
255 struct rpc_task *);
257 struct rpc_task *,
270 int rpc_malloc(struct rpc_task *);
[all …]
H A Dxprt.h43 struct rpc_task;
65 struct rpc_task * rq_task; /* RPC task data */
144 void (*rpcbind)(struct rpc_task *task);
150 int (*buf_alloc)(struct rpc_task *task);
151 void (*buf_free)(struct rpc_task *task);
158 void (*release_request)(struct rpc_task *task);
362 void xprt_connect(struct rpc_task *task);
366 void xprt_reserve(struct rpc_task *task);
379 void xprt_transmit(struct rpc_task *task);
384 void xprt_release(struct rpc_task *task);
[all …]
H A 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,
174 int rpcauth_wrap_req(struct rpc_task *task,
181 int rpcauth_refreshcred(struct rpc_task *);
[all …]
H A 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()
H A Dclnt.h194 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 *task) in rpc_task_close_connection()
/linux-6.15/net/sunrpc/
H A Dsched.c149 struct rpc_task *t; in __rpc_list_enqueue_task()
172 struct rpc_task *t; in __rpc_list_dequeue_task()
180 struct rpc_task, in __rpc_list_dequeue_task()
194 struct rpc_task *task, in __rpc_add_wait_queue_priority()
206 struct rpc_task *task, in __rpc_add_wait_queue()
364 struct rpc_task *task) in rpc_make_runnable()
387 struct rpc_task *task, in __rpc_do_sleep_on_priority()
396 struct rpc_task *task, in __rpc_sleep_on_priority()
610 struct rpc_task *task; in __rpc_find_next_queued_priority()
713 struct rpc_task *task; in rpc_wake_up_locked()
[all …]
H A Dclnt.c883 struct rpc_task *rovr; in rpc_killall_tasks()
915 struct rpc_task *task; in rpc_cancel_tasks()
1234 struct rpc_task *task; in rpc_run_task()
1263 struct rpc_task *task; in rpc_call_sync()
1300 struct rpc_task *task; in rpc_call_async()
1329 struct rpc_task *task; in rpc_run_bc_task()
1679 __rpc_restart_call(struct rpc_task *task, void (*action)(struct rpc_task *)) in __rpc_restart_call() argument
2892 struct rpc_task *task; in rpc_ping()
2917 struct rpc_task *task; in rpc_ping_noreply()
2968 struct rpc_task *task; in rpc_clnt_test_and_add_xprt()
[all …]
H A Dxprt.c882 struct rpc_task *task, in xprt_lock_connect()
923 void xprt_connect(struct rpc_task *task) in xprt_connect()
1195 void xprt_update_rtt(struct rpc_task *task) in xprt_update_rtt()
1236 static void xprt_timer(struct rpc_task *task) in xprt_timer()
1523 void xprt_end_transmit(struct rpc_task *task) in xprt_end_transmit()
1545 struct rpc_task *task = req->rq_task; in xprt_request_transmit()
1620 xprt_transmit(struct rpc_task *task) in xprt_transmit()
1884 xprt_request_init(struct rpc_task *task) in xprt_request_init()
1922 void xprt_reserve(struct rpc_task *task) in xprt_reserve()
1944 void xprt_retry_reserve(struct rpc_task *task) in xprt_retry_reserve()
[all …]
H A Dauth_tls.c35 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 Dauth.c607 rpcauth_bind_root_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_root_cred()
623 rpcauth_bind_machine_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_machine_cred()
639 rpcauth_bind_new_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_new_cred()
724 int rpcauth_marshcred(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_marshcred()
757 int rpcauth_wrap_req(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_wrap_req()
779 rpcauth_checkverf(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_checkverf()
810 rpcauth_unwrap_resp(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_unwrap_resp()
818 rpcauth_xmit_need_reencode(struct rpc_task *task) in rpcauth_xmit_need_reencode()
828 rpcauth_refreshcred(struct rpc_task *task) in rpcauth_refreshcred()
849 rpcauth_invalcred(struct rpc_task *task) in rpcauth_invalcred()
[all …]
H A 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()
H A 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()
H A Dauth_unix.c111 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-6.15/fs/nfs/
H A 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()
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 *, struct nfs_renamedata *)) in nfs_async_rename() argument
403 nfs_complete_sillyrename(struct rpc_task *task, struct nfs_renamedata *data) in nfs_complete_sillyrename()
450 struct rpc_task *task; in nfs_sillyrename()
H A Dproc.c342 static void nfs_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs_proc_unlink_rpc_prepare()
347 static int nfs_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs_proc_unlink_done()
361 static void nfs_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs_proc_rename_rpc_prepare()
367 nfs_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs_proc_rename_done()
602 static int nfs_read_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs_read_done()
625 static int nfs_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs_proc_pgio_rpc_prepare()
632 static int nfs_write_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs_write_done()
650 static void nfs_proc_commit_rpc_prepare(struct rpc_task *task, struct nfs_commit_data *data) in nfs_proc_commit_rpc_prepare()
H A Dnfs3proc.c49 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 *task, struct nfs_commit_data *data) in nfs3_commit_done()
[all …]
H A Dnfs4_fs.h97 struct rpc_task *task;
291 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 Dnfs4proc.c1116 struct rpc_task *task) in nfs4_setup_sequence()
1191 struct rpc_task *task; in nfs4_call_sync_custom()
2492 struct rpc_task *task; in _nfs4_proc_open_confirm()
2663 struct rpc_task *task; in nfs4_run_open_task()
3836 struct rpc_task *task; in nfs4_do_close()
6865 struct rpc_task *task; in _nfs4_proc_delegreturn()
7253 struct rpc_task *task; in nfs4_proc_unlck()
7488 struct rpc_task *task; in _nfs4_do_setlk()
8743 struct rpc_task *task; in nfs4_proc_bind_one_conn_to_session()
9063 struct rpc_task *task; in _nfs4_proc_exchange_id()
[all …]
/linux-6.15/fs/nfs/flexfilelayout/
H A Dflexfilelayout.c693 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()
1228 static int ff_layout_async_handle_error(struct rpc_task *task, in ff_layout_async_handle_error()
1322 static int ff_layout_read_done_cb(struct rpc_task *task, in ff_layout_read_done_cb()
1413 static int ff_layout_read_prepare_common(struct rpc_task *task, in ff_layout_read_prepare_common()
1494 static int ff_layout_write_done_cb(struct rpc_task *task, in ff_layout_write_done_cb()
1544 static int ff_layout_commit_done_cb(struct rpc_task *task, in ff_layout_commit_done_cb()
2047 static bool ff_layout_match_rw(const struct rpc_task *task, in ff_layout_match_rw()
[all …]
/linux-6.15/include/linux/lockd/
H A Dbind.h22 struct rpc_task;
75 bool (*nlmclnt_unlock_prepare)(struct rpc_task*, void *);
/linux-6.15/fs/nfs/filelayout/
H A Dfilelayout.c91 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()
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 *task, void *data) in filelayout_write_prepare()
390 static void filelayout_write_call_done(struct rpc_task *task, void *data) in filelayout_write_call_done()
[all …]
/linux-6.15/include/linux/
H A Dnfs_xdr.h316 struct rpc_task task;
1667 struct rpc_task task;
1672 int (*pgio_done_cb)(struct rpc_task *, struct nfs_pgio_header *);
1703 struct rpc_task task;
1744 struct rpc_task task;
1752 void (*complete)(struct rpc_task *, struct nfs_renamedata *);
1797 int (*unlink_done) (struct rpc_task *, struct inode *);
1819 int (*pgio_rpc_prepare)(struct rpc_task *,
1822 int (*read_done)(struct rpc_task *, struct nfs_pgio_header *);
1825 int (*write_done)(struct rpc_task *, struct nfs_pgio_header *);
[all …]
H A Dnfs_page.h80 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-6.15/include/trace/events/
H A Dsunrpc.h54 const struct rpc_task *task,
99 const struct rpc_task *task, \
299 const struct rpc_task *task \
403 const struct rpc_task *task, \
458 const struct rpc_task *task, \
499 const struct rpc_task *task
563 const struct rpc_task *task,
594 const struct rpc_task *task,
624 const struct rpc_task *task,
1378 const struct rpc_task *task,
[all …]
H A Drpcgss.h85 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,

123