Return to session.h CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / trafshow

trafshow

    1: /*
    2:  *	Copyright (c) 2003 Rinet Corp., Novosibirsk, Russia
    3:  *
    4:  * Redistribution and use in source forms, with and without modification,
    5:  * are permitted provided that this entire comment appears intact.
    6:  *
    7:  * THIS SOURCE CODE IS PROVIDED ``AS IS'' WITHOUT ANY WARRANTIES OF ANY KIND.
    8:  */
    9: 
   10: #ifndef	_SESSION_H_
   11: #define	_SESSION_H_
   12: 
   13: #include <sys/types.h>
   14: #include <sys/socket.h>
   15: #include <sys/time.h>
   16: #include <sys/select.h>
   17: #include <netinet/in.h>
   18: 
   19: /*
   20:  * Session handler.
   21:  */
   22: 
   23: /* currently supported session types */
   24: typedef	enum {
   25: 	PlainFile,	/* simple I/O with a file descriptor */
   26: 	TextStream,	/* CRLFed text lines exchange through TCP */
   27: 	DataSequence	/* raw binary data exchange through UDP */
   28: } SessionType;
   29: 
   30: struct session_binder_ent;
   31: 
   32: #ifndef	HAVE_SOCKADDR_STORAGE
   33: 
   34: /*
   35:  * RFC 2553: protocol-independent placeholder for socket addresses
   36:  */
   37: #define _SS_MAXSIZE	128
   38: #define _SS_ALIGNSIZE	(sizeof(u_int64_t))
   39: #define _SS_PAD1SIZE	(_SS_ALIGNSIZE - sizeof(u_char) * 2)
   40: #define _SS_PAD2SIZE	(_SS_MAXSIZE - sizeof(u_char) * 2 - \
   41: 				_SS_PAD1SIZE - _SS_ALIGNSIZE)
   42: 
   43: struct sockaddr_storage {
   44: 	u_char	ss_len;		/* address length */
   45: 	u_char	ss_family;	/* address family */
   46: 	char	__ss_pad1[_SS_PAD1SIZE];
   47: 	u_int64_t __ss_align;	/* force desired structure storage alignment */
   48: 	char	__ss_pad2[_SS_PAD2SIZE];
   49: };
   50: 
   51: #endif /* HAVE_SOCKADDR_STORAGE */
   52: 
   53: typedef	struct session_ent {
   54: 	u_long	sid;		/* session id (must not be zero!) */
   55: 
   56: 	/* user supplied parameters */
   57: 	int sock;		/* socket file descriptor */
   58: 	struct sockaddr_storage peer;	/* remote peer address and port */
   59: 	struct sockaddr_storage from;	/* recvfrom peer */
   60: 	SessionType type;	/* session type, see above */
   61: 	unsigned timeout;	/* reply timeout in seconds */
   62: 
   63: 	/* internal */
   64: 	struct timeval expire;	/* time until first timeout */
   65: 	char *buf;		/* temporary I/O buffer */
   66: 
   67: 	/* user callback functions */
   68: 	void (*connected)(struct session_ent *sd);
   69: 	void (*read_error)(struct session_ent *sd, int error);
   70: 	void (*read_data)(struct session_ent *sd, const unsigned char *data, int len);
   71: 
   72: 	const void *cookie;	/* user defined container, cast it yourself */
   73: 
   74: 	struct session_binder_ent *sb; /* session binder container */
   75: 
   76: 	struct session_ent *next;
   77: } SESSION;
   78: 
   79: SESSION *session_open(int sock, const struct sockaddr *peer, SessionType type);
   80: int session_sock(SESSION *sd);
   81: int session_start(SESSION *sd);
   82: void session_stop(SESSION *sd);
   83: int session_idle(SESSION *sd);
   84: void session_free(SESSION *sd);
   85: void session_setcallback(SESSION *sd,
   86: 			 void (*connected)(SESSION *sd),
   87: 			 void (*read_error)(SESSION *sd, int error),
   88: 			 void (*read_data)(SESSION *sd, const unsigned char *data, int len));
   89: void session_setcookie(SESSION *sd, const void *cookie);
   90: const void *session_cookie(SESSION *sd);
   91: unsigned session_settimeout(SESSION *sd, unsigned timeout);
   92: int session_send(SESSION *sd, const unsigned char *data, int len);
   93: int session_select(int *nfds, fd_set *readfds, fd_set *writefds,
   94: 		   struct timeval *timeout, int *block);
   95: void session_operate(fd_set *readfds, fd_set *writefds);
   96: void session_timeout();
   97: const struct sockaddr *session_peer(SESSION *sd);
   98: const struct sockaddr *session_from(SESSION *sd);
   99: SESSION *session_find(const struct sockaddr *peer, SessionType type);
  100: 
  101: int session_bind(SESSION *sd, void (*notify)(void *arg), void *arg);
  102: void session_unbind(SESSION *sd, void (*notify)(void *arg), void *arg);
  103: 
  104: int socket_nonblock(int sock, int on);
  105: int socket_keepalive(int sock, int on);
  106: int socket_error(int sock);
  107: int socket_peer(struct sockaddr *peer, int sock);
  108: int socket_name(struct sockaddr *name, int sock);
  109: 
  110: #endif	/* _SESSION_H_ */