Lines Matching refs:rpc_rqst
80 static unsigned long xprt_request_timeout(const struct rpc_rqst *req) in xprt_request_timeout()
266 struct rpc_rqst *req = task->tk_rqstp; in xprt_reserve_xprt()
305 if (list_first_entry(&xprt->xmit_queue, struct rpc_rqst, in xprt_set_congestion_window_wait()
330 struct rpc_rqst *req = task->tk_rqstp; in xprt_reserve_xprt_cong()
460 __xprt_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) in __xprt_get_cong()
479 __xprt_put_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) in __xprt_put_cong()
498 xprt_request_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_request_get_cong()
519 struct rpc_rqst *req = task->tk_rqstp; in xprt_release_rqst_cong()
563 struct rpc_rqst *req = task->tk_rqstp; in xprt_adjust_cwnd()
653 static unsigned long xprt_calc_majortimeo(struct rpc_rqst *req) in xprt_calc_majortimeo()
667 static void xprt_reset_majortimeo(struct rpc_rqst *req) in xprt_reset_majortimeo()
672 static void xprt_reset_minortimeo(struct rpc_rqst *req) in xprt_reset_minortimeo()
677 static void xprt_init_majortimeo(struct rpc_task *task, struct rpc_rqst *req) in xprt_init_majortimeo()
696 int xprt_adjust_timeout(struct rpc_rqst *req) in xprt_adjust_timeout()
804 struct rpc_rqst *req = task->tk_rqstp; in xprt_request_retransmit_after_disconnect()
1006 static struct rpc_rqst *
1010 struct rpc_rqst *req; in xprt_request_rb_find()
1013 req = rb_entry(n, struct rpc_rqst, rq_recv); in xprt_request_rb_find()
1029 xprt_request_rb_insert(struct rpc_xprt *xprt, struct rpc_rqst *new) in xprt_request_rb_insert()
1033 struct rpc_rqst *req; in xprt_request_rb_insert()
1037 req = rb_entry(n, struct rpc_rqst, rq_recv); in xprt_request_rb_insert()
1055 xprt_request_rb_remove(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_request_rb_remove()
1067 struct rpc_rqst *xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid) in xprt_lookup_rqst()
1069 struct rpc_rqst *entry; in xprt_lookup_rqst()
1087 xprt_is_pinned_rqst(struct rpc_rqst *req) in xprt_is_pinned_rqst()
1099 void xprt_pin_rqst(struct rpc_rqst *req) in xprt_pin_rqst()
1111 void xprt_unpin_rqst(struct rpc_rqst *req) in xprt_unpin_rqst()
1122 static void xprt_wait_on_pinned_rqst(struct rpc_rqst *req) in xprt_wait_on_pinned_rqst()
1135 xprt_request_need_enqueue_receive(struct rpc_task *task, struct rpc_rqst *req) in xprt_request_need_enqueue_receive()
1149 struct rpc_rqst *req = task->tk_rqstp; in xprt_request_enqueue_receive()
1180 struct rpc_rqst *req = task->tk_rqstp; in xprt_request_dequeue_receive_locked()
1194 struct rpc_rqst *req = task->tk_rqstp; in xprt_update_rtt()
1216 struct rpc_rqst *req = task->tk_rqstp; in xprt_complete_rqst()
1233 struct rpc_rqst *req = task->tk_rqstp; in xprt_timer()
1258 struct rpc_rqst *req = task->tk_rqstp; in xprt_wait_for_reply_request_def()
1277 struct rpc_rqst *req = task->tk_rqstp; in xprt_wait_for_reply_request_rtt()
1297 struct rpc_rqst *req = task->tk_rqstp; in xprt_request_wait_receive()
1323 xprt_request_need_enqueue_transmit(struct rpc_task *task, struct rpc_rqst *req) in xprt_request_need_enqueue_transmit()
1337 struct rpc_rqst *pos, *req = task->tk_rqstp; in xprt_request_enqueue_transmit()
1396 struct rpc_rqst *req = task->tk_rqstp; in xprt_request_dequeue_transmit_locked()
1403 struct rpc_rqst *next = list_first_entry(&req->rq_xmit2, in xprt_request_dequeue_transmit_locked()
1404 struct rpc_rqst, rq_xmit2); in xprt_request_dequeue_transmit_locked()
1422 struct rpc_rqst *req = task->tk_rqstp; in xprt_request_dequeue_transmit()
1440 struct rpc_rqst *req = task->tk_rqstp; in xprt_request_dequeue_xprt()
1468 xprt_request_prepare(struct rpc_rqst *req) in xprt_request_prepare()
1495 struct rpc_rqst *req = task->tk_rqstp; in xprt_prepare_transmit()
1528 xprt_request_transmit(struct rpc_rqst *req, struct rpc_task *snd_task) in xprt_request_transmit()
1605 struct rpc_rqst *next, *req = task->tk_rqstp; in xprt_transmit()
1612 struct rpc_rqst, rq_xmit); in xprt_transmit()
1651 struct rpc_rqst *req = data; in __xprt_set_rq()
1661 bool xprt_wake_up_backlog(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_wake_up_backlog()
1687 static struct rpc_rqst *xprt_dynamic_alloc_slot(struct rpc_xprt *xprt) in xprt_dynamic_alloc_slot()
1689 struct rpc_rqst *req = ERR_PTR(-EAGAIN); in xprt_dynamic_alloc_slot()
1695 req = kzalloc(sizeof(struct rpc_rqst), GFP_NOFS); in xprt_dynamic_alloc_slot()
1705 static bool xprt_dynamic_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_dynamic_free_slot()
1717 struct rpc_rqst *req; in xprt_alloc_slot()
1721 req = list_entry(xprt->free.next, struct rpc_rqst, rq_list); in xprt_alloc_slot()
1753 void xprt_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_free_slot()
1767 struct rpc_rqst *req; in xprt_free_all_slots()
1769 req = list_first_entry(&xprt->free, struct rpc_rqst, rq_list); in xprt_free_all_slots()
1804 struct rpc_rqst *req; in xprt_alloc()
1815 req = kzalloc(sizeof(struct rpc_rqst), GFP_KERNEL); in xprt_alloc()
1847 xprt_init_connect_cookie(struct rpc_rqst *req, struct rpc_xprt *xprt) in xprt_init_connect_cookie()
1873 struct rpc_rqst *req = task->tk_rqstp; in xprt_request_init()
1950 struct rpc_rqst *req = task->tk_rqstp; in xprt_release()
1986 xprt_init_bc_request(struct rpc_rqst *req, struct rpc_task *task) in xprt_init_bc_request()