Lines Matching refs:rpc_task

70 static void	xprt_connect_status(struct rpc_task *task);
71 static int __xprt_get_cong(struct rpc_xprt *, struct rpc_task *);
183 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt()
234 int xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt_cong()
271 static inline int xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_lock_write()
281 static bool __xprt_lock_write_func(struct rpc_task *task, void *data) in __xprt_lock_write_func()
304 static bool __xprt_lock_write_cong_func(struct rpc_task *task, void *data) in __xprt_lock_write_cong_func()
335 static void xprt_task_clear_bytes_sent(struct rpc_task *task) in xprt_task_clear_bytes_sent()
351 void xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt()
369 void xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt_cong()
379 static inline void xprt_release_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_write()
391 __xprt_get_cong(struct rpc_xprt *xprt, struct rpc_task *task) in __xprt_get_cong()
426 void xprt_release_rqst_cong(struct rpc_task *task) in xprt_release_rqst_cong()
450 void xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result) in xprt_adjust_cwnd()
498 void xprt_wait_for_buffer_space(struct rpc_task *task, rpc_action action) in xprt_wait_for_buffer_space()
535 void xprt_set_retrans_timeout_def(struct rpc_task *task) in xprt_set_retrans_timeout_def()
547 void xprt_set_retrans_timeout_rtt(struct rpc_task *task) in xprt_set_retrans_timeout_rtt()
719 struct rpc_task *task, in xprt_lock_connect()
757 void xprt_connect(struct rpc_task *task) in xprt_connect()
790 static void xprt_connect_status(struct rpc_task *task) in xprt_connect_status()
871 struct rpc_task *task = req->rq_task; in xprt_unpin_rqst()
882 struct rpc_task *task = req->rq_task; in xprt_wait_on_pinned_rqst()
900 void xprt_update_rtt(struct rpc_task *task) in xprt_update_rtt()
922 void xprt_complete_rqst(struct rpc_task *task, int copied) in xprt_complete_rqst()
943 static void xprt_timer(struct rpc_task *task) in xprt_timer()
964 bool xprt_prepare_transmit(struct rpc_task *task) in xprt_prepare_transmit()
996 void xprt_end_transmit(struct rpc_task *task) in xprt_end_transmit()
1007 void xprt_transmit(struct rpc_task *task) in xprt_transmit()
1079 static void xprt_add_backlog(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_add_backlog()
1091 static bool xprt_throttle_congested(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_throttle_congested()
1135 void xprt_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_alloc_slot()
1173 void xprt_lock_and_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_lock_and_alloc_slot()
1261 void xprt_reserve(struct rpc_task *task) in xprt_reserve()
1284 void xprt_retry_reserve(struct rpc_task *task) in xprt_retry_reserve()
1312 void xprt_request_init(struct rpc_task *task) in xprt_request_init()
1340 void xprt_release(struct rpc_task *task) in xprt_release()