[deliverable/linux.git] / include / linux / sunrpc / svc_xprt.h

/*
 * linux/include/linux/sunrpc/svc_xprt.h
 *
 * RPC server transport I/O
 */

#ifndef SUNRPC_SVC_XPRT_H
#define SUNRPC_SVC_XPRT_H

#include <linux/sunrpc/svc.h>
#include <linux/module.h>

struct svc_xprt_ops {
	struct svc_xprt	*(*xpo_create)(struct svc_serv *,
				       struct sockaddr *, int,
				       int);
	struct svc_xprt	*(*xpo_accept)(struct svc_xprt *);
	int		(*xpo_has_wspace)(struct svc_xprt *);
	int		(*xpo_recvfrom)(struct svc_rqst *);
	void		(*xpo_prep_reply_hdr)(struct svc_rqst *);
	int		(*xpo_sendto)(struct svc_rqst *);
	void		(*xpo_release_rqst)(struct svc_rqst *);
	void		(*xpo_detach)(struct svc_xprt *);
	void		(*xpo_free)(struct svc_xprt *);
};

struct svc_xprt_class {
	const char		*xcl_name;
	struct module		*xcl_owner;
	struct svc_xprt_ops	*xcl_ops;
	struct list_head	xcl_list;
	u32			xcl_max_payload;
};

struct svc_xprt {
	struct svc_xprt_class	*xpt_class;
	struct svc_xprt_ops	*xpt_ops;
	struct kref		xpt_ref;
	struct list_head	xpt_list;
	struct list_head	xpt_ready;
	unsigned long		xpt_flags;
#define	XPT_BUSY	0		/* enqueued/receiving */
#define	XPT_CONN	1		/* conn pending */
#define	XPT_CLOSE	2		/* dead or dying */
#define	XPT_DATA	3		/* data pending */
#define	XPT_TEMP	4		/* connected transport */
#define	XPT_DEAD	6		/* transport closed */
#define	XPT_CHNGBUF	7		/* need to change snd/rcv buf sizes */
#define	XPT_DEFERRED	8		/* deferred request pending */
#define	XPT_OLD		9		/* used for xprt aging mark+sweep */
#define	XPT_DETACHED	10		/* detached from tempsocks list */
#define XPT_LISTENER	11		/* listening endpoint */
#define XPT_CACHE_AUTH	12		/* cache auth info */

	struct svc_pool		*xpt_pool;	/* current pool iff queued */
	struct svc_serv		*xpt_server;	/* service for transport */
	atomic_t    	    	xpt_reserved;	/* space on outq that is rsvd */
	struct mutex		xpt_mutex;	/* to serialize sending data */
	spinlock_t		xpt_lock;	/* protects sk_deferred
						 * and xpt_auth_cache */
	void			*xpt_auth_cache;/* auth cache */
	struct list_head	xpt_deferred;	/* deferred requests that need
						 * to be revisted */
};

int	svc_reg_xprt_class(struct svc_xprt_class *);
void	svc_unreg_xprt_class(struct svc_xprt_class *);
void	svc_xprt_init(struct svc_xprt_class *, struct svc_xprt *,
		      struct svc_serv *);
int	svc_create_xprt(struct svc_serv *, char *, unsigned short, int);
void	svc_xprt_received(struct svc_xprt *);
void	svc_xprt_put(struct svc_xprt *xprt);
static inline void svc_xprt_get(struct svc_xprt *xprt)
{
	kref_get(&xprt->xpt_ref);
}

#endif /* SUNRPC_SVC_XPRT_H */
Commit	Line	Data
1d8206b9 TT	1	/*
	2	* linux/include/linux/sunrpc/svc_xprt.h
	3	*
	4	* RPC server transport I/O
	5	*/
	6
	7	#ifndef SUNRPC_SVC_XPRT_H
	8	#define SUNRPC_SVC_XPRT_H
	9
	10	#include <linux/sunrpc/svc.h>
