socket.h

Go to the documentation of this file.

// $Id: socket.h 230 2006-02-09 00:52:46Z MagicalTux $
// original : core.h 2003/03/14 11:55:25 Rev 1.4

#ifndef OA_SOCKET_H
#define OA_SOCKET_H

#include <stdio.h>

#ifdef _WIN32
#define __USE_W32_SOCKETS
#include <windows.h>
#else
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#endif


#define RFIFOP(fd,pos)          \
        (session[fd]->rdata + session[fd]->rdata_pos + (pos))

#define RFIFOB(fd,pos)          \
        (*(unsigned char*)      \
         (session[fd]->rdata + session[fd]->rdata_pos + (pos)))

#define RFIFOW(fd,pos)          \
        (*(unsigned short*)     \
         (session[fd]->rdata + session[fd]->rdata_pos + (pos)))

#define RFIFOL(fd,pos)          \
        (*(unsigned int*)       \
         (session[fd]->rdata + session[fd]->rdata_pos + (pos)))

#ifdef __DEBUG
#define RFIFOSKIP(fd,len)                                       \
        do {                                                    \
                if (session[fd]->rdata_size                     \
                    - session[fd]->rdata_pos - (len) < 0) {     \
                        fprintf(stderr,                         \
                                "Too many skips at %s:%d.\n",   \
                                        __FILE__, __LINE__);    \
                        exit(1);                                \
                } else {                                        \
                        session[fd]->rdata_pos += (len);        \
                }                                               \
        } while (0)
                
#else
#define RFIFOSKIP(fd,len)       \
        (session[fd]->rdata_pos += (len))
#endif // __DEBUG

#define RFIFOREST(fd)           \
        (session[fd]->rdata_size - session[fd]->rdata_pos)

#define RFIFOFLUSH(fd)                                          \
        do {                                                    \
                memmove(session[fd]->rdata,                     \
                        RFIFOP(fd,0), RFIFOREST(fd));           \
                session[fd]->rdata_size = RFIFOREST(fd);        \
                session[fd]->rdata_pos = 0;                     \
        } while (0)

#define RFIFOSPACE(fd) \
        (session[fd]->max_rdata - session[fd]->rdata_size)

#define RBUFP(p,pos) \
        (((unsigned char*)(p)) + (pos))

#define RBUFB(p,pos) \
        (*(unsigned char*)((p) + (pos)))

#define RBUFW(p,pos) \
        (*(unsigned short*)((p) + (pos)))

#define RBUFL(p,pos) \
        (*(unsigned int*)((p) + (pos)))

#define WFIFOSPACE(fd) \
        (session[fd]->max_wdata - session[fd]->wdata_size)

char WPACKETBUF[65536];

#define WPACKETP(pos) \
        (WPACKETBUF + (pos))

#define WPACKETB(pos) \
        (*(unsigned char*)(WPACKETBUF + (pos)))

#define WPACKETW(pos) \
        (*(unsigned short*)(WPACKETBUF + (pos)))

#define WPACKETL(pos) \
        (*(unsigned int*)(WPACKETBUF + (pos)))

#if 0 

#define SENDPACKET(fd,len)                                      \
        (memcpy(session[fd]->wdata + session[fd]->wdata_size,   \
                WFIFOBUF, len);                                 \
         session[fd]->wdata_size = session[fd]->wdata_size + (len);)

#define WFIFOP(fd,pos)                                          \
        (session[fd]->wdata + session[fd]->wdata_size + (pos))

#define WFIFOB(fd,pos)                                          \
        (*(unsigned char*)                                      \
         (session[fd]->wdata + session[fd]->wdata_size + (pos)))

#define WFIFOW(fd,pos)                                          \
        (*(unsigned short*)                                     \
         (session[fd]->wdata + session[fd]->wdata_size + (pos)))

#define WFIFOL(fd,pos)                                          \
        (*(unsigned int*)                                       \
         (session[fd]->wdata + session[fd]->wdata_size + (pos)))

#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)

#endif // 0

#define WBUFP(p,pos) \
        (((unsigned char*)(p)) + (pos))

#define WBUFB(p,pos) \
        (*(unsigned char*)((p) + (pos)))

#define WBUFW(p,pos) \
        (*(unsigned short*)((p) + (pos)))

#define WBUFL(p,pos) \
        (*(unsigned int*)((p) + (pos)))

#ifdef __INTERIX
#define FD_SETSIZE 4096
#endif // __INTERIX

/* Removed Cygwin FD_SETSIZE declarations, now are directly passed on to the compiler through Makefile [Valaris] */
/* Removed LCCWIN32 FD_SETSIZE declarations, must be passed directly to the compiler while compiling [MagicalTux] */

// Struct declaration

struct socket_data{
        unsigned char eof;                      
        unsigned char not_used_big_rdata;       
        unsigned char not_used_big_wdata;       
        char *rdata, *wdata;
        int max_rdata, max_wdata;
        int rdata_size, wdata_size;
        int rdata_pos;
        struct sockaddr_in client_addr;
        int (*func_recv)(int);
        int (*func_send)(int);
        int (*func_parse)(int);
        int (*func_console)(char*);
        void* session_data;
};

// Data prototype declaration

extern struct socket_data *session[FD_SETSIZE];

int fd_max;

extern char listen_ip[16]; // 15 + NULL

// Function prototype declaration

int make_listen_port(int);
int make_connection(long, int);
int delete_session(int);
int realloc_fifo(int fd, int rfifo_size, int wfifo_size);
void SENDPACKET(const int fd, const int len);
//int WFIFOSET(int fd, unsigned int len);
//int RFIFOSKIP(int fd, int len);
#ifdef HAVE_ARES_LIB
void set_proxy_dnsbl(const char *dnsbl);
#endif

void flush_fifos(void);
int do_sendrecv(int next);
int do_parsepacket(void);
void do_socket(void);

int start_console(int (*parse_console_func)(char*));

void set_defaultparse(int (*defaultparse)(int));

int Net_Init(void);

unsigned int addr_[16]; /* ip addresses of local host (host byte order) */
unsigned int naddr_; /* # of ip addresses */

#endif // OA_SOCKET_H

---