30 #define RPC_MAXCWND(xprt)	((xprt)->max_reqs << RPC_CWNDSHIFT)  argument
31 #define RPCXPRT_CONGESTED(xprt) ((xprt)->cong >= (xprt)->cwnd)  argument
148 	void		(*set_buffer_size)(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize);
149 	int		(*reserve_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
150 	void		(*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
151 	void		(*alloc_slot)(struct rpc_xprt *xprt, struct rpc_task *task);
152 	void		(*free_slot)(struct rpc_xprt *xprt,
155 	void		(*set_port)(struct rpc_xprt *xprt, unsigned short port);
156 	void		(*connect)(struct rpc_xprt *xprt, struct rpc_task *task);
157 	int		(*get_srcaddr)(struct rpc_xprt *xprt, char *buf,
159 	unsigned short	(*get_srcport)(struct rpc_xprt *xprt);
166 	void		(*timer)(struct rpc_xprt *xprt, struct rpc_task *task);
168 	void		(*close)(struct rpc_xprt *xprt);
169 	void		(*destroy)(struct rpc_xprt *xprt);
170 	void		(*set_connect_timeout)(struct rpc_xprt *xprt,
173 	void		(*print_stats)(struct rpc_xprt *xprt, struct seq_file *seq);
174 	int		(*enable_swap)(struct rpc_xprt *xprt);
175 	void		(*disable_swap)(struct rpc_xprt *xprt);
176 	void		(*inject_disconnect)(struct rpc_xprt *xprt);
177 	int		(*bc_setup)(struct rpc_xprt *xprt,
179 	size_t		(*bc_maxpayload)(struct rpc_xprt *xprt);
180 	unsigned int	(*bc_num_slots)(struct rpc_xprt *xprt);
182 	void		(*bc_destroy)(struct rpc_xprt *xprt,
372 unsigned long		xprt_reconnect_delay(const struct rpc_xprt *xprt);
373 void			xprt_reconnect_backoff(struct rpc_xprt *xprt,
377 int			xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task);
378 int			xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task);
379 void			xprt_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task);
380 void			xprt_free_slot(struct rpc_xprt *xprt,
391 void			xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task);
392 void			xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task);
394 struct rpc_xprt *	xprt_get(struct rpc_xprt *xprt);
395 void			xprt_put(struct rpc_xprt *xprt);
400 void			xprt_add_backlog(struct rpc_xprt *xprt, struct rpc_task *task);
401 bool			xprt_wake_up_backlog(struct rpc_xprt *xprt, struct rpc_rqst *req);
405 xprt_enable_swap(struct rpc_xprt *xprt)  in xprt_enable_swap()  argument
407 	return xprt->ops->enable_swap(xprt);  in xprt_enable_swap()
411 xprt_disable_swap(struct rpc_xprt *xprt)  in xprt_disable_swap()  argument
413 	xprt->ops->disable_swap(xprt);  in xprt_disable_swap()
424 void			xprt_wake_pending_tasks(struct rpc_xprt *xprt, int status);
425 void			xprt_wait_for_buffer_space(struct rpc_xprt *xprt);
426 bool			xprt_write_space(struct rpc_xprt *xprt);
427 void			xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result);
428 struct rpc_rqst *	xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid);
434 bool			xprt_request_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req);
435 void			xprt_disconnect_done(struct rpc_xprt *xprt);
436 void			xprt_force_disconnect(struct rpc_xprt *xprt);
437 void			xprt_conditional_disconnect(struct rpc_xprt *xprt, unsigned int cookie);
460 static inline void xprt_set_connected(struct rpc_xprt *xprt)  in xprt_set_connected()  argument
462 	set_bit(XPRT_CONNECTED, &xprt->state);  in xprt_set_connected()
465 static inline void xprt_clear_connected(struct rpc_xprt *xprt)  in xprt_clear_connected()  argument
467 	clear_bit(XPRT_CONNECTED, &xprt->state);  in xprt_clear_connected()
470 static inline int xprt_connected(struct rpc_xprt *xprt)  in xprt_connected()  argument
472 	return test_bit(XPRT_CONNECTED, &xprt->state);  in xprt_connected()
475 static inline int xprt_test_and_set_connected(struct rpc_xprt *xprt)  in xprt_test_and_set_connected()  argument
477 	return test_and_set_bit(XPRT_CONNECTED, &xprt->state);  in xprt_test_and_set_connected()
480 static inline int xprt_test_and_clear_connected(struct rpc_xprt *xprt)  in xprt_test_and_clear_connected()  argument
482 	return test_and_clear_bit(XPRT_CONNECTED, &xprt->state);  in xprt_test_and_clear_connected()
485 static inline void xprt_clear_connecting(struct rpc_xprt *xprt)  in xprt_clear_connecting()  argument
488 	clear_bit(XPRT_CONNECTING, &xprt->state);  in xprt_clear_connecting()
492 static inline int xprt_connecting(struct rpc_xprt *xprt)  in xprt_connecting()  argument
494 	return test_bit(XPRT_CONNECTING, &xprt->state);  in xprt_connecting()
497 static inline int xprt_test_and_set_connecting(struct rpc_xprt *xprt)  in xprt_test_and_set_connecting()  argument
499 	return test_and_set_bit(XPRT_CONNECTING, &xprt->state);  in xprt_test_and_set_connecting()
502 static inline void xprt_set_bound(struct rpc_xprt *xprt)  in xprt_set_bound()  argument
504 	test_and_set_bit(XPRT_BOUND, &xprt->state);  in xprt_set_bound()
507 static inline int xprt_bound(struct rpc_xprt *xprt)  in xprt_bound()  argument
509 	return test_bit(XPRT_BOUND, &xprt->state);  in xprt_bound()
512 static inline void xprt_clear_bound(struct rpc_xprt *xprt)  in xprt_clear_bound()  argument
514 	clear_bit(XPRT_BOUND, &xprt->state);  in xprt_clear_bound()
517 static inline void xprt_clear_binding(struct rpc_xprt *xprt)  in xprt_clear_binding()  argument
520 	clear_bit(XPRT_BINDING, &xprt->state);  in xprt_clear_binding()
524 static inline int xprt_test_and_set_binding(struct rpc_xprt *xprt)  in xprt_test_and_set_binding()  argument
526 	return test_and_set_bit(XPRT_BINDING, &xprt->state);  in xprt_test_and_set_binding()
529 void xprt_set_offline_locked(struct rpc_xprt *xprt, struct rpc_xprt_switch *xps);
530 void xprt_set_online_locked(struct rpc_xprt *xprt, struct rpc_xprt_switch *xps);
531 void xprt_delete_locked(struct rpc_xprt *xprt, struct rpc_xprt_switch *xps);