Home
last modified time | relevance | path

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

123

/linux/include/linux/sunrpc/
A Dsched.h43 struct rpc_task { struct
53 void (*tk_action)(struct rpc_task *); argument
107 struct rpc_task *task;
218 void rpc_execute(struct rpc_task *);
224 struct rpc_task *task,
230 struct rpc_task *task,
234 struct rpc_task *,
237 struct rpc_task *);
239 struct rpc_task *,
252 int rpc_malloc(struct rpc_task *);
[all …]
A Dxprt.h54 struct rpc_task;
75 struct rpc_task * rq_task; /* RPC task data */
139 void (*rpcbind)(struct rpc_task *task);
142 int (*buf_alloc)(struct rpc_task *task);
143 void (*buf_free)(struct rpc_task *task);
148 void (*release_request)(struct rpc_task *task);
346 void xprt_connect(struct rpc_task *task);
350 void xprt_reserve(struct rpc_task *task);
364 void xprt_transmit(struct rpc_task *task);
369 void xprt_release(struct rpc_task *task);
[all …]
A Dauth.h130 int (*crmarshal)(struct rpc_task *task,
132 int (*crrefresh)(struct rpc_task *);
133 int (*crvalidate)(struct rpc_task *task,
135 int (*crwrap_req)(struct rpc_task *task,
137 int (*crunwrap_resp)(struct rpc_task *task,
141 bool (*crneed_reencode)(struct rpc_task *);
165 int rpcauth_marshcred(struct rpc_task *task,
167 int rpcauth_checkverf(struct rpc_task *task,
171 int rpcauth_wrap_req(struct rpc_task *task,
178 int rpcauth_refreshcred(struct rpc_task *);
[all …]
A Dclnt.h176 void rpc_task_release_transport(struct rpc_task *);
177 void rpc_task_release_client(struct rpc_task *);
188 void rpcb_getport_async(struct rpc_task *);
193 void rpc_call_start(struct rpc_task *);
200 struct rpc_task *rpc_call_null(struct rpc_clnt *clnt, struct rpc_cred *cred,
202 int rpc_restart_call_prepare(struct rpc_task *);
203 int rpc_restart_call(struct rpc_task *);
237 const char *rpc_proc_name(const struct rpc_task *task);
245 static inline int rpc_reply_expected(struct rpc_task *task) in rpc_reply_expected()
251 static inline void rpc_task_close_connection(struct rpc_task *task) in rpc_task_close_connection()
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()
/linux/net/sunrpc/
A Dsched.c134 struct rpc_task *t; in __rpc_list_enqueue_task()
157 struct rpc_task *t; in __rpc_list_dequeue_task()
165 struct rpc_task, in __rpc_list_dequeue_task()
179 struct rpc_task *task, in __rpc_add_wait_queue_priority()
196 struct rpc_task *task, in __rpc_add_wait_queue()
356 struct rpc_task *task) in rpc_make_runnable()
377 struct rpc_task *task, in __rpc_do_sleep_on_priority()
386 struct rpc_task *task, in __rpc_sleep_on_priority()
600 struct rpc_task *task; in __rpc_find_next_queued_priority()
703 struct rpc_task *task; in rpc_wake_up_locked()
[all …]
A Dclnt.c837 struct rpc_task *rovr; in rpc_killall_tasks()
1127 struct rpc_task *task; in rpc_run_task()
1154 struct rpc_task *task; in rpc_call_sync()
1191 struct rpc_task *task; in rpc_call_async()
1218 struct rpc_task *task; in rpc_run_bc_task()
1563 __rpc_restart_call(struct rpc_task *task, void (*action)(struct rpc_task *)) in __rpc_restart_call() argument
1915 call_bind(struct rpc_task *task) in call_bind()
2734 struct rpc_task *task; in rpc_ping()
2785 struct rpc_task *task; in rpc_clnt_test_and_add_xprt()
2838 struct rpc_task *task; in rpc_clnt_setup_test_and_add_xprt()
[all …]
A Dxprt.c878 struct rpc_task *task, in xprt_lock_connect()
919 void xprt_connect(struct rpc_task *task) in xprt_connect()
1192 void xprt_update_rtt(struct rpc_task *task) in xprt_update_rtt()
1231 static void xprt_timer(struct rpc_task *task) in xprt_timer()
1509 void xprt_end_transmit(struct rpc_task *task) in xprt_end_transmit()
1531 struct rpc_task *task = req->rq_task; in xprt_request_transmit()
1603 xprt_transmit(struct rpc_task *task) in xprt_transmit()
1870 xprt_request_init(struct rpc_task *task) in xprt_request_init()
1908 void xprt_reserve(struct rpc_task *task) in xprt_reserve()
1930 void xprt_retry_reserve(struct rpc_task *task) in xprt_retry_reserve()
[all …]
A Dauth.c610 rpcauth_bind_root_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_root_cred()
624 rpcauth_bind_machine_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_machine_cred()
638 rpcauth_bind_new_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_new_cred()
723 int rpcauth_marshcred(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_marshcred()
756 int rpcauth_wrap_req(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_wrap_req()
773 rpcauth_checkverf(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_checkverf()
804 rpcauth_unwrap_resp(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_unwrap_resp()
812 rpcauth_xmit_need_reencode(struct rpc_task *task) in rpcauth_xmit_need_reencode()
822 rpcauth_refreshcred(struct rpc_task *task) in rpcauth_refreshcred()
843 rpcauth_invalcred(struct rpc_task *task) in rpcauth_invalcred()
[all …]
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()
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()
A 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/fs/nfs/
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()
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()
A Dnfs3proc.c48 nfs3_async_handle_jukebox(struct rpc_task *task, struct inode *inode) in nfs3_async_handle_jukebox()
466 static void nfs3_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs3_proc_unlink_rpc_prepare()
472 nfs3_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs3_proc_unlink_done()
490 static void nfs3_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs3_proc_rename_rpc_prepare()
496 nfs3_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs3_proc_rename_done()
844 static int nfs3_read_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs3_read_done()
870 static int nfs3_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs3_proc_pgio_rpc_prepare()
877 static int nfs3_write_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs3_write_done()
898 static void nfs3_proc_commit_rpc_prepare(struct rpc_task *task, struct nfs_commit_data *data) in nfs3_proc_commit_rpc_prepare()
903 static int nfs3_commit_done(struct rpc_task *task, struct nfs_commit_data *data) in nfs3_commit_done()
[all …]
A Dnfs4proc.c1043 struct rpc_task *task) in nfs4_setup_sequence()
1118 struct rpc_task *task; in nfs4_call_sync_custom()
2387 struct rpc_task *task; in _nfs4_proc_open_confirm()
2556 struct rpc_task *task; in nfs4_run_open_task()
3723 struct rpc_task *task; in nfs4_do_close()
6486 struct rpc_task *task; in _nfs4_proc_delegreturn()
6849 struct rpc_task *task; in nfs4_proc_unlck()
7074 struct rpc_task *task; in _nfs4_do_setlk()
8268 struct rpc_task *task; in nfs4_proc_bind_one_conn_to_session()
8586 struct rpc_task *task; in _nfs4_proc_exchange_id()
[all …]
A Dproc.c341 static void nfs_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs_proc_unlink_rpc_prepare()
346 static int nfs_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs_proc_unlink_done()
360 static void nfs_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs_proc_rename_rpc_prepare()
366 nfs_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs_proc_rename_done()
596 static int nfs_read_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs_read_done()
619 static int nfs_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs_proc_pgio_rpc_prepare()
626 static int nfs_write_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs_write_done()
644 static void nfs_proc_commit_rpc_prepare(struct rpc_task *task, struct nfs_commit_data *data) in nfs_proc_commit_rpc_prepare()
A Dnfs4_fs.h94 struct rpc_task *task;
286 extern int nfs4_async_handle_error(struct rpc_task *task,
336 extern int nfs41_sequence_done(struct rpc_task *, struct nfs4_sequence_res *);
518 extern int nfs_wait_on_sequence(struct nfs_seqid *seqid, struct rpc_task *task);
526 struct rpc_task *task);
527 extern int nfs4_sequence_done(struct rpc_task *task,
/linux/fs/nfs/flexfilelayout/
A Dflexfilelayout.c36 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task,
670 nfs4_ff_layout_stat_io_end_read(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_read()
701 nfs4_ff_layout_stat_io_end_write(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_write()
1016 struct rpc_task *task = &hdr->task; in ff_layout_reset_write()
1064 struct rpc_task *task = &hdr->task; in ff_layout_reset_read()
1195 static int ff_layout_async_handle_error(struct rpc_task *task, in ff_layout_async_handle_error()
1285 static int ff_layout_read_done_cb(struct rpc_task *task, in ff_layout_read_done_cb()
1373 static int ff_layout_read_prepare_common(struct rpc_task *task, in ff_layout_read_prepare_common()
1449 static int ff_layout_write_done_cb(struct rpc_task *task, in ff_layout_write_done_cb()
1496 static int ff_layout_commit_done_cb(struct rpc_task *task, in ff_layout_commit_done_cb()
[all …]
/linux/fs/nfs/filelayout/
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()
203 static int filelayout_read_done_cb(struct rpc_task *task, in filelayout_read_done_cb()
266 static void filelayout_read_prepare(struct rpc_task *task, void *data) in filelayout_read_prepare()
292 static void filelayout_read_call_done(struct rpc_task *task, void *data) in filelayout_read_call_done()
313 static int filelayout_write_done_cb(struct rpc_task *task, in filelayout_write_done_cb()
341 static int filelayout_commit_done_cb(struct rpc_task *task, in filelayout_commit_done_cb()
364 static void filelayout_write_prepare(struct rpc_task *task, void *data) in filelayout_write_prepare()
388 static void filelayout_write_call_done(struct rpc_task *task, void *data) in filelayout_write_call_done()
[all …]
/linux/include/linux/
A Dnfs_xdr.h316 struct rpc_task task;
1619 struct rpc_task task;
1624 int (*pgio_done_cb)(struct rpc_task *, struct nfs_pgio_header *);
1655 struct rpc_task task;
1703 void (*complete)(struct rpc_task *, struct nfs_renamedata *);
1747 void (*unlink_rpc_prepare) (struct rpc_task *, struct nfs_unlinkdata *);
1748 int (*unlink_done) (struct rpc_task *, struct inode *);
1770 int (*pgio_rpc_prepare)(struct rpc_task *,
1773 int (*read_done)(struct rpc_task *, struct nfs_pgio_header *);
1776 int (*write_done)(struct rpc_task *, struct nfs_pgio_header *);
[all …]
A Dnfs_page.h76 int (*rw_done)(struct rpc_task *, struct nfs_pgio_header *,
78 void (*rw_result)(struct rpc_task *, struct nfs_pgio_header *);
154 extern bool nfs_async_iocounter_wait(struct rpc_task *, struct nfs_lock_context *);
/linux/include/trace/events/
A Dsunrpc.h54 const struct rpc_task *task,
99 const struct rpc_task *task, \
267 const struct rpc_task *task \
372 const struct rpc_task *task, \
427 const struct rpc_task *task, \
468 const struct rpc_task *task
532 const struct rpc_task *task,
563 const struct rpc_task *task,
593 const struct rpc_task *task,
1309 const struct rpc_task *task,
[all …]
A Drpcgss.h85 const struct rpc_task *task,
113 const struct rpc_task *task, \
322 const struct rpc_task *task
343 const struct rpc_task *task,
372 const struct rpc_task *task
400 const struct rpc_task *task,
434 const struct rpc_task *task,
/linux/include/linux/lockd/
A Dbind.h22 struct rpc_task;
73 bool (*nlmclnt_unlock_prepare)(struct rpc_task*, void *);
/linux/net/sunrpc/auth_gss/
A Dauth_gss.c374 gss_upcall_callback(struct rpc_task *task) in gss_upcall_callback()
577 gss_refresh_upcall(struct rpc_task *task) in gss_refresh_upcall()
1255 struct rpc_task *task; in gss_send_destroy_context()
1574 static int gss_renew_cred(struct rpc_task *task) in gss_renew_cred()
1617 gss_refresh(struct rpc_task *task) in gss_refresh()
1641 gss_refresh_null(struct rpc_task *task) in gss_refresh_null()
1647 gss_validate(struct rpc_task *task, struct xdr_stream *xdr) in gss_validate()
1706 struct rpc_task *task, struct xdr_stream *xdr) in gss_wrap_req_integ()
1799 struct rpc_task *task, struct xdr_stream *xdr) in gss_wrap_req_priv()
2073 gss_xmit_need_reencode(struct rpc_task *task) in gss_xmit_need_reencode()
[all …]

Completed in 98 milliseconds

123