Stuff

// original : core.h 2003/03/14 11:55:25 Rev 1.4#ifndef	_SOCKET_H_#define _SOCKET_H_#include <stdio.h>#include <sys/types.h>#ifdef _WIN32	#include <winsock.h>#else	#include <sys/socket.h>	#include <netinet/in.h>#endif#define RFIFOSIZE_SERVERLINK 128 * 1024#define WFIFOSIZE_SERVERLINK 128 * 1024// ここで閉じるのではなく、socket.c で閉じる#define close(id) do{ if (session[id]) session[id]->eof = 1; } while(0);// define declaration#define RFIFOSPACE(fd) (session[fd]->max_rdata - session[fd]->rdata_size)#define RFIFOP(fd,pos) (session[fd]->rdata_pos + (pos))#define RFIFOB(fd,pos) (*(unsigned char*)RFIFOP(fd,pos))#define RFIFOW(fd,pos) (*(unsigned short*)RFIFOP(fd,pos))#define RFIFOL(fd,pos) (*(unsigned int*)RFIFOP(fd,pos))#define RFIFOREST(fd)  (session[fd]->rdata_size - session[fd]->rdata_pos)#define RFIFOSKIP(fd,len) (session[fd]->rdata_pos += (len))#define WFIFOSPACE(fd) (session[fd]->max_wdata - session[fd]->wdata_size)#define WFIFOP(fd,pos) (session[fd]->wdata_size + (pos))#define WFIFOB(fd,pos) (*(unsigned char*)WFIFOP(fd,pos))#define WFIFOW(fd,pos) (*(unsigned short*)WFIFOP(fd,pos))#define WFIFOL(fd,pos) (*(unsigned int*)WFIFOP(fd,pos))#define WFIFOREST(fd)  (session[fd]->wdata_size - session[fd]->wdata_pos)// use function instead of macro.//#define WFIFOSET(fd,len) (session[fd]->wdata_size = (session[fd]->wdata_size + (len) + 2048 < session[fd]->max_wdata) ? session[fd]->wdata_size + (len) : session[fd]->wdata_size)#define RBUFP(p,pos) ((unsigned char*)(p) + (pos))#define RBUFB(p,pos) (*(unsigned char*)RBUFP(p,pos))#define RBUFW(p,pos) (*(unsigned short*)RBUFP(p,pos))#define RBUFL(p,pos) (*(unsigned int*)RBUFP(p,pos))#define WBUFP(p,pos) (((unsigned char*)(p)) + (pos))#define WBUFB(p,pos) (*(unsigned char*)WBUFP(p,pos))#define WBUFW(p,pos) (*(unsigned short*)WBUFP(p,pos))#define WBUFL(p,pos) (*(unsigned int*)WBUFP(p,pos))#ifdef __INTERIX#define FD_SETSIZE 4096#endif // __INTERIX// Struct declarationstruct socket_data{	int eof;	int auth;	unsigned int tick;	unsigned char *rdata, *wdata;	unsigned char *max_rdata , *max_wdata;	unsigned char *rdata_size, *rdata_pos;	unsigned char *wdata_size, *wdata_pos;	struct sockaddr_in client_addr;	int (*func_recv)(int);	int (*func_send)(int);	int (*func_parse)(int);	int (*func_destruct)(int);	int flag_destruct;	// デストラクタが再度呼ばれない為のフラグ	int flag_httpd;		// 0:httpd 未解析 1;解析済み	unsigned int rlr_tick, rlr_bytes, rlr_disc;	// 帯域制限用	void* session_data;	void* session_data2;	int server_port;#ifdef _WIN32	SOCKET socket;#endif};// Data prototype declarationextern struct socket_data *session[FD_SETSIZE];extern int fd_max;extern unsigned long listen_ip;// Function prototype declarationint make_listen_port(int, unsigned long);int make_connection(long, int);void delete_session(int);void realloc_fifo(int fd, int rfifo_size, int wfifo_size);void WFIFOSET(int fd, int len);void WFIFORESERVE(int fd, int len);void do_sendrecv(int next);void do_parsepacket(void);int parsepacket_timer(int tid, unsigned int tick, int id, int data);void do_socket(void);void set_defaultparse(int (*defaultparse)(int));void set_sock_destruct(int (*func_destruct)(int));void socket_enable_httpd(int);struct httpd_session_data;void socket_httpd_page(struct httpd_session_data* sd, const char* url);const char* get_socket_ctrl_panel_url(void);void socket_set_httpd_page_connection_func(void (*func)(int fd,char*,char*,char*));#endif // _SOCKET_H_