78 static unsigned long xprt_request_timeout(const struct rpc_rqst *req)  in xprt_request_timeout()
238 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_reserve_xprt()
277 		if (list_first_entry(&xprt->xmit_queue, struct rpc_rqst,  in xprt_set_congestion_window_wait()
302 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_reserve_xprt_cong()
432 __xprt_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req)  in __xprt_get_cong()
451 __xprt_put_cong(struct rpc_xprt *xprt, struct rpc_rqst *req)  in __xprt_put_cong()
470 xprt_request_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req)  in xprt_request_get_cong()
491 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_release_rqst_cong()
535 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_adjust_cwnd()
625 static unsigned long xprt_calc_majortimeo(struct rpc_rqst *req)  in xprt_calc_majortimeo()
639 static void xprt_reset_majortimeo(struct rpc_rqst *req)  in xprt_reset_majortimeo()
644 static void xprt_reset_minortimeo(struct rpc_rqst *req)  in xprt_reset_minortimeo()
649 static void xprt_init_majortimeo(struct rpc_task *task, struct rpc_rqst *req)  in xprt_init_majortimeo()
668 int xprt_adjust_timeout(struct rpc_rqst *req)  in xprt_adjust_timeout()
774 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_request_retransmit_after_disconnect()
958 static struct rpc_rqst *
962 	struct rpc_rqst *req;  in xprt_request_rb_find()
965 		req = rb_entry(n, struct rpc_rqst, rq_recv);  in xprt_request_rb_find()
981 xprt_request_rb_insert(struct rpc_xprt *xprt, struct rpc_rqst *new)  in xprt_request_rb_insert()
985 	struct rpc_rqst *req;  in xprt_request_rb_insert()
989 		req = rb_entry(n, struct rpc_rqst, rq_recv);  in xprt_request_rb_insert()
1007 xprt_request_rb_remove(struct rpc_xprt *xprt, struct rpc_rqst *req)  in xprt_request_rb_remove()
1019 struct rpc_rqst *xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid)  in xprt_lookup_rqst()
1021 	struct rpc_rqst *entry;  in xprt_lookup_rqst()
1039 xprt_is_pinned_rqst(struct rpc_rqst *req)  in xprt_is_pinned_rqst()
1051 void xprt_pin_rqst(struct rpc_rqst *req)  in xprt_pin_rqst()
1063 void xprt_unpin_rqst(struct rpc_rqst *req)  in xprt_unpin_rqst()
1074 static void xprt_wait_on_pinned_rqst(struct rpc_rqst *req)  in xprt_wait_on_pinned_rqst()
1087 xprt_request_need_enqueue_receive(struct rpc_task *task, struct rpc_rqst *req)  in xprt_request_need_enqueue_receive()
1101 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_request_enqueue_receive()
1132 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_request_dequeue_receive_locked()
1146 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_update_rtt()
1168 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_complete_rqst()
1185 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_timer()
1210 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_wait_for_reply_request_def()
1229 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_wait_for_reply_request_rtt()
1249 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_request_wait_receive()
1275 xprt_request_need_enqueue_transmit(struct rpc_task *task, struct rpc_rqst *req)  in xprt_request_need_enqueue_transmit()
1289 	struct rpc_rqst *pos, *req = task->tk_rqstp;  in xprt_request_enqueue_transmit()
1336 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_request_dequeue_transmit_locked()
1343 			struct rpc_rqst *next = list_first_entry(&req->rq_xmit2,  in xprt_request_dequeue_transmit_locked()
1344 					struct rpc_rqst, rq_xmit2);  in xprt_request_dequeue_transmit_locked()
1361 	struct rpc_rqst *req = task->tk_rqstp;  in xprt_request_dequeue_transmit()
1379 	struct rpc_rqst	*req = task->tk_rqstp;  in xprt_request_dequeue_xprt()
1407 xprt_request_prepare(struct rpc_rqst *req)  in xprt_request_prepare()
1434 	struct rpc_rqst	*req = task->tk_rqstp;  in xprt_prepare_transmit()
1467 xprt_request_transmit(struct rpc_rqst *req, struct rpc_task *snd_task)  in xprt_request_transmit()
1542 	struct rpc_rqst *next, *req = task->tk_rqstp;  in xprt_transmit()
1549 						struct rpc_rqst, rq_xmit);  in xprt_transmit()
1588 	struct rpc_rqst *req = data;  in __xprt_set_rq()
1598 bool xprt_wake_up_backlog(struct rpc_xprt *xprt, struct rpc_rqst *req)  in xprt_wake_up_backlog()
1624 static struct rpc_rqst *xprt_dynamic_alloc_slot(struct rpc_xprt *xprt)  in xprt_dynamic_alloc_slot()
1626 	struct rpc_rqst *req = ERR_PTR(-EAGAIN);  in xprt_dynamic_alloc_slot()
1645 static bool xprt_dynamic_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req)  in xprt_dynamic_free_slot()
1657 	struct rpc_rqst *req;  in xprt_alloc_slot()
1661 		req = list_entry(xprt->free.next, struct rpc_rqst, rq_list);  in xprt_alloc_slot()
1693 void xprt_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req)  in xprt_free_slot()
1707 	struct rpc_rqst *req;  in xprt_free_all_slots()
1709 		req = list_first_entry(&xprt->free, struct rpc_rqst, rq_list);  in xprt_free_all_slots()
1720 	struct rpc_rqst *req;  in xprt_alloc()
1730 		req = kzalloc(sizeof(struct rpc_rqst), GFP_KERNEL);  in xprt_alloc()
1760 xprt_init_connect_cookie(struct rpc_rqst *req, struct rpc_xprt *xprt)  in xprt_init_connect_cookie()
1786 	struct rpc_rqst	*req = task->tk_rqstp;  in xprt_request_init()
1863 	struct rpc_rqst	*req = task->tk_rqstp;  in xprt_release()
1899 xprt_init_bc_request(struct rpc_rqst *req, struct rpc_task *task)  in xprt_init_bc_request()