Home
last modified time | relevance | path

Searched refs:rpc_rqst (Results 1 – 25 of 36) sorted by relevance

12

/linux/net/sunrpc/
H A Dbackchannel_rqst.c34 struct rpc_rqst *req; in xprt_svc_destroy_nullify_bc()
37 while ((req = lwq_dequeue(&bc_serv->sv_cb_list, struct rpc_rqst, in xprt_svc_destroy_nullify_bc()
75 static void xprt_free_allocation(struct rpc_rqst *req) in xprt_free_allocation()
110 static struct rpc_rqst *xprt_alloc_bc_req(struct rpc_xprt *xprt) in xprt_alloc_bc_req()
113 struct rpc_rqst *req; in xprt_alloc_bc_req()
168 struct rpc_rqst *req; in xprt_setup_bc()
217 struct rpc_rqst, in xprt_setup_bc()
245 struct rpc_rqst *req = NULL, *tmp = NULL; in xprt_destroy_bc()
270 static struct rpc_rqst *xprt_get_bc_request(struct rpc_xprt *xprt, __be32 xid, in xprt_get_bc_request()
271 struct rpc_rqst *new) in xprt_get_bc_request()
[all …]
H A Dxprt.c76 static int xprt_request_prepare(struct rpc_rqst *req, struct xdr_buf *buf);
81 static unsigned long xprt_request_timeout(const struct rpc_rqst *req) in xprt_request_timeout()
267 struct rpc_rqst *req = task->tk_rqstp; in xprt_reserve_xprt()
306 if (list_first_entry(&xprt->xmit_queue, struct rpc_rqst, in xprt_set_congestion_window_wait()
331 struct rpc_rqst *req = task->tk_rqstp; in xprt_reserve_xprt_cong()
461 __xprt_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) in __xprt_get_cong()
480 __xprt_put_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) in __xprt_put_cong()
499 xprt_request_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_request_get_cong()
520 struct rpc_rqst *req = task->tk_rqstp; in xprt_release_rqst_cong()
564 struct rpc_rqst *req = task->tk_rqstp; in xprt_adjust_cwnd()
[all …]
H A Dauth_tls.c19 static void tls_encode_probe(struct rpc_rqst *rqstp, struct xdr_stream *xdr, in tls_encode_probe()
24 static int tls_decode_probe(struct rpc_rqst *rqstp, struct xdr_stream *xdr, in tls_decode_probe()
H A Drpcb_clnt.c837 static void rpcb_enc_mapping(struct rpc_rqst *req, struct xdr_stream *xdr, in rpcb_enc_mapping()
850 static int rpcb_dec_getport(struct rpc_rqst *req, struct xdr_stream *xdr, in rpcb_dec_getport()
871 static int rpcb_dec_set(struct rpc_rqst *req, struct xdr_stream *xdr, in rpcb_dec_set()
902 static void rpcb_enc_getaddr(struct rpc_rqst *req, struct xdr_stream *xdr, in rpcb_enc_getaddr()
917 static int rpcb_dec_getaddr(struct rpc_rqst *req, struct xdr_stream *xdr, in rpcb_dec_getaddr()
H A Dxprtsock.c575 int flags, struct rpc_rqst *req) in xs_read_stream_request()
636 struct rpc_rqst *req; in xs_read_stream_call()
672 struct rpc_rqst *req; in xs_read_stream_reply()
846 static int xs_nospace(struct rpc_rqst *req, struct sock_xprt *transport) in xs_nospace()
871 static int xs_sock_nospace(struct rpc_rqst *req) in xs_sock_nospace()
885 static int xs_stream_nospace(struct rpc_rqst *req, bool vm_wait) in xs_stream_nospace()
901 static int xs_stream_prepare_request(struct rpc_rqst *req, struct xdr_buf *buf) in xs_stream_prepare_request()
906 static void xs_stream_abort_send_request(struct rpc_rqst *req) in xs_stream_abort_send_request()
922 xs_send_request_was_aborted(struct sock_xprt *transport, struct rpc_rqst *req) in xs_send_request_was_aborted()
949 static int xs_local_send_request(struct rpc_rqst *req) in xs_local_send_request()
[all …]
H A Dclnt.c1345 struct rpc_task *rpc_run_bc_task(struct rpc_rqst *req, in rpc_run_bc_task()
1386 void rpc_prepare_reply_pages(struct rpc_rqst *req, struct page **pages, in rpc_prepare_reply_pages()
1909 struct rpc_rqst *req = task->tk_rqstp; in call_allocate()
1966 struct rpc_rqst *req = task->tk_rqstp; in rpc_xdr_encode()
2411 struct rpc_rqst *req = task->tk_rqstp; in call_bc_transmit_status()
2537 rpc_check_connected(const struct rpc_rqst *req) in rpc_check_connected()
2611 struct rpc_rqst *req = task->tk_rqstp; in call_decode()
2680 struct rpc_rqst *req = task->tk_rqstp; in rpc_encode_header()
2854 static void rpcproc_encode_null(struct rpc_rqst *rqstp, struct xdr_stream *xdr, in rpcproc_encode_null()
2859 static int rpcproc_decode_null(struct rpc_rqst *rqstp, struct xdr_stream *xdr, in rpcproc_decode_null()
H A Dstats.c157 struct rpc_rqst *req = task->tk_rqstp; in rpc_count_iostats_metrics()
/linux/include/linux/sunrpc/
H A Dbc_xprt.h21 struct rpc_rqst *xprt_lookup_bc_request(struct rpc_xprt *xprt, __be32 xid);
22 void xprt_complete_bc_request(struct rpc_rqst *req, uint32_t copied);
23 void xprt_init_bc_request(struct rpc_rqst *req, struct rpc_task *task,
25 void xprt_free_bc_request(struct rpc_rqst *req);
28 void xprt_enqueue_bc_request(struct rpc_rqst *req);
33 void xprt_free_bc_rqst(struct rpc_rqst *req);
71 static inline void xprt_free_bc_request(struct rpc_rqst *req) in xprt_free_bc_request()
H A Dxprt.h56 struct rpc_rqst { struct
76 void (*rq_release_snd_buf)(struct rpc_rqst *); /* release rq_enc_pages */ argument
125 static inline int xprt_rqst_add_seqno(struct rpc_rqst *req, u32 seqno) in xprt_rqst_add_seqno() argument
158 struct rpc_rqst *req);
167 int (*prepare_request)(struct rpc_rqst *req,
169 int (*send_request)(struct rpc_rqst *req);
170 void (*abort_send_request)(struct rpc_rqst *req);
187 void (*bc_free_rqst)(struct rpc_rqst *rqst);
335 static inline int bc_prealloc(struct rpc_rqst *req) in bc_prealloc()
340 static inline int bc_prealloc(struct rpc_rqst *req) in bc_prealloc()
[all …]
H A Dclnt.h209 void rpc_prepare_reply_pages(struct rpc_rqst *req, struct page **pages,
/linux/net/sunrpc/xprtrdma/
H A Dbackchannel.c57 static int rpcrdma_bc_marshal_reply(struct rpc_rqst *rqst) in rpcrdma_bc_marshal_reply()
98 int xprt_rdma_bc_send_reply(struct rpc_rqst *rqst) in xprt_rdma_bc_send_reply()
134 struct rpc_rqst *rqst, *tmp; in xprt_rdma_bc_destroy()
152 void xprt_rdma_bc_free_rqst(struct rpc_rqst *rqst) in xprt_rdma_bc_free_rqst()
166 static struct rpc_rqst *rpcrdma_bc_rqst_get(struct rpcrdma_xprt *r_xprt) in xprt_rdma_bc_free_rqst()
170 struct rpc_rqst *rqst; in rpcrdma_bc_rqst_get()
174 rqst = list_first_entry_or_null(&xprt->bc_pa_list, struct rpc_rqst, in rpcrdma_bc_rqst_get()
224 struct rpc_rqst *rqst; in rpcrdma_bc_receive_call()
H A Dsvc_rdma_backchannel.c28 struct rpc_rqst *req; in svc_rdma_handle_bc_reply()
76 struct rpc_rqst *rqst, in svc_rdma_bc_sendto()
103 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_bc_allocate()
129 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_bc_free()
136 rpcrdma_bc_send_request(struct svcxprt_rdma *rdma, struct rpc_rqst *rqst) in rpcrdma_bc_send_request()
180 static int xprt_rdma_bc_send_request(struct rpc_rqst *rqst) in xprt_rdma_bc_send_request()
H A Dxprt_rdma.h206 struct rpc_rqst *rr_rqst;
336 struct rpc_rqst rl_slot;
354 rpcr_to_rdmar(const struct rpc_rqst *rqst) in rpcr_to_rdmar()
586 int rpcrdma_marshal_req(struct rpcrdma_xprt *r_xprt, struct rpc_rqst *rqst);
617 int xprt_rdma_bc_send_reply(struct rpc_rqst *rqst);
618 void xprt_rdma_bc_free_rqst(struct rpc_rqst *);
H A Drpc_rdma.c127 struct rpc_rqst *rqst) in rpcrdma_args_inline()
159 struct rpc_rqst *rqst) in rpcrdma_results_inline()
170 const struct rpc_rqst *rqst) in rpcrdma_nonpayload_inline()
297 struct rpc_rqst *rqst, in rpcrdma_encode_read_list()
350 struct rpc_rqst *rqst, in rpcrdma_encode_write_list()
424 struct rpc_rqst *rqst, in rpcrdma_encode_reply_chunk()
821 rpcrdma_marshal_req(struct rpcrdma_xprt *r_xprt, struct rpc_rqst *rqst) in rpcrdma_marshal_req()
1001 rpcrdma_inline_fixup(struct rpc_rqst *rqst, char *srcp, int copy_len, int pad) in rpcrdma_inline_fixup()
1226 struct rpc_rqst *rqst) in rpcrdma_decode_msg()
1281 struct rpc_rqst *rqs in rpcrdma_decode_error()
[all...]
H A Dtransport.c498 /* rl_kref has two owners while a Send is outstanding: the rpc_rqst
509 struct rpc_rqst *rqst = &req->rl_slot; in xprt_rdma_alloc_slot()
543 * xprt_rdma_alloc_slot - allocate an rpc_rqst in xprt_rdma_free_slot()
545 * @task: RPC task requesting a fresh rpc_rqst in xprt_rdma_free_slot()
548 * %0 if task->tk_rqstp points to a fresh rpc_rqst
549 * %-EAGAIN if no rpc_rqst is available; queued on backlog in rpcrdma_check_regbuf()
574 struct rpc_rqst *rqst = &req->rl_slot; in xprt_rdma_allocate()
585 * xprt_rdma_free_slot - release an rpc_rqst in xprt_rdma_allocate()
587 * @rqst: rpc_rqst to release in xprt_rdma_allocate()
591 xprt_rdma_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *rqs in xprt_rdma_allocate()
[all...]
/linux/fs/nfs/
H A Dnfs2xdr.c83 static struct user_namespace *rpc_rqst_userns(const struct rpc_rqst *rqstp) in rpc_rqst_userns()
549 static void nfs2_xdr_enc_fhandle(struct rpc_rqst *req, in nfs2_xdr_enc_fhandle()
566 static void nfs2_xdr_enc_sattrargs(struct rpc_rqst *req, in nfs2_xdr_enc_sattrargs()
576 static void nfs2_xdr_enc_diropargs(struct rpc_rqst *req, in nfs2_xdr_enc_diropargs()
585 static void nfs2_xdr_enc_readlinkargs(struct rpc_rqst *req, in nfs2_xdr_enc_readlinkargs()
621 static void nfs2_xdr_enc_readargs(struct rpc_rqst *req, in nfs2_xdr_enc_readargs()
663 static void nfs2_xdr_enc_writeargs(struct rpc_rqst *req, in nfs2_xdr_enc_writeargs()
681 static void nfs2_xdr_enc_createargs(struct rpc_rqst *req, in nfs2_xdr_enc_createargs()
691 static void nfs2_xdr_enc_removeargs(struct rpc_rqst *req, in nfs2_xdr_enc_removeargs()
708 static void nfs2_xdr_enc_renameargs(struct rpc_rqst *req, in nfs2_xdr_enc_renameargs()
[all …]
H A Dnfs42xdr.c548 static void nfs4_xdr_enc_allocate(struct rpc_rqst *req, in nfs4_xdr_enc_allocate()
568 static void nfs4_xdr_enc_copy(struct rpc_rqst *req, in nfs4_xdr_enc_copy()
591 static void nfs4_xdr_enc_offload_cancel(struct rpc_rqst *req, in nfs4_xdr_enc_offload_cancel()
610 static void nfs4_xdr_enc_offload_status(struct rpc_rqst *req, in nfs4_xdr_enc_offload_status()
629 static void nfs4_xdr_enc_copy_notify(struct rpc_rqst *req, in nfs4_xdr_enc_copy_notify()
648 static void nfs4_xdr_enc_deallocate(struct rpc_rqst *req, in nfs4_xdr_enc_deallocate()
668 static void nfs4_xdr_enc_zero_range(struct rpc_rqst *req, in nfs4_xdr_enc_zero_range()
689 static void nfs4_xdr_enc_read_plus(struct rpc_rqst *req, in nfs4_xdr_enc_read_plus()
711 static void nfs4_xdr_enc_seek(struct rpc_rqst *req, in nfs4_xdr_enc_seek()
730 static void nfs4_xdr_enc_layoutstats(struct rpc_rqst *req, in nfs4_xdr_enc_layoutstats()
[all …]
H A Dnfs4xdr.c71 static int decode_layoutget(struct xdr_stream *xdr, struct rpc_rqst *req,
1033 struct rpc_rqst *req, in encode_compound_hdr()
1606 …(struct xdr_stream *xdr, const struct nfs4_readdir_arg *readdir, struct rpc_rqst *req, struct comp… in encode_readdir()
1666 …nk(struct xdr_stream *xdr, const struct nfs4_readlink *readlink, struct rpc_rqst *req, struct comp… in encode_readlink()
2188 static void nfs4_xdr_enc_access(struct rpc_rqst *req, struct xdr_stream *xdr, in nfs4_xdr_enc_access()
2208 static void nfs4_xdr_enc_lookup(struct rpc_rqst *req, struct xdr_stream *xdr, in nfs4_xdr_enc_lookup()
2228 static void nfs4_xdr_enc_lookupp(struct rpc_rqst *req, struct xdr_stream *xdr, in nfs4_xdr_enc_lookupp()
2248 static void nfs4_xdr_enc_lookup_root(struct rpc_rqst *req, in nfs4_xdr_enc_lookup_root()
2268 static void nfs4_xdr_enc_remove(struct rpc_rqst *req, struct xdr_stream *xdr, in nfs4_xdr_enc_remove()
2286 static void nfs4_xdr_enc_rename(struct rpc_rqst *req, struct xdr_stream *xdr, in nfs4_xdr_enc_rename()
[all …]
H A Dmount_clnt.c239 static void mnt_xdr_enc_dirpath(struct rpc_rqst *req, struct xdr_stream *xdr, in mnt_xdr_enc_dirpath()
291 static int mnt_xdr_dec_mountres(struct rpc_rqst *req, in mnt_xdr_dec_mountres()
384 static int mnt_xdr_dec_mountres3(struct rpc_rqst *req, in mnt_xdr_dec_mountres3()
/linux/fs/nfsd/
H A Dnfs4callback.c630 static void nfs4_xdr_enc_cb_null(struct rpc_rqst *req, struct xdr_stream *xdr, in nfs4_xdr_enc_cb_null()
639 static void nfs4_xdr_enc_cb_getattr(struct rpc_rqst *req, in nfs4_xdr_enc_cb_getattr()
659 static void nfs4_xdr_enc_cb_recall(struct rpc_rqst *req, struct xdr_stream *xdr, in nfs4_xdr_enc_cb_recall()
679 nfs4_xdr_enc_cb_recall_any(struct rpc_rqst *req, in nfs4_xdr_enc_cb_recall_any()
705 static int nfs4_xdr_dec_cb_null(struct rpc_rqst *req, struct xdr_stream *xdr, in nfs4_xdr_dec_cb_null()
714 static int nfs4_xdr_dec_cb_getattr(struct rpc_rqst *rqstp, in nfs4_xdr_dec_cb_getattr()
754 static int nfs4_xdr_dec_cb_recall(struct rpc_rqst *rqstp, in nfs4_xdr_dec_cb_recall()
777 nfs4_xdr_dec_cb_recall_any(struct rpc_rqst *rqstp, in nfs4_xdr_dec_cb_recall_any()
848 static void nfs4_xdr_enc_cb_layout(struct rpc_rqst *req, in nfs4_xdr_enc_cb_layout()
866 static int nfs4_xdr_dec_cb_layout(struct rpc_rqst *rqstp, in nfs4_xdr_dec_cb_layout()
[all …]
/linux/net/sunrpc/auth_gss/
H A Dgss_rpc_xdr.h167 void gssx_enc_accept_sec_context(struct rpc_rqst *req,
170 int gssx_dec_accept_sec_context(struct rpc_rqst *rqstp,
H A Dauth_gss.c1531 struct rpc_rqst *req = task->tk_rqstp; in gss_marshal()
1750 struct rpc_rqst *rqstp = task->tk_rqstp; in gss_wrap_req_integ()
1792 priv_release_snd_buf(struct rpc_rqst *rqstp) in priv_release_snd_buf()
1803 alloc_enc_pages(struct rpc_rqst *rqstp) in alloc_enc_pages()
1841 struct rpc_rqst *rqstp = task->tk_rqstp; in gss_wrap_req_priv()
1990 struct gss_cl_ctx *ctx, struct rpc_rqst *rqstp, in gss_unwrap_resp_integ()
2062 struct gss_cl_ctx *ctx, struct rpc_rqst *rqstp, in gss_unwrap_resp_priv()
2121 struct rpc_rqst *req = task->tk_rqstp; in gss_xmit_need_reencode()
2158 struct rpc_rqst *rqstp = task->tk_rqstp; in gss_unwrap_resp()
H A Dgss_rpc_xdr.c788 void gssx_enc_accept_sec_context(struct rpc_rqst *req, in gssx_enc_accept_sec_context()
845 int gssx_dec_accept_sec_context(struct rpc_rqst *rqstp, in gssx_dec_accept_sec_context()
/linux/tools/net/sunrpc/xdrgen/templates/C/program/encoder/
H A Dargument.j26 static void {{ program }}_xdr_enc_{{ argument }}(struct rpc_rqst *req,
/linux/include/trace/events/
H A Drpcrdma.h598 const struct rpc_rqst *rqst
625 const struct rpc_rqst *rqst \
797 const struct rpc_rqst *rqst = &req->rl_slot;
856 const struct rpc_rqst *rqst = &req->rl_slot;
880 TP_PROTO(const struct rpc_rqst *rqst,
907 TP_PROTO(const struct rpc_rqst *rqst,
950 const struct rpc_rqst *rqst = &req->rl_slot;
987 const struct rpc_rqst *rqst = &req->rl_slot;
1290 const struct rpc_rqst *rqst,
1321 const struct rpc_rqst *rqst
[all …]

12