From a8f828a066773a59fdf646299359d35ae0e845af Mon Sep 17 00:00:00 2001 From: wyatt8740 Date: Mon, 6 Jan 2014 12:02:16 -0500 Subject: Removed accidental upload of copyrighted map files --- WinQuake/net_bw.c | 1526 ++++++++++++++++++++++++++--------------------------- 1 file changed, 763 insertions(+), 763 deletions(-) (limited to 'WinQuake/net_bw.c') diff --git a/WinQuake/net_bw.c b/WinQuake/net_bw.c index 2fb3e06..360a4ee 100644 --- a/WinQuake/net_bw.c +++ b/WinQuake/net_bw.c @@ -1,763 +1,763 @@ -/* -Copyright (C) 1996-1997 Id Software, Inc. - -This program is free software; you can redistribute it and/or -modify it under the terms of the GNU General Public License -as published by the Free Software Foundation; either version 2 -of the License, or (at your option) any later version. - -This program is distributed in the hope that it will be useful, -but WITHOUT ANY WARRANTY; without even the implied warranty of -MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. - -See the GNU General Public License for more details. - -You should have received a copy of the GNU General Public License -along with this program; if not, write to the Free Software -Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. - -*/ -// net_bw.c - -#include -#include -#include - -#include "quakedef.h" -#include "dosisms.h" - - -// this section is general Unix stuff that we need - -#define EIO 5 /* I/O error */ -#define EBADS 9 -#define EWOULDBLOCK 35 /* function would block */ -#define EMSGSIZE 40 /* message to big for buffers */ -#define EPROTONOSUPPORT 43 /* Protocol not supported */ -#define ESOCKTNOSUPPORT 44 /* Socket type not supported */ -#define EPFNOSUPPORT 46 /* Protocol family not supported */ -#define EAFNOSUPPORT 47 /* Address family not supported */ -#define ECONNABORTED 53 /* User requested hangup */ -#define ENOBUFS 55 /* No buffers available */ -#define EISCONN 56 /* Socket has closed */ -#define ENOTCONN 57 /* Socket is not connected */ -#define ESHUTDOWN 58 /* Socket is closed */ -#define ETOOMANYREFS 59 /* Too many sockets open */ -#define ETIMEDOUT 60 /* Connection timed out */ -#define ECONNREFUSED 61 /* Connection refused */ - -#define AF_INET 2 /* internet */ - -#define PF_INET AF_INET - -#define SOCK_STREAM 1 /* stream */ -#define SOCK_DGRAM 2 /* datagram */ - -#define IPPROTO_TCP 6 -#define IPPROTO_UDP 17 - -#define INADDR_ANY 0 - -#define SIOCDONE 0x7300 -#define FIONREAD 0x667f -#define FIONBIO 0x667e -#define FIONWIN 0x1000 -#define FIONTIN 0x2000 - -#define BRDINIT 0 -#define BRDADDR 10 - -#define MAXHOSTNAMELEN 256 - -#define SOL_SOCKET 0xffff /* options for socket level */ - -/* - * Option flags per-socket. - */ -#define SO_DEBUG 0x0001 /* turn on debugging info recording */ -#define SO_ACCEPTCONN 0x0002 /* socket has had listen() */ -#define SO_REUSEADDR 0x0004 /* allow local address reuse */ -#define SO_KEEPALIVE 0x0008 /* keep connections alive */ -#define SO_DONTROUTE 0x0010 /* just use interface addresses */ -#define SO_BROADCAST 0x0020 /* permit sending of broadcast msgs */ -#define SO_USELOOPBACK 0x0040 /* bypass hardware when possible */ -#define SO_LINGER 0x0080 /* linger on close if data present */ -#define SO_OOBINLINE 0x0100 /* leave received OOB data in line */ -#define SO_USEPRIV 0x4000 /* allocate from privileged port area */ -#define SO_CANTSIG 0x8000 /* prevent SIGPIPE on SS_CANTSENDMORE */ - -/* - * Additional options, not kept in so_options. - */ -#define SO_SNDBUF 0x1001 /* send buffer size */ -#define SO_RCVBUF 0x1002 /* receive buffer size */ -#define SO_SNDLOWAT 0x1003 /* send low-water mark */ -#define SO_RCVLOWAT 0x1004 /* receive low-water mark */ -#define SO_SNDTIMEO 0x1005 /* send timeout */ -#define SO_RCVTIMEO 0x1006 /* receive timeout */ -#define SO_ERROR 0x1007 /* get error status and clear */ -#define SO_TYPE 0x1008 /* get socket type */ - - -struct in_addr -{ - union - { - struct { unsigned char s_b1,s_b2,s_b3,s_b4; } S_un_b; - struct { unsigned short s_w1,s_w2; } S_un_w; - unsigned long S_addr; - } S_un; -}; -#define s_addr S_un.S_addr /* can be used for most tcp & ip code */ -#define s_host S_un.S_un_b.s_b2 /* host on imp */ -#define s_net S_un.S_un_b.s_b1 /* network */ -#define s_imp S_un.S_un_w.s_w2 /* imp */ -#define s_impno S_un.S_un_b.s_b4 /* imp # */ -#define s_lh S_un.S_un_b.s_b3 /* logical host */ - -struct sockaddr_in -{ - short sin_family; - unsigned short sin_port; - struct in_addr sin_addr; - char sin_zero[8]; -}; - -struct hostent { - char *h_name; /* official name of host */ - char **h_aliases; /* alias list */ - int h_addrtype; /* host address type */ - int h_length; /* length of address */ - char **h_addr_list; /* list of addresses from name server */ -#define h_addr h_addr_list[0] /* address, for backward compatiblity */ -}; - -char *inet_ntoa(struct in_addr in); - - -// this section is B&W specific constants & structures - -#define BW_IOCTL_BIND 0 -#define BW_IOCTL_CLEAROPTIONS 5 -#define BW_IOCTL_SETOPTIONS 6 -#define BW_IOCTL_PEEK 7 -#define BW_IOCTL_SETWINMASK 8 - -#define BW_OPTION_BLOCKING 0x01 -#define BW_OPTION_REUSEBUFFERS 0x80 - -#define BW_ERR_USR_HANGUP 50 -#define BW_ERR_HANGUP 51 -#define BW_ERR_NET_ERR 52 -#define BW_ERR_IS_CLOSED 53 -#define BW_ERR_TIME_OUT 54 -#define BW_ERR_RESET 55 -#define BW_ERR_FULL 56 -#define BW_ERR_BLOCK 57 -#define BW_ERR_SHUTDOWN 58 - -#pragma pack(1) - -typedef struct -{ - char state; // always 1 - short localPort; - struct in_addr localAddr; - char reason; // always 0 - char options; - short dataAvailable; -} BW_UDPinfo_t; - -typedef struct -{ - char reserved1 [6]; - unsigned short info2Offset; - char reserved2 [18]; - struct in_addr remoteAddr; -} BW_UDPreadInfo1_t; - -typedef struct -{ - short remotePort; - char reserved1 [2]; - unsigned short dataLenPlus8; - char reserved2 [2]; - char data[1]; // actual size is - 8 -} BW_UDPreadInfo2_t; - -typedef struct -{ - char reserved1 [2]; - short remotePort; - unsigned short dataLen; - struct in_addr remoteAddr; - char reserved2 [42]; - char data[1]; // actual size is -} BW_writeInfo_t; - -typedef struct -{ - short ioport; - byte dma; - byte vector; - byte irq; - short bufferSize; - short maxWindow; - short timeZone; - byte myType; - int inetAddr; - short value; - byte subnetMask; - short etherPointer; - short logserverPointer; - short nameserverPointer; - short printserverPointer; - short timeserverPointer; - short gatewayPointer; - short driverSegment; - byte transferSize; - char cardName [9]; -} BW_ethdevinfo_t; - -#pragma pack() - -#define LOWMEM_SIZE 4096 - -static unsigned char *lowmem_buffer; -static int lowmem_bufseg; -static int lowmem_bufoff; -static BW_ethdevinfo_t ethdevinfo; -static int netmask; -static struct in_addr bcastaddr; - -extern regs_t regs; - -static int net_acceptsocket = -1; // socket for fielding new connections -static int net_controlsocket = 0; - -#include "net_bw.h" - -//============================================================================= - -static int BW_ioctl(int s, char *msg, int msglen) -{ - Q_memcpy(lowmem_buffer, msg, msglen); - - regs.x.ax = 0x4403; - regs.x.bx = s; - regs.x.cx = msglen; - regs.x.dx = lowmem_bufoff; - regs.x.ds = lowmem_bufseg; - if (dos_int86(0x21)) - return regs.x.ax; - return 0; -} - -//============================================================================= - -static int BW_TranslateError(int error) -{ - switch(error) - { - case BW_ERR_USR_HANGUP: return ECONNABORTED; - case BW_ERR_HANGUP: return EISCONN; - case BW_ERR_NET_ERR: return ENOTCONN; - case BW_ERR_IS_CLOSED: return ENOTCONN; - case BW_ERR_TIME_OUT: return ETIMEDOUT; - case BW_ERR_RESET: return ECONNREFUSED; - case BW_ERR_FULL: return ETOOMANYREFS; - case BW_ERR_BLOCK: return EWOULDBLOCK; - case BW_ERR_SHUTDOWN: return ESHUTDOWN; - } - return EIO; -} - -//============================================================================= - -static int GetEthdevinfo(void) -{ - int fd; - - Q_strcpy((char *)lowmem_buffer, "ETHDEV27"); - regs.x.ax = 0x3d42; - regs.x.ds = lowmem_bufseg; - regs.x.dx = lowmem_bufoff; - if (dos_int86(0x21)) - return -1; - fd = regs.x.ax; - - regs.x.ax = 0x4401; - regs.x.bx = fd; - regs.x.dx = 0x60; - dos_int86(0x21); - - regs.h.ah = 0x3f; - regs.x.cx = sizeof(ethdevinfo); - regs.x.es = regs.x.ds = lowmem_bufseg; - regs.x.dx = lowmem_bufoff; - regs.x.bx = fd; - if (dos_int86(0x21)) - return -1; - Q_memcpy(ðdevinfo, lowmem_buffer, regs.x.ax); - - regs.h.ah = 0x3e; - regs.x.bx = fd; - dos_int86(0x21); - - return 0; -} - -//============================================================================= - -int BW_Init(void) -{ - struct qsockaddr addr; - char *colon; - - if (COM_CheckParm ("-noudp")) - return -1; - - lowmem_buffer = dos_getmemory(LOWMEM_SIZE); - if (!lowmem_buffer) - Sys_Error("not enough low memory\n"); - lowmem_bufoff = ptr2real(lowmem_buffer) & 0xf; - lowmem_bufseg = ptr2real(lowmem_buffer) >> 4; - - if (GetEthdevinfo()) - { - Con_DPrintf("Beame & Whiteside TCP/IP not detected\n"); - dos_freememory(lowmem_buffer); - return -1; - } - netmask = 0xffffffff >> (32 - ethdevinfo.subnetMask); - bcastaddr.s_addr = (ethdevinfo.inetAddr & netmask) | (~netmask); - - if ((net_controlsocket = BW_OpenSocket (0)) == -1) - { - dos_freememory(lowmem_buffer); - Con_DPrintf ("BW_Init unable to open control socket; disabled\n"); - return -1; - } - - BW_GetSocketAddr (net_controlsocket, &addr); - Q_strcpy(my_tcpip_address, BW_AddrToString (&addr)); - colon = Q_strrchr (my_tcpip_address, ':'); - if (colon) - *colon = 0; - - Con_Printf("BW_Init: UDP initialized\n"); - tcpipAvailable = true; - - return net_controlsocket; -} - -//============================================================================= - -void BW_Shutdown(void) -{ - BW_Listen (false); - BW_CloseSocket (net_controlsocket); - dos_freememory(lowmem_buffer); -} - -//============================================================================= - -void BW_Listen (qboolean state) -{ - // enable listening - if (state) - { - if (net_acceptsocket != -1) - return; - if ((net_acceptsocket = BW_OpenSocket (net_hostport)) == -1) - Sys_Error ("BW_Listen: Unable to open accept socket\n"); - return; - } - - // disable listening - if (net_acceptsocket == -1) - return; - BW_CloseSocket (net_acceptsocket); - net_acceptsocket = -1; -} - - -//============================================================================= - -/* -OpenSocket returns a handle to a network socket that has been opened, -set to nonblocking, and bound to . Additional socket options -should be set here if they are needed. -1 is returned on failure. -*/ - -int BW_OpenSocket(int port) -{ - int s; - int ret; - int deadman = 3 * 1024; - static int dynamic = 1024; - static char reuse_msg[2] = {BW_IOCTL_SETOPTIONS, BW_OPTION_REUSEBUFFERS}; - static char bind_msg[3] = {BW_IOCTL_BIND, 0, 0}; - static char nonblock_msg[2] = {BW_IOCTL_CLEAROPTIONS, BW_OPTION_BLOCKING}; - - // allocate a UDP socket - Q_strcpy((char *)lowmem_buffer, "UDP-IP10"); - regs.x.ax = 0x3d42; - regs.x.ds = lowmem_bufseg; - regs.x.dx = lowmem_bufoff; - if (dos_int86(0x21)) - { - Con_Printf("BW_OpenSocket failed: %u\n", BW_TranslateError(regs.x.ax)); - return -1; - } - s = regs.x.ax; - - // set file descriptor to raw mode - regs.x.ax = 0x4401; - regs.x.bx = s; - regs.x.dx = 0x60; - dos_int86(0x21); - - if (BW_ioctl(s, reuse_msg, 2)) - { - Con_Printf("BW_OpenSocket ioctl(reuse) failed\n"); - return -1; - } - - if (BW_ioctl(s, nonblock_msg, 2)) - { - Con_Printf("BW_OpenSocket ioctl(nonblocking) failed\n"); - return -1; - } - - // if a socket was specified, bind to it and return - if (port) - { - *(short *)&bind_msg[1] = port; - if (BW_ioctl(s, bind_msg, 3)) - { - BW_CloseSocket(s); - return -1; - } - return s; - } - - // B&W does NOT do dynamic allocation, so if port == 0 we must fake it - do - { - port = dynamic++; - if (dynamic == 4096) - dynamic = 1024; - deadman--; - *(short *)&bind_msg[1] = port; - ret = BW_ioctl(s, bind_msg, 3); - } - while (ret && deadman); - if (ret) - return -1; - return s; -} - -//============================================================================= - -int BW_CloseSocket(int socket) -{ - regs.h.ah = 0x3e; - regs.x.bx = socket; - if(dos_int86(0x21)) - { - Con_Printf("BW_CloseSocket %u failed: %u\n", socket, BW_TranslateError(regs.x.ax)); - return -1; - } - return 0; -} - -//============================================================================= - -int BW_Connect (int socket, struct qsockaddr *hostaddr) -{ - return 0; -} - -//============================================================================= - -int BW_CheckNewConnections(void) -{ - if (net_acceptsocket == 0) - return -1; - - // see if there's anything waiting - regs.x.ax = 0x4406; - regs.x.bx = net_acceptsocket; - dos_int86(0x21); - if (regs.x.ax == 0) - return -1; - return net_acceptsocket; -} - -//============================================================================= - -int BW_Read(int s, byte *buf, int len, struct qsockaddr *from) -{ - BW_UDPreadInfo1_t *info1; - BW_UDPreadInfo2_t *info2; - - // ask if there's anything waiting - regs.x.ax = 0x4406; - regs.x.bx = s; - dos_int86(0x21); - if (regs.x.ax == 0) - return 0; - - // there was, so let's get it - regs.h.ah = 0x3f; - regs.x.cx = /* len + 53 */ LOWMEM_SIZE; - regs.x.es = regs.x.ds = lowmem_bufseg; - regs.x.dx = lowmem_bufoff; - regs.x.bx = s; - if (dos_int86(0x21)) - { - Con_Printf("BW UDP read error: %u\n", BW_TranslateError(regs.x.ax)); - return -1; - } - - info1 = (BW_UDPreadInfo1_t *)lowmem_buffer; - info2 = (BW_UDPreadInfo2_t *)(lowmem_buffer + info1->info2Offset); - - if (from) - { - from->sa_family = AF_INET; - ((struct sockaddr_in *)from)->sin_addr = info1->remoteAddr; - ((struct sockaddr_in *)from)->sin_port = htons(info2->remotePort); - } - - len = info2->dataLenPlus8 - 8; - if (len > NET_DATAGRAMSIZE) - { - Con_Printf("BW UDP read packet too large: %u\n", len); - return -1; - } - Q_memcpy(buf, info2->data, len); - - return len; -} - -//============================================================================= - -int BW_Broadcast(int s, byte *msg, int len) -{ - BW_writeInfo_t *writeInfo; - - // ask if we're clear to send - regs.x.ax = 0x4407; - regs.x.bx = s; - dos_int86(0x21); - if (regs.x.ax == 0) - return 0; - - // yes, let's do it - writeInfo = (BW_writeInfo_t *)lowmem_buffer; - writeInfo->remoteAddr = bcastaddr; - writeInfo->remotePort = net_hostport; - writeInfo->dataLen = len; - if (len > NET_DATAGRAMSIZE) - Sys_Error("BW UDP write packet too large: %u\n", len); - Q_memcpy(writeInfo->data, msg, len); - writeInfo->data[len] = 0; - regs.h.ah = 0x40; - regs.x.bx = s; - regs.x.cx = len + sizeof(BW_writeInfo_t); - regs.x.es = regs.x.ds = lowmem_bufseg; - regs.x.dx = lowmem_bufoff; - if (dos_int86(0x21)) - { - Con_Printf("BW_Broadcast failed: %u\n", BW_TranslateError(regs.x.ax)); - return -1; - } - - return len; -} - -//============================================================================= - -int BW_Write(int s, byte *msg, int len, struct qsockaddr *to) -{ - BW_writeInfo_t *writeInfo; - - // ask if we're clear to send - regs.x.ax = 0x4407; - regs.x.bx = s; - dos_int86(0x21); - if (regs.x.ax == 0) - return 0; - - // yes, let's do it - writeInfo = (BW_writeInfo_t *)lowmem_buffer; - writeInfo->remoteAddr = ((struct sockaddr_in *)to)->sin_addr; - writeInfo->remotePort = ntohs(((struct sockaddr_in *)to)->sin_port); - writeInfo->dataLen = len; - if (len > NET_DATAGRAMSIZE) - Sys_Error("BW UDP write packet too large: %u\n", len); - Q_memcpy(writeInfo->data, msg, len); - writeInfo->data[len] = 0; - regs.h.ah = 0x40; - regs.x.bx = s; - regs.x.cx = len + sizeof(BW_writeInfo_t); - regs.x.es = regs.x.ds = lowmem_bufseg; - regs.x.dx = lowmem_bufoff; - if (dos_int86(0x21)) - { - Con_Printf("BW_Write failed: %u\n", BW_TranslateError(regs.x.ax)); - return -1; - } - - return len; -} - -//============================================================================= - - -char *BW_AddrToString (struct qsockaddr *addr) -{ - static char buffer[22]; - - sprintf(buffer, "%d.%d.%d.%d:%d", - ((struct sockaddr_in *)addr)->sin_addr.s_net, - ((struct sockaddr_in *)addr)->sin_addr.s_host, - ((struct sockaddr_in *)addr)->sin_addr.s_lh, - ((struct sockaddr_in *)addr)->sin_addr.s_impno, - ntohs(((struct sockaddr_in *)addr)->sin_port) - ); - return buffer; -} - -//============================================================================= - -int BW_StringToAddr (char *string, struct qsockaddr *addr) -{ - int ha1, ha2, ha3, ha4, hp; - int ipaddr; - - sscanf(string, "%d.%d.%d.%d:%d", &ha1, &ha2, &ha3, &ha4, &hp); - ipaddr = (ha1 << 24) | (ha2 << 16) | (ha3 << 8) | ha4; - - addr->sa_family = AF_INET; - ((struct sockaddr_in *)addr)->sin_addr.s_addr = htonl(ipaddr); - ((struct sockaddr_in *)addr)->sin_port = htons((short)hp); - return 0; -} - -//============================================================================= - -int BW_GetSocketAddr (int socket, struct qsockaddr *addr) -{ - regs.x.ax = 0x4402; - regs.x.bx = socket; - regs.x.cx = sizeof(BW_UDPinfo_t); - regs.x.dx = lowmem_bufoff; - regs.x.ds = lowmem_bufseg; - dos_int86(0x21); - - addr->sa_family = AF_INET; - ((struct sockaddr_in *)addr)->sin_addr.s_addr = ((BW_UDPinfo_t *)lowmem_buffer)->localAddr.s_addr; - ((struct sockaddr_in *)addr)->sin_port = htons(((BW_UDPinfo_t *)lowmem_buffer)->localPort); - - return 0; -} - -//============================================================================= - -int BW_GetNameFromAddr (struct qsockaddr *addr, char *name) -{ - Q_strcpy(name, BW_AddrToString(addr)); - return 0; -} - -///============================================================================= - -int BW_GetAddrFromName (char *name, struct qsockaddr *hostaddr) -{ - char buff[MAXHOSTNAMELEN]; - char *b; - int addr; - int num; - int mask; - int run; - int port; - - if (name[0] < '0' || name[0] > '9') - return -1; - - buff[0] = '.'; - b = buff; - Q_strcpy(buff+1, name); - if (buff[1] == '.') - b++; - - addr = 0; - mask = -1; - while (*b == '.') - { - b++; - num = 0; - run = 0; - while (!( *b < '0' || *b > '9')) - { - num = num*10 + *b++ - '0'; - if (++run > 3) - return -1; - } - if ((*b < '0' || *b > '9') && *b != '.' && *b != ':' && *b != 0) - return -1; - if (num < 0 || num > 255) - return -1; - mask<<=8; - addr = (addr<<8) + num; - } - addr = htonl(addr); - mask = htonl(mask); - - if (*b++ == ':') - port = Q_atoi(b); - else - port = net_hostport; - - hostaddr->sa_family = AF_INET; - ((struct sockaddr_in *)hostaddr)->sin_port = htons((short)port); - ((struct sockaddr_in *)hostaddr)->sin_addr.s_addr = - ((ethdevinfo.inetAddr & mask) | addr); - - return 0; -} - -//============================================================================= - -int BW_AddrCompare (struct qsockaddr *addr1, struct qsockaddr *addr2) -{ - if (addr1->sa_family != addr2->sa_family) - return -1; - - if (((struct sockaddr_in *)addr1)->sin_addr.s_addr != ((struct sockaddr_in *)addr2)->sin_addr.s_addr) - return -1; - - if (((struct sockaddr_in *)addr1)->sin_port != ((struct sockaddr_in *)addr2)->sin_port) - return 1; - - return 0; -} - -//============================================================================= - -int BW_GetSocketPort (struct qsockaddr *addr) -{ - return ntohs(((struct sockaddr_in *)addr)->sin_port); -} - - -int BW_SetSocketPort (struct qsockaddr *addr, int port) -{ - ((struct sockaddr_in *)addr)->sin_port = htons(port); - return 0; -} - -//============================================================================= +/* +Copyright (C) 1996-1997 Id Software, Inc. + +This program is free software; you can redistribute it and/or +modify it under the terms of the GNU General Public License +as published by the Free Software Foundation; either version 2 +of the License, or (at your option) any later version. + +This program is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. + +See the GNU General Public License for more details. + +You should have received a copy of the GNU General Public License +along with this program; if not, write to the Free Software +Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. + +*/ +// net_bw.c + +#include +#include +#include + +#include "quakedef.h" +#include "dosisms.h" + + +// this section is general Unix stuff that we need + +#define EIO 5 /* I/O error */ +#define EBADS 9 +#define EWOULDBLOCK 35 /* function would block */ +#define EMSGSIZE 40 /* message to big for buffers */ +#define EPROTONOSUPPORT 43 /* Protocol not supported */ +#define ESOCKTNOSUPPORT 44 /* Socket type not supported */ +#define EPFNOSUPPORT 46 /* Protocol family not supported */ +#define EAFNOSUPPORT 47 /* Address family not supported */ +#define ECONNABORTED 53 /* User requested hangup */ +#define ENOBUFS 55 /* No buffers available */ +#define EISCONN 56 /* Socket has closed */ +#define ENOTCONN 57 /* Socket is not connected */ +#define ESHUTDOWN 58 /* Socket is closed */ +#define ETOOMANYREFS 59 /* Too many sockets open */ +#define ETIMEDOUT 60 /* Connection timed out */ +#define ECONNREFUSED 61 /* Connection refused */ + +#define AF_INET 2 /* internet */ + +#define PF_INET AF_INET + +#define SOCK_STREAM 1 /* stream */ +#define SOCK_DGRAM 2 /* datagram */ + +#define IPPROTO_TCP 6 +#define IPPROTO_UDP 17 + +#define INADDR_ANY 0 + +#define SIOCDONE 0x7300 +#define FIONREAD 0x667f +#define FIONBIO 0x667e +#define FIONWIN 0x1000 +#define FIONTIN 0x2000 + +#define BRDINIT 0 +#define BRDADDR 10 + +#define MAXHOSTNAMELEN 256 + +#define SOL_SOCKET 0xffff /* options for socket level */ + +/* + * Option flags per-socket. + */ +#define SO_DEBUG 0x0001 /* turn on debugging info recording */ +#define SO_ACCEPTCONN 0x0002 /* socket has had listen() */ +#define SO_REUSEADDR 0x0004 /* allow local address reuse */ +#define SO_KEEPALIVE 0x0008 /* keep connections alive */ +#define SO_DONTROUTE 0x0010 /* just use interface addresses */ +#define SO_BROADCAST 0x0020 /* permit sending of broadcast msgs */ +#define SO_USELOOPBACK 0x0040 /* bypass hardware when possible */ +#define SO_LINGER 0x0080 /* linger on close if data present */ +#define SO_OOBINLINE 0x0100 /* leave received OOB data in line */ +#define SO_USEPRIV 0x4000 /* allocate from privileged port area */ +#define SO_CANTSIG 0x8000 /* prevent SIGPIPE on SS_CANTSENDMORE */ + +/* + * Additional options, not kept in so_options. + */ +#define SO_SNDBUF 0x1001 /* send buffer size */ +#define SO_RCVBUF 0x1002 /* receive buffer size */ +#define SO_SNDLOWAT 0x1003 /* send low-water mark */ +#define SO_RCVLOWAT 0x1004 /* receive low-water mark */ +#define SO_SNDTIMEO 0x1005 /* send timeout */ +#define SO_RCVTIMEO 0x1006 /* receive timeout */ +#define SO_ERROR 0x1007 /* get error status and clear */ +#define SO_TYPE 0x1008 /* get socket type */ + + +struct in_addr +{ + union + { + struct { unsigned char s_b1,s_b2,s_b3,s_b4; } S_un_b; + struct { unsigned short s_w1,s_w2; } S_un_w; + unsigned long S_addr; + } S_un; +}; +#define s_addr S_un.S_addr /* can be used for most tcp & ip code */ +#define s_host S_un.S_un_b.s_b2 /* host on imp */ +#define s_net S_un.S_un_b.s_b1 /* network */ +#define s_imp S_un.S_un_w.s_w2 /* imp */ +#define s_impno S_un.S_un_b.s_b4 /* imp # */ +#define s_lh S_un.S_un_b.s_b3 /* logical host */ + +struct sockaddr_in +{ + short sin_family; + unsigned short sin_port; + struct in_addr sin_addr; + char sin_zero[8]; +}; + +struct hostent { + char *h_name; /* official name of host */ + char **h_aliases; /* alias list */ + int h_addrtype; /* host address type */ + int h_length; /* length of address */ + char **h_addr_list; /* list of addresses from name server */ +#define h_addr h_addr_list[0] /* address, for backward compatiblity */ +}; + +char *inet_ntoa(struct in_addr in); + + +// this section is B&W specific constants & structures + +#define BW_IOCTL_BIND 0 +#define BW_IOCTL_CLEAROPTIONS 5 +#define BW_IOCTL_SETOPTIONS 6 +#define BW_IOCTL_PEEK 7 +#define BW_IOCTL_SETWINMASK 8 + +#define BW_OPTION_BLOCKING 0x01 +#define BW_OPTION_REUSEBUFFERS 0x80 + +#define BW_ERR_USR_HANGUP 50 +#define BW_ERR_HANGUP 51 +#define BW_ERR_NET_ERR 52 +#define BW_ERR_IS_CLOSED 53 +#define BW_ERR_TIME_OUT 54 +#define BW_ERR_RESET 55 +#define BW_ERR_FULL 56 +#define BW_ERR_BLOCK 57 +#define BW_ERR_SHUTDOWN 58 + +#pragma pack(1) + +typedef struct +{ + char state; // always 1 + short localPort; + struct in_addr localAddr; + char reason; // always 0 + char options; + short dataAvailable; +} BW_UDPinfo_t; + +typedef struct +{ + char reserved1 [6]; + unsigned short info2Offset; + char reserved2 [18]; + struct in_addr remoteAddr; +} BW_UDPreadInfo1_t; + +typedef struct +{ + short remotePort; + char reserved1 [2]; + unsigned short dataLenPlus8; + char reserved2 [2]; + char data[1]; // actual size is - 8 +} BW_UDPreadInfo2_t; + +typedef struct +{ + char reserved1 [2]; + short remotePort; + unsigned short dataLen; + struct in_addr remoteAddr; + char reserved2 [42]; + char data[1]; // actual size is +} BW_writeInfo_t; + +typedef struct +{ + short ioport; + byte dma; + byte vector; + byte irq; + short bufferSize; + short maxWindow; + short timeZone; + byte myType; + int inetAddr; + short value; + byte subnetMask; + short etherPointer; + short logserverPointer; + short nameserverPointer; + short printserverPointer; + short timeserverPointer; + short gatewayPointer; + short driverSegment; + byte transferSize; + char cardName [9]; +} BW_ethdevinfo_t; + +#pragma pack() + +#define LOWMEM_SIZE 4096 + +static unsigned char *lowmem_buffer; +static int lowmem_bufseg; +static int lowmem_bufoff; +static BW_ethdevinfo_t ethdevinfo; +static int netmask; +static struct in_addr bcastaddr; + +extern regs_t regs; + +static int net_acceptsocket = -1; // socket for fielding new connections +static int net_controlsocket = 0; + +#include "net_bw.h" + +//============================================================================= + +static int BW_ioctl(int s, char *msg, int msglen) +{ + Q_memcpy(lowmem_buffer, msg, msglen); + + regs.x.ax = 0x4403; + regs.x.bx = s; + regs.x.cx = msglen; + regs.x.dx = lowmem_bufoff; + regs.x.ds = lowmem_bufseg; + if (dos_int86(0x21)) + return regs.x.ax; + return 0; +} + +//============================================================================= + +static int BW_TranslateError(int error) +{ + switch(error) + { + case BW_ERR_USR_HANGUP: return ECONNABORTED; + case BW_ERR_HANGUP: return EISCONN; + case BW_ERR_NET_ERR: return ENOTCONN; + case BW_ERR_IS_CLOSED: return ENOTCONN; + case BW_ERR_TIME_OUT: return ETIMEDOUT; + case BW_ERR_RESET: return ECONNREFUSED; + case BW_ERR_FULL: return ETOOMANYREFS; + case BW_ERR_BLOCK: return EWOULDBLOCK; + case BW_ERR_SHUTDOWN: return ESHUTDOWN; + } + return EIO; +} + +//============================================================================= + +static int GetEthdevinfo(void) +{ + int fd; + + Q_strcpy((char *)lowmem_buffer, "ETHDEV27"); + regs.x.ax = 0x3d42; + regs.x.ds = lowmem_bufseg; + regs.x.dx = lowmem_bufoff; + if (dos_int86(0x21)) + return -1; + fd = regs.x.ax; + + regs.x.ax = 0x4401; + regs.x.bx = fd; + regs.x.dx = 0x60; + dos_int86(0x21); + + regs.h.ah = 0x3f; + regs.x.cx = sizeof(ethdevinfo); + regs.x.es = regs.x.ds = lowmem_bufseg; + regs.x.dx = lowmem_bufoff; + regs.x.bx = fd; + if (dos_int86(0x21)) + return -1; + Q_memcpy(ðdevinfo, lowmem_buffer, regs.x.ax); + + regs.h.ah = 0x3e; + regs.x.bx = fd; + dos_int86(0x21); + + return 0; +} + +//============================================================================= + +int BW_Init(void) +{ + struct qsockaddr addr; + char *colon; + + if (COM_CheckParm ("-noudp")) + return -1; + + lowmem_buffer = dos_getmemory(LOWMEM_SIZE); + if (!lowmem_buffer) + Sys_Error("not enough low memory\n"); + lowmem_bufoff = ptr2real(lowmem_buffer) & 0xf; + lowmem_bufseg = ptr2real(lowmem_buffer) >> 4; + + if (GetEthdevinfo()) + { + Con_DPrintf("Beame & Whiteside TCP/IP not detected\n"); + dos_freememory(lowmem_buffer); + return -1; + } + netmask = 0xffffffff >> (32 - ethdevinfo.subnetMask); + bcastaddr.s_addr = (ethdevinfo.inetAddr & netmask) | (~netmask); + + if ((net_controlsocket = BW_OpenSocket (0)) == -1) + { + dos_freememory(lowmem_buffer); + Con_DPrintf ("BW_Init unable to open control socket; disabled\n"); + return -1; + } + + BW_GetSocketAddr (net_controlsocket, &addr); + Q_strcpy(my_tcpip_address, BW_AddrToString (&addr)); + colon = Q_strrchr (my_tcpip_address, ':'); + if (colon) + *colon = 0; + + Con_Printf("BW_Init: UDP initialized\n"); + tcpipAvailable = true; + + return net_controlsocket; +} + +//============================================================================= + +void BW_Shutdown(void) +{ + BW_Listen (false); + BW_CloseSocket (net_controlsocket); + dos_freememory(lowmem_buffer); +} + +//============================================================================= + +void BW_Listen (qboolean state) +{ + // enable listening + if (state) + { + if (net_acceptsocket != -1) + return; + if ((net_acceptsocket = BW_OpenSocket (net_hostport)) == -1) + Sys_Error ("BW_Listen: Unable to open accept socket\n"); + return; + } + + // disable listening + if (net_acceptsocket == -1) + return; + BW_CloseSocket (net_acceptsocket); + net_acceptsocket = -1; +} + + +//============================================================================= + +/* +OpenSocket returns a handle to a network socket that has been opened, +set to nonblocking, and bound to . Additional socket options +should be set here if they are needed. -1 is returned on failure. +*/ + +int BW_OpenSocket(int port) +{ + int s; + int ret; + int deadman = 3 * 1024; + static int dynamic = 1024; + static char reuse_msg[2] = {BW_IOCTL_SETOPTIONS, BW_OPTION_REUSEBUFFERS}; + static char bind_msg[3] = {BW_IOCTL_BIND, 0, 0}; + static char nonblock_msg[2] = {BW_IOCTL_CLEAROPTIONS, BW_OPTION_BLOCKING}; + + // allocate a UDP socket + Q_strcpy((char *)lowmem_buffer, "UDP-IP10"); + regs.x.ax = 0x3d42; + regs.x.ds = lowmem_bufseg; + regs.x.dx = lowmem_bufoff; + if (dos_int86(0x21)) + { + Con_Printf("BW_OpenSocket failed: %u\n", BW_TranslateError(regs.x.ax)); + return -1; + } + s = regs.x.ax; + + // set file descriptor to raw mode + regs.x.ax = 0x4401; + regs.x.bx = s; + regs.x.dx = 0x60; + dos_int86(0x21); + + if (BW_ioctl(s, reuse_msg, 2)) + { + Con_Printf("BW_OpenSocket ioctl(reuse) failed\n"); + return -1; + } + + if (BW_ioctl(s, nonblock_msg, 2)) + { + Con_Printf("BW_OpenSocket ioctl(nonblocking) failed\n"); + return -1; + } + + // if a socket was specified, bind to it and return + if (port) + { + *(short *)&bind_msg[1] = port; + if (BW_ioctl(s, bind_msg, 3)) + { + BW_CloseSocket(s); + return -1; + } + return s; + } + + // B&W does NOT do dynamic allocation, so if port == 0 we must fake it + do + { + port = dynamic++; + if (dynamic == 4096) + dynamic = 1024; + deadman--; + *(short *)&bind_msg[1] = port; + ret = BW_ioctl(s, bind_msg, 3); + } + while (ret && deadman); + if (ret) + return -1; + return s; +} + +//============================================================================= + +int BW_CloseSocket(int socket) +{ + regs.h.ah = 0x3e; + regs.x.bx = socket; + if(dos_int86(0x21)) + { + Con_Printf("BW_CloseSocket %u failed: %u\n", socket, BW_TranslateError(regs.x.ax)); + return -1; + } + return 0; +} + +//============================================================================= + +int BW_Connect (int socket, struct qsockaddr *hostaddr) +{ + return 0; +} + +//============================================================================= + +int BW_CheckNewConnections(void) +{ + if (net_acceptsocket == 0) + return -1; + + // see if there's anything waiting + regs.x.ax = 0x4406; + regs.x.bx = net_acceptsocket; + dos_int86(0x21); + if (regs.x.ax == 0) + return -1; + return net_acceptsocket; +} + +//============================================================================= + +int BW_Read(int s, byte *buf, int len, struct qsockaddr *from) +{ + BW_UDPreadInfo1_t *info1; + BW_UDPreadInfo2_t *info2; + + // ask if there's anything waiting + regs.x.ax = 0x4406; + regs.x.bx = s; + dos_int86(0x21); + if (regs.x.ax == 0) + return 0; + + // there was, so let's get it + regs.h.ah = 0x3f; + regs.x.cx = /* len + 53 */ LOWMEM_SIZE; + regs.x.es = regs.x.ds = lowmem_bufseg; + regs.x.dx = lowmem_bufoff; + regs.x.bx = s; + if (dos_int86(0x21)) + { + Con_Printf("BW UDP read error: %u\n", BW_TranslateError(regs.x.ax)); + return -1; + } + + info1 = (BW_UDPreadInfo1_t *)lowmem_buffer; + info2 = (BW_UDPreadInfo2_t *)(lowmem_buffer + info1->info2Offset); + + if (from) + { + from->sa_family = AF_INET; + ((struct sockaddr_in *)from)->sin_addr = info1->remoteAddr; + ((struct sockaddr_in *)from)->sin_port = htons(info2->remotePort); + } + + len = info2->dataLenPlus8 - 8; + if (len > NET_DATAGRAMSIZE) + { + Con_Printf("BW UDP read packet too large: %u\n", len); + return -1; + } + Q_memcpy(buf, info2->data, len); + + return len; +} + +//============================================================================= + +int BW_Broadcast(int s, byte *msg, int len) +{ + BW_writeInfo_t *writeInfo; + + // ask if we're clear to send + regs.x.ax = 0x4407; + regs.x.bx = s; + dos_int86(0x21); + if (regs.x.ax == 0) + return 0; + + // yes, let's do it + writeInfo = (BW_writeInfo_t *)lowmem_buffer; + writeInfo->remoteAddr = bcastaddr; + writeInfo->remotePort = net_hostport; + writeInfo->dataLen = len; + if (len > NET_DATAGRAMSIZE) + Sys_Error("BW UDP write packet too large: %u\n", len); + Q_memcpy(writeInfo->data, msg, len); + writeInfo->data[len] = 0; + regs.h.ah = 0x40; + regs.x.bx = s; + regs.x.cx = len + sizeof(BW_writeInfo_t); + regs.x.es = regs.x.ds = lowmem_bufseg; + regs.x.dx = lowmem_bufoff; + if (dos_int86(0x21)) + { + Con_Printf("BW_Broadcast failed: %u\n", BW_TranslateError(regs.x.ax)); + return -1; + } + + return len; +} + +//============================================================================= + +int BW_Write(int s, byte *msg, int len, struct qsockaddr *to) +{ + BW_writeInfo_t *writeInfo; + + // ask if we're clear to send + regs.x.ax = 0x4407; + regs.x.bx = s; + dos_int86(0x21); + if (regs.x.ax == 0) + return 0; + + // yes, let's do it + writeInfo = (BW_writeInfo_t *)lowmem_buffer; + writeInfo->remoteAddr = ((struct sockaddr_in *)to)->sin_addr; + writeInfo->remotePort = ntohs(((struct sockaddr_in *)to)->sin_port); + writeInfo->dataLen = len; + if (len > NET_DATAGRAMSIZE) + Sys_Error("BW UDP write packet too large: %u\n", len); + Q_memcpy(writeInfo->data, msg, len); + writeInfo->data[len] = 0; + regs.h.ah = 0x40; + regs.x.bx = s; + regs.x.cx = len + sizeof(BW_writeInfo_t); + regs.x.es = regs.x.ds = lowmem_bufseg; + regs.x.dx = lowmem_bufoff; + if (dos_int86(0x21)) + { + Con_Printf("BW_Write failed: %u\n", BW_TranslateError(regs.x.ax)); + return -1; + } + + return len; +} + +//============================================================================= + + +char *BW_AddrToString (struct qsockaddr *addr) +{ + static char buffer[22]; + + sprintf(buffer, "%d.%d.%d.%d:%d", + ((struct sockaddr_in *)addr)->sin_addr.s_net, + ((struct sockaddr_in *)addr)->sin_addr.s_host, + ((struct sockaddr_in *)addr)->sin_addr.s_lh, + ((struct sockaddr_in *)addr)->sin_addr.s_impno, + ntohs(((struct sockaddr_in *)addr)->sin_port) + ); + return buffer; +} + +//============================================================================= + +int BW_StringToAddr (char *string, struct qsockaddr *addr) +{ + int ha1, ha2, ha3, ha4, hp; + int ipaddr; + + sscanf(string, "%d.%d.%d.%d:%d", &ha1, &ha2, &ha3, &ha4, &hp); + ipaddr = (ha1 << 24) | (ha2 << 16) | (ha3 << 8) | ha4; + + addr->sa_family = AF_INET; + ((struct sockaddr_in *)addr)->sin_addr.s_addr = htonl(ipaddr); + ((struct sockaddr_in *)addr)->sin_port = htons((short)hp); + return 0; +} + +//============================================================================= + +int BW_GetSocketAddr (int socket, struct qsockaddr *addr) +{ + regs.x.ax = 0x4402; + regs.x.bx = socket; + regs.x.cx = sizeof(BW_UDPinfo_t); + regs.x.dx = lowmem_bufoff; + regs.x.ds = lowmem_bufseg; + dos_int86(0x21); + + addr->sa_family = AF_INET; + ((struct sockaddr_in *)addr)->sin_addr.s_addr = ((BW_UDPinfo_t *)lowmem_buffer)->localAddr.s_addr; + ((struct sockaddr_in *)addr)->sin_port = htons(((BW_UDPinfo_t *)lowmem_buffer)->localPort); + + return 0; +} + +//============================================================================= + +int BW_GetNameFromAddr (struct qsockaddr *addr, char *name) +{ + Q_strcpy(name, BW_AddrToString(addr)); + return 0; +} + +///============================================================================= + +int BW_GetAddrFromName (char *name, struct qsockaddr *hostaddr) +{ + char buff[MAXHOSTNAMELEN]; + char *b; + int addr; + int num; + int mask; + int run; + int port; + + if (name[0] < '0' || name[0] > '9') + return -1; + + buff[0] = '.'; + b = buff; + Q_strcpy(buff+1, name); + if (buff[1] == '.') + b++; + + addr = 0; + mask = -1; + while (*b == '.') + { + b++; + num = 0; + run = 0; + while (!( *b < '0' || *b > '9')) + { + num = num*10 + *b++ - '0'; + if (++run > 3) + return -1; + } + if ((*b < '0' || *b > '9') && *b != '.' && *b != ':' && *b != 0) + return -1; + if (num < 0 || num > 255) + return -1; + mask<<=8; + addr = (addr<<8) + num; + } + addr = htonl(addr); + mask = htonl(mask); + + if (*b++ == ':') + port = Q_atoi(b); + else + port = net_hostport; + + hostaddr->sa_family = AF_INET; + ((struct sockaddr_in *)hostaddr)->sin_port = htons((short)port); + ((struct sockaddr_in *)hostaddr)->sin_addr.s_addr = + ((ethdevinfo.inetAddr & mask) | addr); + + return 0; +} + +//============================================================================= + +int BW_AddrCompare (struct qsockaddr *addr1, struct qsockaddr *addr2) +{ + if (addr1->sa_family != addr2->sa_family) + return -1; + + if (((struct sockaddr_in *)addr1)->sin_addr.s_addr != ((struct sockaddr_in *)addr2)->sin_addr.s_addr) + return -1; + + if (((struct sockaddr_in *)addr1)->sin_port != ((struct sockaddr_in *)addr2)->sin_port) + return 1; + + return 0; +} + +//============================================================================= + +int BW_GetSocketPort (struct qsockaddr *addr) +{ + return ntohs(((struct sockaddr_in *)addr)->sin_port); +} + + +int BW_SetSocketPort (struct qsockaddr *addr, int port) +{ + ((struct sockaddr_in *)addr)->sin_port = htons(port); + return 0; +} + +//============================================================================= -- cgit v1.2.3