e1b3157f	11	#include <linux/module.h>
1d8206b9 TT	12
1d8206b9 TT	13	struct svc_xprt_ops {
b700cbb1 TT	14	struct svc_xprt (xpo_create)(struct svc_serv *,
	15	struct sockaddr *, int,
	16	int);
38a417cc	17	struct svc_xprt (xpo_accept)(struct svc_xprt *);
323bee32	18	int (xpo_has_wspace)(struct svc_xprt );
5d137990	19	int (xpo_recvfrom)(struct svc_rqst );
e831fe65	20	void (xpo_prep_reply_hdr)(struct svc_rqst );
5d137990	21	int (xpo_sendto)(struct svc_rqst );
5148bf4e	22	void (xpo_release_rqst)(struct svc_rqst );
755cceab TT	23	void (xpo_detach)(struct svc_xprt );
755cceab TT	24	void (xpo_free)(struct svc_xprt );
1d8206b9 TT	25	};
	26
	27	struct svc_xprt_class {
	28	const char *xcl_name;
	29	struct module *xcl_owner;
	30	struct svc_xprt_ops *xcl_ops;
	31	struct list_head xcl_list;
49023155	32	u32 xcl_max_payload;
1d8206b9 TT	33	};
	34
	35	struct svc_xprt {
	36	struct svc_xprt_class *xpt_class;
	37	struct svc_xprt_ops *xpt_ops;
e1b3157f	38	struct kref xpt_ref;
7a182083 TT	39	struct list_head xpt_list;
7a182083 TT	40	struct list_head xpt_ready;
02fc6c36 TT	41	unsigned long xpt_flags;
	42	#define XPT_BUSY 0 /* enqueued/receiving */
	43	#define XPT_CONN 1 /* conn pending */
	44	#define XPT_CLOSE 2 /* dead or dying */
	45	#define XPT_DATA 3 /* data pending */
	46	#define XPT_TEMP 4 /* connected transport */
	47	#define XPT_DEAD 6 /* transport closed */
	48	#define XPT_CHNGBUF 7 /* need to change snd/rcv buf sizes */
	49	#define XPT_DEFERRED 8 /* deferred request pending */
	50	#define XPT_OLD 9 /* used for xprt aging mark+sweep */
	51	#define XPT_DETACHED 10 /* detached from tempsocks list */
	52	#define XPT_LISTENER 11 /* listening endpoint */
def13d74	53	#define XPT_CACHE_AUTH 12 /* cache auth info */
bb5cf160 TT	54
	55	struct svc_pool xpt_pool; / current pool iff queued */
	56	struct svc_serv xpt_server; / service for transport */
7a90e8cc	57	atomic_t xpt_reserved; /* space on outq that is rsvd */
a50fea26	58	struct mutex xpt_mutex; /* to serialize sending data */
def13d74 TT	59	spinlock_t xpt_lock; /* protects sk_deferred
	60	* and xpt_auth_cache */
	61	void xpt_auth_cache;/ auth cache */
8c7b0172 TT	62	struct list_head xpt_deferred; /* deferred requests that need
8c7b0172 TT	63	* to be revisted */
1d8206b9 TT	64	};
	65
	66	int svc_reg_xprt_class(struct svc_xprt_class *);
	67	void svc_unreg_xprt_class(struct svc_xprt_class *);
bb5cf160 TT	68	void svc_xprt_init(struct svc_xprt_class , struct svc_xprt ,
bb5cf160 TT	69	struct svc_serv *);
b700cbb1	70	int svc_create_xprt(struct svc_serv , char , unsigned short, int);
a6046f71	71	void svc_xprt_received(struct svc_xprt *);
e1b3157f	72	void svc_xprt_put(struct svc_xprt *xprt);
e1b3157f TT	73	static inline void svc_xprt_get(struct svc_xprt *xprt)
	74	{
	75	kref_get(&xprt->xpt_ref);
	76	}
1d8206b9 TT	77
1d8206b9 TT	78	#endif /* SUNRPC_SVC_XPRT_H */