Lines Matching refs:rpc_task

75 static void	 xprt_request_init(struct rpc_task *task);
266 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt()
330 int xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt_cong()
365 static inline int xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_lock_write()
377 static bool __xprt_lock_write_func(struct rpc_task *task, void *data) in __xprt_lock_write_func()
420 void xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt()
438 void xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt_cong()
448 void xprt_release_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_write()
519 void xprt_release_rqst_cong(struct rpc_task *task) in xprt_release_rqst_cong()
563 void xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result) in xprt_adjust_cwnd()
679 static void xprt_init_majortimeo(struct rpc_task *task, struct rpc_rqst *req) in xprt_init_majortimeo()
801 xprt_request_retransmit_after_disconnect(struct rpc_task *task) in xprt_request_retransmit_after_disconnect()
877 struct rpc_task *task, in xprt_lock_connect()
918 void xprt_connect(struct rpc_task *task) in xprt_connect()
1127 xprt_request_data_received(struct rpc_task *task) in xprt_request_data_received()
1134 xprt_request_need_enqueue_receive(struct rpc_task *task, struct rpc_rqst *req) in xprt_request_need_enqueue_receive()
1146 xprt_request_enqueue_receive(struct rpc_task *task) in xprt_request_enqueue_receive()
1177 xprt_request_dequeue_receive_locked(struct rpc_task *task) in xprt_request_dequeue_receive_locked()
1191 void xprt_update_rtt(struct rpc_task *task) in xprt_update_rtt()
1213 void xprt_complete_rqst(struct rpc_task *task, int copied) in xprt_complete_rqst()
1230 static void xprt_timer(struct rpc_task *task) in xprt_timer()
1255 void xprt_wait_for_reply_request_def(struct rpc_task *task) in xprt_wait_for_reply_request_def()
1271 void xprt_wait_for_reply_request_rtt(struct rpc_task *task) in xprt_wait_for_reply_request_rtt()
1294 void xprt_request_wait_receive(struct rpc_task *task) in xprt_request_wait_receive()
1322 xprt_request_need_enqueue_transmit(struct rpc_task *task, struct rpc_rqst *req) in xprt_request_need_enqueue_transmit()
1334 xprt_request_enqueue_transmit(struct rpc_task *task) in xprt_request_enqueue_transmit()
1393 xprt_request_dequeue_transmit_locked(struct rpc_task *task) in xprt_request_dequeue_transmit_locked()
1419 xprt_request_dequeue_transmit(struct rpc_task *task) in xprt_request_dequeue_transmit()
1437 xprt_request_dequeue_xprt(struct rpc_task *task) in xprt_request_dequeue_xprt()
1482 xprt_request_need_retransmit(struct rpc_task *task) in xprt_request_need_retransmit()
1492 bool xprt_prepare_transmit(struct rpc_task *task) in xprt_prepare_transmit()
1508 void xprt_end_transmit(struct rpc_task *task) in xprt_end_transmit()
1527 xprt_request_transmit(struct rpc_rqst *req, struct rpc_task *snd_task) in xprt_request_transmit()
1530 struct rpc_task *task = req->rq_task; in xprt_request_transmit()
1602 xprt_transmit(struct rpc_task *task) in xprt_transmit()
1633 static void xprt_complete_request_init(struct rpc_task *task) in xprt_complete_request_init()
1639 void xprt_add_backlog(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_add_backlog()
1646 static bool __xprt_set_rq(struct rpc_task *task, void *data) in __xprt_set_rq()
1668 static bool xprt_throttle_congested(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_throttle_congested()
1712 void xprt_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_alloc_slot()
1867 xprt_request_init(struct rpc_task *task) in xprt_request_init()
1890 xprt_do_reserve(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_do_reserve()
1905 void xprt_reserve(struct rpc_task *task) in xprt_reserve()
1927 void xprt_retry_reserve(struct rpc_task *task) in xprt_retry_reserve()
1944 void xprt_release(struct rpc_task *task) in xprt_release()
1983 xprt_init_bc_request(struct rpc_rqst *req, struct rpc_task *task) in xprt_init_bc_request()