net/sunrpc/xprt.c

76 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)
267 	struct rpc_rqst *req = task->tk_rqstp;
306 		if (list_first_entry(&xprt->xmit_queue, struct rpc_rqst,
331 	struct rpc_rqst *req = task->tk_rqstp;
461 __xprt_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req)
480 __xprt_put_cong(struct rpc_xprt *xprt, struct rpc_rqst *req)
499 xprt_request_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req)
520 	struct rpc_rqst *req = task->tk_rqstp;
564 	struct rpc_rqst *req = task->tk_rqstp;
654 static unsigned long xprt_calc_majortimeo(struct rpc_rqst *req,
668 static void xprt_reset_majortimeo(struct rpc_rqst *req,
674 static void xprt_reset_minortimeo(struct rpc_rqst *req)
679 static void xprt_init_majortimeo(struct rpc_task *task, struct rpc_rqst *req,
700 int xprt_adjust_timeout(struct rpc_rqst *req)
808 	struct rpc_rqst *req = task->tk_rqstp;
1005 static struct rpc_rqst *
1009 	struct rpc_rqst *req;
1012 		req = rb_entry(n, struct rpc_rqst, rq_recv);
1028 xprt_request_rb_insert(struct rpc_xprt *xprt, struct rpc_rqst *new)
1032 	struct rpc_rqst *req;
1036 		req = rb_entry(n, struct rpc_rqst, rq_recv);
1054 xprt_request_rb_remove(struct rpc_xprt *xprt, struct rpc_rqst *req)
1066 struct rpc_rqst *xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid)
1068 	struct rpc_rqst *entry;
1086 xprt_is_pinned_rqst(struct rpc_rqst *req)
1098 void xprt_pin_rqst(struct rpc_rqst *req)
1110 void xprt_unpin_rqst(struct rpc_rqst *req)
1121 static void xprt_wait_on_pinned_rqst(struct rpc_rqst *req)
1134 xprt_request_need_enqueue_receive(struct rpc_task *task, struct rpc_rqst *req)
1148 	struct rpc_rqst *req = task->tk_rqstp;
1183 	struct rpc_rqst *req = task->tk_rqstp;
1197 	struct rpc_rqst *req = task->tk_rqstp;
1219 	struct rpc_rqst *req = task->tk_rqstp;
1238 	struct rpc_rqst *req = task->tk_rqstp;
1263 	struct rpc_rqst *req = task->tk_rqstp;
1282 	struct rpc_rqst *req = task->tk_rqstp;
1302 	struct rpc_rqst *req = task->tk_rqstp;
1328 xprt_request_need_enqueue_transmit(struct rpc_task *task, struct rpc_rqst *req)
1342 	struct rpc_rqst *pos, *req = task->tk_rqstp;
1396 	struct rpc_rqst *req = task->tk_rqstp;
1409 			struct rpc_rqst *next = list_first_entry(&req->rq_xmit2,
1410 					struct rpc_rqst, rq_xmit2);
1429 	struct rpc_rqst *req = task->tk_rqstp;
1447 	struct rpc_rqst	*req = task->tk_rqstp;
1470  * @req: pointer to rpc_rqst
1478 xprt_request_prepare(struct rpc_rqst *req, struct xdr_buf *buf)
1506 	struct rpc_rqst	*req = task->tk_rqstp;
1542 xprt_request_transmit(struct rpc_rqst *req, struct rpc_task *snd_task)
1622 	struct rpc_rqst *next, *req = task->tk_rqstp;
1629 						struct rpc_rqst, rq_xmit);
1668 	struct rpc_rqst *req = data;
1678 bool xprt_wake_up_backlog(struct rpc_xprt *xprt, struct rpc_rqst *req)
1704 static struct rpc_rqst *xprt_dynamic_alloc_slot(struct rpc_xprt *xprt)
1706 	struct rpc_rqst *req = ERR_PTR(-EAGAIN);
1722 static bool xprt_dynamic_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req)
1734 	struct rpc_rqst *req;
1738 		req = list_entry(xprt->free.next, struct rpc_rqst, rq_list);
1770 void xprt_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req)
1784 	struct rpc_rqst *req;
1786 		req = list_first_entry(&xprt->free, struct rpc_rqst, rq_list);
1821 	struct rpc_rqst *req;
1832 		req = kzalloc(sizeof(struct rpc_rqst), GFP_KERNEL);
1861 xprt_init_connect_cookie(struct rpc_rqst *req, struct rpc_xprt *xprt)
1887 	struct rpc_rqst	*req = task->tk_rqstp;
1964 	struct rpc_rqst	*req = task->tk_rqstp;
1998 xprt_init_bc_request(struct rpc_rqst *req, struct rpc_task *task,