Lines Matching refs:rpc_xprt

68 static void	 xprt_init(struct rpc_xprt *xprt, struct net *net);
69 static __be32 xprt_alloc_xid(struct rpc_xprt *xprt);
71 static int __xprt_get_cong(struct rpc_xprt *, struct rpc_task *);
72 static void __xprt_put_cong(struct rpc_xprt *, struct rpc_rqst *);
73 static void xprt_destroy(struct rpc_xprt *xprt);
183 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt()
215 static void xprt_clear_locked(struct rpc_xprt *xprt) in xprt_clear_locked()
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()
283 struct rpc_xprt *xprt = data; in __xprt_lock_write_func()
293 static void __xprt_lock_write_next(struct rpc_xprt *xprt) in __xprt_lock_write_next()
306 struct rpc_xprt *xprt = data; in __xprt_lock_write_cong_func()
322 static void __xprt_lock_write_next_cong(struct rpc_xprt *xprt) in __xprt_lock_write_next_cong()
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()
411 __xprt_put_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) in __xprt_put_cong()
450 void xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result) in xprt_adjust_cwnd()
480 void xprt_wake_pending_tasks(struct rpc_xprt *xprt, int status) in xprt_wake_pending_tasks()
501 struct rpc_xprt *xprt = req->rq_xprt; in xprt_wait_for_buffer_space()
514 void xprt_write_space(struct rpc_xprt *xprt) in xprt_write_space()
583 struct rpc_xprt *xprt = req->rq_xprt; in xprt_adjust_timeout()
615 struct rpc_xprt *xprt = in xprt_autoclose()
616 container_of(work, struct rpc_xprt, task_cleanup); in xprt_autoclose()
629 void xprt_disconnect_done(struct rpc_xprt *xprt) in xprt_disconnect_done()
644 void xprt_force_disconnect(struct rpc_xprt *xprt) in xprt_force_disconnect()
668 void xprt_conditional_disconnect(struct rpc_xprt *xprt, unsigned int cookie) in xprt_conditional_disconnect()
686 xprt_has_timer(const struct rpc_xprt *xprt) in xprt_has_timer()
692 xprt_schedule_autodisconnect(struct rpc_xprt *xprt) in xprt_schedule_autodisconnect()
702 struct rpc_xprt *xprt = from_timer(xprt, t, timer); in xprt_init_autodisconnect()
718 bool xprt_lock_connect(struct rpc_xprt *xprt, in xprt_lock_connect()
737 void xprt_unlock_connect(struct rpc_xprt *xprt, void *cookie) in xprt_unlock_connect()
759 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_connect()
792 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; in xprt_connect_status()
831 struct rpc_rqst *xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid) in xprt_lookup_rqst()
925 struct rpc_xprt *xprt = req->rq_xprt; in xprt_complete_rqst()
946 struct rpc_xprt *xprt = req->rq_xprt; in xprt_timer()
967 struct rpc_xprt *xprt = req->rq_xprt; in xprt_prepare_transmit()
1010 struct rpc_xprt *xprt = req->rq_xprt; in xprt_transmit()
1079 static void xprt_add_backlog(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_add_backlog()
1085 static void xprt_wake_up_backlog(struct rpc_xprt *xprt) in xprt_wake_up_backlog()
1091 static bool xprt_throttle_congested(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_throttle_congested()
1107 static struct rpc_rqst *xprt_dynamic_alloc_slot(struct rpc_xprt *xprt) in xprt_dynamic_alloc_slot()
1125 static bool xprt_dynamic_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_dynamic_free_slot()
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()
1187 void xprt_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) in xprt_free_slot()
1199 static void xprt_free_all_slots(struct rpc_xprt *xprt) in xprt_free_all_slots()
1209 struct rpc_xprt *xprt_alloc(struct net *net, size_t size, in xprt_alloc()
1213 struct rpc_xprt *xprt; in xprt_alloc()
1245 void xprt_free(struct rpc_xprt *xprt) in xprt_free()
1263 struct rpc_xprt *xprt = task->tk_xprt; in xprt_reserve()
1286 struct rpc_xprt *xprt = task->tk_xprt; in xprt_retry_reserve()
1297 static inline __be32 xprt_alloc_xid(struct rpc_xprt *xprt) in xprt_alloc_xid()
1307 static inline void xprt_init_xid(struct rpc_xprt *xprt) in xprt_init_xid()
1314 struct rpc_xprt *xprt = task->tk_xprt; in xprt_request_init()
1342 struct rpc_xprt *xprt; in xprt_release()
1388 static void xprt_init(struct rpc_xprt *xprt, struct net *net) in xprt_init()
1423 struct rpc_xprt *xprt_create_transport(struct xprt_create *args) in xprt_create_transport()
1425 struct rpc_xprt *xprt; in xprt_create_transport()
1474 struct rpc_xprt *xprt = in xprt_destroy_cb()
1475 container_of(work, struct rpc_xprt, task_cleanup); in xprt_destroy_cb()
1494 static void xprt_destroy(struct rpc_xprt *xprt) in xprt_destroy()
1515 xprt_destroy(container_of(kref, struct rpc_xprt, kref)); in xprt_destroy_kref()
1523 struct rpc_xprt *xprt_get(struct rpc_xprt *xprt) in xprt_get()
1536 void xprt_put(struct rpc_xprt *xprt) in xprt_put()