Home
last modified time | relevance | path

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

/net/sunrpc/
Dsched.c46 static void rpc_release_task(struct rpc_task *task);
65 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer()
87 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_add_timer()
104 struct rpc_task *task; in rpc_rotate_queue_owner()
107 task = list_first_entry(q, struct rpc_task, u.tk_wait.list); in rpc_rotate_queue_owner()
138 struct rpc_task *task, in __rpc_add_wait_queue_priority()
142 struct rpc_task *t; in __rpc_add_wait_queue_priority()
168 struct rpc_task *task, in __rpc_add_wait_queue()
194 static void __rpc_remove_wait_queue_priority(struct rpc_task *task) in __rpc_remove_wait_queue_priority()
196 struct rpc_task *t; in __rpc_remove_wait_queue_priority()
[all …]
Dclnt.c60 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 …]
Dxprt.c66 static void xprt_request_init(struct rpc_task *, struct rpc_xprt *);
67 static void xprt_connect_status(struct rpc_task *task);
68 static int __xprt_get_cong(struct rpc_xprt *, struct rpc_task *);
197 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt()
250 int xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt_cong()
286 static inline int xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_lock_write()
296 static bool __xprt_lock_write_func(struct rpc_task *task, void *data) in __xprt_lock_write_func()
320 static bool __xprt_lock_write_cong_func(struct rpc_task *task, void *data) in __xprt_lock_write_cong_func()
358 void xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt()
375 void xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt_cong()
[all …]
Dauth_null.c62 nul_marshal(struct rpc_task *task, __be32 *p) in nul_marshal()
76 nul_refresh(struct rpc_task *task) in nul_refresh()
83 nul_validate(struct rpc_task *task, __be32 *p) in nul_validate()
Dauth.c581 rpcauth_generic_bind_cred(struct rpc_task *task, struct rpc_cred *cred, int lookupflags) in rpcauth_generic_bind_cred()
590 rpcauth_bind_root_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_root_cred()
604 rpcauth_bind_new_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_new_cred()
614 rpcauth_bindcred(struct rpc_task *task, struct rpc_cred *cred, int flags) in rpcauth_bindcred()
673 rpcauth_marshcred(struct rpc_task *task, __be32 *p) in rpcauth_marshcred()
684 rpcauth_checkverf(struct rpc_task *task, __be32 *p) in rpcauth_checkverf()
704 rpcauth_wrap_req(struct rpc_task *task, kxdreproc_t encode, void *rqstp, in rpcauth_wrap_req()
729 rpcauth_unwrap_resp(struct rpc_task *task, kxdrdproc_t decode, void *rqstp, in rpcauth_unwrap_resp()
744 rpcauth_refreshcred(struct rpc_task *task) in rpcauth_refreshcred()
767 rpcauth_invalcred(struct rpc_task *task) in rpcauth_invalcred()
[all …]
Dauth_unix.c144 unx_marshal(struct rpc_task *task, __be32 *p) in unx_marshal()
178 unx_refresh(struct rpc_task *task) in unx_refresh()
185 unx_validate(struct rpc_task *task, __be32 *p) in unx_validate()
Dxprtsock.c481 static void xs_nospace_callback(struct rpc_task *task) in xs_nospace_callback()
494 static int xs_nospace(struct rpc_task *task) in xs_nospace()
550 static int xs_local_send_request(struct rpc_task *task) in xs_local_send_request()
604 static int xs_udp_send_request(struct rpc_task *task) in xs_udp_send_request()
686 static int xs_tcp_send_request(struct rpc_task *task) in xs_tcp_send_request()
759 static void xs_tcp_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xs_tcp_release_xprt()
905 struct rpc_task *task; in xs_local_data_ready()
968 struct rpc_task *task; in xs_udp_data_ready()
1655 static void xs_udp_timer(struct rpc_xprt *xprt, struct rpc_task *task) in xs_udp_timer()
1738 static void xs_local_rpcbind(struct rpc_task *task) in xs_local_rpcbind()
[all …]
Dsunrpc.h40 static inline int rpc_reply_expected(struct rpc_task *task) in rpc_reply_expected()
Dbc_svc.c48 struct rpc_task *task; in bc_send()
Drpcb_clnt.c113 static void rpcb_getport_done(struct rpc_task *, void *);
599 static struct rpc_task *rpcb_call_async(struct rpc_clnt *rpcb_clnt, struct rpcbind_args *map, struc… in rpcb_call_async()
647 void rpcb_getport_async(struct rpc_task *task) in rpcb_getport_async()
655 struct rpc_task *child; in rpcb_getport_async()
783 static void rpcb_getport_done(struct rpc_task *child, void *data) in rpcb_getport_done()
Dauth_generic.c59 static struct rpc_cred *generic_bind_cred(struct rpc_task *task, in generic_bind_cred()
Dstats.c141 void rpc_count_iostats(const struct rpc_task *task, struct rpc_iostats *stats) in rpc_count_iostats()
/net/sunrpc/xprtrdma/
Dtransport.c430 xprt_rdma_connect(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_rdma_connect()
451 xprt_rdma_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_rdma_reserve_xprt()
476 xprt_rdma_allocate(struct rpc_task *task, size_t size) in xprt_rdma_allocate()
627 xprt_rdma_send_request(struct rpc_task *task) in xprt_rdma_send_request()
/net/sunrpc/auth_gss/
Dauth_gss.c385 gss_upcall_callback(struct rpc_task *task) in gss_upcall_callback()
517 gss_refresh_upcall(struct rpc_task *task) in gss_refresh_upcall()
991 struct rpc_task *task; in gss_destroying_context()
1157 gss_marshal(struct rpc_task *task, __be32 *p) in gss_marshal()
1212 static int gss_renew_cred(struct rpc_task *task) in gss_renew_cred()
1255 gss_refresh(struct rpc_task *task) in gss_refresh()
1279 gss_refresh_null(struct rpc_task *task) in gss_refresh_null()
1285 gss_validate(struct rpc_task *task, __be32 *p) in gss_validate()
1500 gss_wrap_req(struct rpc_task *task, in gss_wrap_req()
1612 gss_unwrap_resp(struct rpc_task *task, in gss_unwrap_resp()