Lines Matching defs:xprt

216 static void xprt_clear_locked(struct rpc_xprt *xprt)  in xprt_clear_locked()
236 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt()
267 xprt_need_congestion_window_wait(struct rpc_xprt *xprt) in xprt_need_congestion_window_wait()
273 xprt_set_congestion_window_wait(struct rpc_xprt *xprt) in xprt_set_congestion_window_wait()
285 xprt_test_and_clear_congestion_window_wait(struct rpc_xprt *xprt) in xprt_test_and_clear_congestion_window_wait()
300 int xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt_cong()
335 static inline int xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_lock_write()
349 struct rpc_xprt *xprt = data; in __xprt_lock_write_func() local
355 static void __xprt_lock_write_next(struct rpc_xprt *xprt) in __xprt_lock_write_next()
368 static void __xprt_lock_write_next_cong(struct rpc_xprt *xprt) in __xprt_lock_write_next_cong()
390 void xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt()
408 void xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_xprt_cong()
418 static inline void xprt_release_write(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_release_write()
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()
497 static void xprt_clear_congestion_window_wait_locked(struct rpc_xprt *xprt) in xprt_clear_congestion_window_wait_locked()
508 xprt_clear_congestion_window_wait(struct rpc_xprt *xprt) in xprt_clear_congestion_window_wait()
533 void xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result) in xprt_adjust_cwnd()
563 void xprt_wake_pending_tasks(struct rpc_xprt *xprt, int status) in xprt_wake_pending_tasks()
580 void xprt_wait_for_buffer_space(struct rpc_xprt *xprt) in xprt_wait_for_buffer_space()
587 xprt_clear_write_space_locked(struct rpc_xprt *xprt) in xprt_clear_write_space_locked()
604 bool xprt_write_space(struct rpc_xprt *xprt) in xprt_write_space()
652 struct rpc_xprt *xprt = req->rq_xprt; in xprt_init_majortimeo() local
670 struct rpc_xprt *xprt = req->rq_xprt; in xprt_adjust_timeout() local
705 struct rpc_xprt *xprt = in xprt_autoclose() local
722 void xprt_disconnect_done(struct rpc_xprt *xprt) in xprt_disconnect_done()
738 static void xprt_schedule_autoclose_locked(struct rpc_xprt *xprt) in xprt_schedule_autoclose_locked()
754 void xprt_force_disconnect(struct rpc_xprt *xprt) in xprt_force_disconnect()
766 xprt_connect_cookie(struct rpc_xprt *xprt) in xprt_connect_cookie()
775 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_retransmit_after_disconnect() local
792 void xprt_conditional_disconnect(struct rpc_xprt *xprt, unsigned int cookie) in xprt_conditional_disconnect()
806 xprt_has_timer(const struct rpc_xprt *xprt) in xprt_has_timer()
812 xprt_schedule_autodisconnect(struct rpc_xprt *xprt) in xprt_schedule_autodisconnect()
823 struct rpc_xprt *xprt = from_timer(xprt, t, timer); in xprt_init_autodisconnect() local
834 bool xprt_lock_connect(struct rpc_xprt *xprt, in xprt_lock_connect()
854 void xprt_unlock_connect(struct rpc_xprt *xprt, void *cookie) in xprt_unlock_connect()
878 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_connect() local
916 unsigned long xprt_reconnect_delay(const struct rpc_xprt *xprt) in xprt_reconnect_delay()
933 void xprt_reconnect_backoff(struct rpc_xprt *xprt, unsigned long init_to) in xprt_reconnect_backoff()
959 xprt_request_rb_find(struct rpc_xprt *xprt, __be32 xid) in xprt_request_rb_find()
981 xprt_request_rb_insert(struct rpc_xprt *xprt, struct rpc_rqst *new) 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()
1102 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_enqueue_receive() local
1169 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_rqst() local
1186 struct rpc_xprt *xprt = req->rq_xprt; in xprt_timer() local
1250 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_wait_receive() local
1290 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_enqueue_transmit() local
1362 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_dequeue_transmit() local
1380 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_dequeue_xprt() local
1409 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_prepare() local
1435 struct rpc_xprt *xprt = req->rq_xprt; in xprt_prepare_transmit() local
1450 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_end_transmit() local
1469 struct rpc_xprt *xprt = req->rq_xprt; in xprt_request_transmit() local
1543 struct rpc_xprt *xprt = req->rq_xprt; in xprt_transmit() local
1579 void xprt_add_backlog(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_add_backlog()
1598 bool xprt_wake_up_backlog(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_wake_up_backlog()
1608 static bool xprt_throttle_congested(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_throttle_congested()
1624 static struct rpc_rqst *xprt_dynamic_alloc_slot(struct rpc_xprt *xprt) 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()
1655 void xprt_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_alloc_slot()
1693 void xprt_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_free_slot()
1705 static void xprt_free_all_slots(struct rpc_xprt *xprt) in xprt_free_all_slots()
1719 struct rpc_xprt *xprt; in xprt_alloc() local
1751 void xprt_free(struct rpc_xprt *xprt) in xprt_free()
1760 xprt_init_connect_cookie(struct rpc_rqst *req, struct rpc_xprt *xprt) in xprt_init_connect_cookie()
1766 xprt_alloc_xid(struct rpc_xprt *xprt) in xprt_alloc_xid()
1777 xprt_init_xid(struct rpc_xprt *xprt) in xprt_init_xid()
1785 struct rpc_xprt *xprt = task->tk_xprt; in xprt_request_init() local
1806 xprt_do_reserve(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_do_reserve()
1823 struct rpc_xprt *xprt = task->tk_xprt; in xprt_reserve() local
1845 struct rpc_xprt *xprt = task->tk_xprt; in xprt_retry_reserve() local
1862 struct rpc_xprt *xprt; in xprt_release() local
1915 static void xprt_init(struct rpc_xprt *xprt, struct net *net) in xprt_init()
1953 struct rpc_xprt *xprt; in xprt_create_transport() local
1998 struct rpc_xprt *xprt = in xprt_destroy_cb() local
2025 static void xprt_destroy(struct rpc_xprt *xprt) in xprt_destroy()
2059 struct rpc_xprt *xprt_get(struct rpc_xprt *xprt) in xprt_get()
2072 void xprt_put(struct rpc_xprt *xprt) in xprt_put()