32 #define RPC_MAXCWND(xprt)	((xprt)->max_reqs << RPC_CWNDSHIFT)  argument
33 #define RPCXPRT_CONGESTED(xprt) ((xprt)->cong >= (xprt)->cwnd)  argument
125 	void		(*set_buffer_size)(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize);
126 	int		(*reserve_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
127 	void		(*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
128 	void		(*alloc_slot)(struct rpc_xprt *xprt, struct rpc_task *task);
129 	void		(*free_slot)(struct rpc_xprt *xprt,
132 	void		(*set_port)(struct rpc_xprt *xprt, unsigned short port);
133 	void		(*connect)(struct rpc_xprt *xprt, struct rpc_task *task);
138 	void		(*timer)(struct rpc_xprt *xprt, struct rpc_task *task);
140 	void		(*close)(struct rpc_xprt *xprt);
141 	void		(*destroy)(struct rpc_xprt *xprt);
142 	void		(*set_connect_timeout)(struct rpc_xprt *xprt,
145 	void		(*print_stats)(struct rpc_xprt *xprt, struct seq_file *seq);
146 	int		(*enable_swap)(struct rpc_xprt *xprt);
147 	void		(*disable_swap)(struct rpc_xprt *xprt);
148 	void		(*inject_disconnect)(struct rpc_xprt *xprt);
149 	int		(*bc_setup)(struct rpc_xprt *xprt,
152 	size_t		(*bc_maxpayload)(struct rpc_xprt *xprt);
154 	void		(*bc_destroy)(struct rpc_xprt *xprt,
330 int			xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task);
331 int			xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task);
332 void			xprt_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task);
333 void			xprt_free_slot(struct rpc_xprt *xprt,
335 void			xprt_lock_and_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task);
340 void			xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task);
341 void			xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task);
343 struct rpc_xprt *	xprt_get(struct rpc_xprt *xprt);
344 void			xprt_put(struct rpc_xprt *xprt);
350 static inline __be32 *xprt_skip_transport_header(struct rpc_xprt *xprt, __be32 *p)  in xprt_skip_transport_header()  argument
352 	return p + xprt->tsh_size;  in xprt_skip_transport_header()
356 xprt_enable_swap(struct rpc_xprt *xprt)  in xprt_enable_swap()  argument
358 	return xprt->ops->enable_swap(xprt);  in xprt_enable_swap()
362 xprt_disable_swap(struct rpc_xprt *xprt)  in xprt_disable_swap()  argument
364 	xprt->ops->disable_swap(xprt);  in xprt_disable_swap()
375 void			xprt_wake_pending_tasks(struct rpc_xprt *xprt, int status);
377 void			xprt_write_space(struct rpc_xprt *xprt);
378 void			xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result);
379 struct rpc_rqst *	xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid);
385 void			xprt_disconnect_done(struct rpc_xprt *xprt);
386 void			xprt_force_disconnect(struct rpc_xprt *xprt);
387 void			xprt_conditional_disconnect(struct rpc_xprt *xprt, unsigned int cookie);
404 static inline void xprt_set_connected(struct rpc_xprt *xprt)  in xprt_set_connected()  argument
406 	set_bit(XPRT_CONNECTED, &xprt->state);  in xprt_set_connected()
409 static inline void xprt_clear_connected(struct rpc_xprt *xprt)  in xprt_clear_connected()  argument
411 	clear_bit(XPRT_CONNECTED, &xprt->state);  in xprt_clear_connected()
414 static inline int xprt_connected(struct rpc_xprt *xprt)  in xprt_connected()  argument
416 	return test_bit(XPRT_CONNECTED, &xprt->state);  in xprt_connected()
419 static inline int xprt_test_and_set_connected(struct rpc_xprt *xprt)  in xprt_test_and_set_connected()  argument
421 	return test_and_set_bit(XPRT_CONNECTED, &xprt->state);  in xprt_test_and_set_connected()
424 static inline int xprt_test_and_clear_connected(struct rpc_xprt *xprt)  in xprt_test_and_clear_connected()  argument
426 	return test_and_clear_bit(XPRT_CONNECTED, &xprt->state);  in xprt_test_and_clear_connected()
429 static inline void xprt_clear_connecting(struct rpc_xprt *xprt)  in xprt_clear_connecting()  argument
432 	clear_bit(XPRT_CONNECTING, &xprt->state);  in xprt_clear_connecting()
436 static inline int xprt_connecting(struct rpc_xprt *xprt)  in xprt_connecting()  argument
438 	return test_bit(XPRT_CONNECTING, &xprt->state);  in xprt_connecting()
441 static inline int xprt_test_and_set_connecting(struct rpc_xprt *xprt)  in xprt_test_and_set_connecting()  argument
443 	return test_and_set_bit(XPRT_CONNECTING, &xprt->state);  in xprt_test_and_set_connecting()
446 static inline void xprt_set_bound(struct rpc_xprt *xprt)  in xprt_set_bound()  argument
448 	test_and_set_bit(XPRT_BOUND, &xprt->state);  in xprt_set_bound()
451 static inline int xprt_bound(struct rpc_xprt *xprt)  in xprt_bound()  argument
453 	return test_bit(XPRT_BOUND, &xprt->state);  in xprt_bound()
456 static inline void xprt_clear_bound(struct rpc_xprt *xprt)  in xprt_clear_bound()  argument
458 	clear_bit(XPRT_BOUND, &xprt->state);  in xprt_clear_bound()
461 static inline void xprt_clear_binding(struct rpc_xprt *xprt)  in xprt_clear_binding()  argument
464 	clear_bit(XPRT_BINDING, &xprt->state);  in xprt_clear_binding()
468 static inline int xprt_test_and_set_binding(struct rpc_xprt *xprt)  in xprt_test_and_set_binding()  argument
470 	return test_and_set_bit(XPRT_BINDING, &xprt->state);  in xprt_test_and_set_binding()
475 static inline void xprt_inject_disconnect(struct rpc_xprt *xprt)  in xprt_inject_disconnect()  argument
479 	if (atomic_dec_return(&xprt->inject_disconnect))  in xprt_inject_disconnect()
481 	atomic_set(&xprt->inject_disconnect, rpc_inject_disconnect);  in xprt_inject_disconnect()
482 	xprt->ops->inject_disconnect(xprt);  in xprt_inject_disconnect()
485 static inline void xprt_inject_disconnect(struct rpc_xprt *xprt)  in xprt_inject_disconnect()  argument