| /linux/include/linux/sunrpc/ |
| 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 *task);
[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 *task,
[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 | 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()
[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 *task);
[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 | 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 *task, int result) in xprt_adjust_cwnd()
[all …]
|
| H A D | auth.c | 607 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()
647 rpcauth_bindcred(struct rpc_task *task, const struct cred *cred, int flags) in rpcauth_bindcred()
724 int rpcauth_marshcred(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_marshcred()
739 int rpcauth_wrap_req_encode(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_wrap_req_encode()
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()
794 rpcauth_unwrap_resp_decode(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_unwrap_resp_decode()
810 rpcauth_unwrap_resp(struct rpc_task *task, struct xdr_stream *xdr) in rpcauth_unwrap_resp()
[all …]
|
| 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 | 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()
|
| H A D | rpcb_clnt.c | 113 static void rpcb_getport_done(struct rpc_task *, void *);
620 static struct rpc_task *rpcb_call_async(struct rpc_clnt *rpcb_clnt, in rpcb_call_async()
669 void rpcb_getport_async(struct rpc_task *task) in rpcb_getport_async()
677 struct rpc_task *child; in rpcb_getport_async()
795 static void rpcb_getport_done(struct rpc_task *child, void *data) in rpcb_getport_done()
|
| H A D | stats.c | 154 void rpc_count_iostats_metrics(const struct rpc_task *task, in rpc_count_iostats_metrics()
200 void rpc_count_iostats(const struct rpc_task *task, struct rpc_iostats *stats) in rpc_count_iostats()
|
| H A D | xprtsock.c | 1244 * Note: we don't call sock_error() since there may be a rpc_task
1383 struct rpc_task *task; in xs_udp_data_read_skb()
1708 static void xs_udp_timer(struct rpc_xprt *xprt, struct rpc_task *task) in xs_udp_timer()
1875 static void xs_local_rpcbind(struct rpc_task *task) in xs_local_rpcbind()
2074 static void xs_local_connect(struct rpc_xprt *xprt, struct rpc_task *task) in xs_local_connect()
2791 static void xs_connect(struct rpc_xprt *xprt, struct rpc_task *task) in xs_connect()
2945 static int bc_malloc(struct rpc_task *task) in bc_malloc()
2973 static void bc_free(struct rpc_task *task) in bc_free()
|
| H A D | svc.c | 1680 struct rpc_task *task; in svc_process_bc()
|
| /linux/fs/nfs/ |
| H A D | nfs40proc.c | 12 static void nfs40_call_sync_prepare(struct rpc_task *task, void *calldata) in nfs40_call_sync_prepare()
19 static void nfs40_call_sync_done(struct rpc_task *task, void *calldata) in nfs40_call_sync_done()
39 static int nfs40_sequence_done(struct rpc_task *task, in nfs40_sequence_done()
81 static void nfs4_renew_done(struct rpc_task *task, void *calldata) in nfs4_renew_done()
265 static void nfs4_release_lockowner_prepare(struct rpc_task *task, void *calldata) in nfs4_release_lockowner_prepare()
275 static void nfs4_release_lockowner_done(struct rpc_task *task, void *calldata) in nfs4_release_lockowner_done()
|
| H A D | pnfs.h | 309 int pnfs_roc_done(struct rpc_task *task, struct nfs4_layoutreturn_args **argpp,
314 bool pnfs_wait_on_layoutreturn(struct inode *ino, struct rpc_task *task);
416 void pnfs_generic_write_commit_done(struct rpc_task *task, void *data);
784 pnfs_roc_done(struct rpc_task *task, in pnfs_roc_done()
800 pnfs_wait_on_layoutreturn(struct inode *ino, struct rpc_task *task) in pnfs_wait_on_layoutreturn()
|
| H A D | sysfs.c | 225 static bool shutdown_match_client(const struct rpc_task *task, const void *data) in shutdown_match_client()
|
| H A D | nfs4session.c | 357 static bool nfs41_assign_slot(struct rpc_task *task, void *pslot) in nfs41_assign_slot()
|
| H A D | localio.c | 592 struct rpc_task *task = &hdr->task; in nfs_local_pgio_release()
|
| /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,
|
| H A D | rpcrdma.h | 392 const struct rpc_task *task,
434 const struct rpc_task *task, \
443 const struct rpc_task *task,
482 const struct rpc_task *task, \
522 const struct rpc_task *task = req->rl_slot.rq_task;
1082 const struct rpc_task *task = req->rl_slot.rq_task;
1256 const struct rpc_task *task,
1431 const struct rpc_task *task
|
| /linux/net/sunrpc/xprtrdma/ |
| H A D | transport.c | 430 xprt_rdma_timer(struct rpc_xprt *xprt, struct rpc_task *task)
480 xprt_rdma_connect(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_rdma_connect()
552 xprt_rdma_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) in rpcrdma_check_regbuf()
622 xprt_rdma_allocate(struct rpc_task *task)
651 xprt_rdma_free(struct rpc_task *task) in xprt_rdma_send_request()
|
| 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()
|
| /linux/net/sunrpc/auth_gss/ |
| H A D | auth_gss.c | 393 gss_upcall_callback(struct rpc_task *task) in gss_upcall_callback()
597 gss_refresh_upcall(struct rpc_task *task) in gss_refresh_upcall()
1283 struct rpc_task *task; in gss_send_destroy_context()
1529 static int gss_marshal(struct rpc_task *task, struct xdr_stream *xdr) in gss_marshal()
1605 static int gss_renew_cred(struct rpc_task *task) in gss_renew_cred()
1648 gss_refresh(struct rpc_task *task) in gss_refresh()
1672 gss_refresh_null(struct rpc_task *task) in gss_refresh_null()
1694 gss_validate(struct rpc_task *task, struct xdr_stream *xdr) in gss_validate()
1748 struct rpc_task *task, struct xdr_stream *xdr) in gss_wrap_req_integ()
1839 struct rpc_task *task, struct xdr_stream *xdr) in gss_wrap_req_priv()
[all …]
|