Lines Matching refs:rpc_xprt
72 static void xprt_init(struct rpc_xprt *xprt, struct net *net);
73 static __be32 xprt_alloc_xid(struct rpc_xprt *xprt);
74 static void xprt_destroy(struct rpc_xprt *xprt);
247 static void xprt_clear_locked(struct rpc_xprt *xprt) in xprt_clear_locked()
265 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt()
296 xprt_need_congestion_window_wait(struct rpc_xprt *xprt) in xprt_need_congestion_window_wait()
302 xprt_set_congestion_window_wait(struct rpc_xprt *xprt) in xprt_set_congestion_window_wait()
314 xprt_test_and_clear_congestion_window_wait(struct rpc_xprt *xprt) in xprt_test_and_clear_congestion_window_wait()
329 int xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt_cong()
364 static inline int xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_lock_write()
378 struct rpc_xprt *xprt = data; in __xprt_lock_write_func()
384 static void __xprt_lock_write_next(struct rpc_xprt *xprt) in __xprt_lock_write_next()
397 static void __xprt_lock_write_next_cong(struct rpc_xprt *xprt) in __xprt_lock_write_next_cong()
419 void xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt()
437 void xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt_cong()
447 void xprt_release_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_write()
461 __xprt_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) in __xprt_get_cong()
480 __xprt_put_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) in __xprt_put_cong()
499 xprt_request_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_request_get_cong()
526 static void xprt_clear_congestion_window_wait_locked(struct rpc_xprt *xprt) in xprt_clear_congestion_window_wait_locked()
537 xprt_clear_congestion_window_wait(struct rpc_xprt *xprt) in xprt_clear_congestion_window_wait()
562 void xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result) in xprt_adjust_cwnd()
592 void xprt_wake_pending_tasks(struct rpc_xprt *xprt, int status) in xprt_wake_pending_tasks()
609 void xprt_wait_for_buffer_space(struct rpc_xprt *xprt) in xprt_wait_for_buffer_space()
616 xprt_clear_write_space_locked(struct rpc_xprt *xprt) in xprt_clear_write_space_locked()
633 bool xprt_write_space(struct rpc_xprt *xprt) in xprt_write_space()
681 struct rpc_xprt *xprt = req->rq_xprt; in xprt_init_majortimeo()
699 struct rpc_xprt *xprt = req->rq_xprt; in xprt_adjust_timeout()
734 struct rpc_xprt *xprt = in xprt_autoclose()
735 container_of(work, struct rpc_xprt, task_cleanup); in xprt_autoclose()
753 void xprt_disconnect_done(struct rpc_xprt *xprt) in xprt_disconnect_done()
769 static void xprt_schedule_autoclose_locked(struct rpc_xprt *xprt) in xprt_schedule_autoclose_locked()
785 void xprt_force_disconnect(struct rpc_xprt *xprt) in xprt_force_disconnect()
797 xprt_connect_cookie(struct rpc_xprt *xprt) in xprt_connect_cookie()
806 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_retransmit_after_disconnect()
823 void xprt_conditional_disconnect(struct rpc_xprt *xprt, unsigned int cookie) in xprt_conditional_disconnect()
837 xprt_has_timer(const struct rpc_xprt *xprt) in xprt_has_timer()
843 xprt_schedule_autodisconnect(struct rpc_xprt *xprt) in xprt_schedule_autodisconnect()
854 struct rpc_xprt *xprt = from_timer(xprt, t, timer); in xprt_init_autodisconnect()
866 static void xprt_inject_disconnect(struct rpc_xprt *xprt) in xprt_inject_disconnect()
873 static inline void xprt_inject_disconnect(struct rpc_xprt *xprt) in xprt_inject_disconnect()
878 bool xprt_lock_connect(struct rpc_xprt *xprt, in xprt_lock_connect()
898 void xprt_unlock_connect(struct rpc_xprt *xprt, void *cookie) in xprt_unlock_connect()
922 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_connect()
960 unsigned long xprt_reconnect_delay(const struct rpc_xprt *xprt) in xprt_reconnect_delay()
977 void xprt_reconnect_backoff(struct rpc_xprt *xprt, unsigned long init_to) in xprt_reconnect_backoff()
1003 xprt_request_rb_find(struct rpc_xprt *xprt, __be32 xid) in xprt_request_rb_find()
1025 xprt_request_rb_insert(struct rpc_xprt *xprt, struct rpc_rqst *new) in xprt_request_rb_insert()
1051 xprt_request_rb_remove(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_request_rb_remove()
1063 struct rpc_rqst *xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid) in xprt_lookup_rqst()
1146 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_enqueue_receive()
1217 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_rqst()
1236 struct rpc_xprt *xprt = req->rq_xprt; in xprt_timer()
1300 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_wait_receive()
1340 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_enqueue_transmit()
1421 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_dequeue_transmit()
1439 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_dequeue_xprt()
1471 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_prepare()
1498 struct rpc_xprt *xprt = req->rq_xprt; in xprt_prepare_transmit()
1516 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_end_transmit()
1535 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_transmit()
1611 struct rpc_xprt *xprt = req->rq_xprt; in xprt_transmit()
1647 void xprt_add_backlog(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_add_backlog()
1666 bool xprt_wake_up_backlog(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_wake_up_backlog()
1676 static bool xprt_throttle_congested(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_throttle_congested()
1692 static struct rpc_rqst *xprt_dynamic_alloc_slot(struct rpc_xprt *xprt) in xprt_dynamic_alloc_slot()
1710 static bool xprt_dynamic_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_dynamic_free_slot()
1720 void xprt_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_alloc_slot()
1758 void xprt_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_free_slot()
1770 static void xprt_free_all_slots(struct rpc_xprt *xprt) in xprt_free_all_slots()
1787 static int xprt_alloc_id(struct rpc_xprt *xprt) in xprt_alloc_id()
1799 static void xprt_free_id(struct rpc_xprt *xprt) in xprt_free_id()
1804 struct rpc_xprt *xprt_alloc(struct net *net, size_t size, in xprt_alloc()
1808 struct rpc_xprt *xprt; in xprt_alloc()
1838 void xprt_free(struct rpc_xprt *xprt) in xprt_free()
1849 xprt_init_connect_cookie(struct rpc_rqst *req, struct rpc_xprt *xprt) in xprt_init_connect_cookie()
1855 xprt_alloc_xid(struct rpc_xprt *xprt) in xprt_alloc_xid()
1866 xprt_init_xid(struct rpc_xprt *xprt) in xprt_init_xid()
1874 struct rpc_xprt *xprt = task->tk_xprt; in xprt_request_init()
1895 xprt_do_reserve(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_do_reserve()
1912 struct rpc_xprt *xprt = task->tk_xprt; in xprt_reserve()
1934 struct rpc_xprt *xprt = task->tk_xprt; in xprt_retry_reserve()
1951 struct rpc_xprt *xprt; in xprt_release()
2002 static void xprt_init(struct rpc_xprt *xprt, struct net *net) in xprt_init()
2038 struct rpc_xprt *xprt_create_transport(struct xprt_create *args) in xprt_create_transport()
2040 struct rpc_xprt *xprt; in xprt_create_transport()
2081 struct rpc_xprt *xprt = in xprt_destroy_cb()
2082 container_of(work, struct rpc_xprt, task_cleanup); in xprt_destroy_cb()
2108 static void xprt_destroy(struct rpc_xprt *xprt) in xprt_destroy()
2134 xprt_destroy(container_of(kref, struct rpc_xprt, kref)); in xprt_destroy_kref()
2142 struct rpc_xprt *xprt_get(struct rpc_xprt *xprt) in xprt_get()
2155 void xprt_put(struct rpc_xprt *xprt) in xprt_put()
2162 void xprt_set_offline_locked(struct rpc_xprt *xprt, struct rpc_xprt_switch *xps) in xprt_set_offline_locked()
2171 void xprt_set_online_locked(struct rpc_xprt *xprt, struct rpc_xprt_switch *xps) in xprt_set_online_locked()
2180 void xprt_delete_locked(struct rpc_xprt *xprt, struct rpc_xprt_switch *xps) in xprt_delete_locked()