quakespasm/Quake/net_sdlnet.c

/*
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
Foundat(&addr->sa_dataion, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

*/

#include "quakedef.h"

#if defined(_WIN32)
#include <winsock2.h>
#endif

#if defined(LINUX)
#include <SDL_net.h>
#else
#include <SDL_net/SDL_net.h>
#endif

#include "net_sdlnet.h"

#define MAX_SOCKETS 32
#define MAXHOSTNAMELEN 255
#define AF_INET 		2	/* internet */

static int              net_controlsocket;
static int              net_broadcastsocket = 0;
static int              net_acceptsocket = -1;
static struct qsockaddr broadcastaddr;

SDLNet_SocketSet    acceptsocket_set;

IPaddress           myaddr;

// contains a map of socket numbers to SDL_net UDP sockets
UDPsocket           net_sockets[MAX_SOCKETS];

int socket_id(UDPsocket socket)
{
    int i;
    int index = -1;

    for (i = 0; i < MAX_SOCKETS; i++)
    {
        if (net_sockets[i] == socket)
            return i;

        if (net_sockets[i] == NULL && index == -1)
        {
            index = i;
            break;
        }
    }

    if (index == -1)
    {
        // todo error
    }

    net_sockets[index] = socket;

    return index;
}

char *_AddrToString (int ip, int port)
{
    static char buffer[22];

    sprintf(buffer, "%d.%d.%d.%d:%d", (ip >> 24) & 0xff, (ip >> 16) & 0xff, (ip >> 8) & 0xff, ip & 0xff, port);
    return buffer;
}

char *_IPAddrToString (IPaddress *address)
{
    int ip;
    int port;

    ip = SDLNet_Read32(&address->host);
    port = SDLNet_Read16(&address->port);

    return _AddrToString(ip, port);
}

int  SDLN_Init (void)
{
	int         i;
	char        buff[MAXHOSTNAMELEN];
	char        *p;
    IPaddress   *ipaddress;

    // init SDL
    if (SDLNet_Init() == -1)
    {
        Con_SafePrintf ("SDL_net initialization failed.\n");
        return -1;
    }

    // allocate a socket set for the accept socket
    acceptsocket_set = SDLNet_AllocSocketSet(1);
    if (acceptsocket_set == NULL)
    {
		Con_DPrintf ("SDL_net initialization failed: Could not create socket set.\n");
        return -1;
    }

	// determine my name
	if (gethostname(buff, MAXHOSTNAMELEN) == -1)
	{
		Con_DPrintf ("SDL_net initialization failed: Could not determine host name.\n");
		return -1;
	}

	// if the quake hostname isn't set, set it to the machine name
	if (Q_strcmp(hostname.string, "UNNAMED") == 0)
	{
		// see if it's a text IP address (well, close enough)
		for (p = buff; *p; p++)
			if ((*p < '0' || *p > '9') && *p != '.')
				break;

		// if it is a real name, strip off the domain; we only want the host
		if (*p)
		{
			for (i = 0; i < 15; i++)
				if (buff[i] == '.')
					break;
			buff[i] = 0;
		}
		Cvar_Set ("hostname", buff);
	}

    // set my IP address
	i = COM_CheckParm ("-ip");
	if (i)
	{
		if (i < com_argc-1)
		{
            SDLNet_ResolveHost(&myaddr, com_argv[i+1], 0);
			if (myaddr.host == INADDR_NONE)
				Sys_Error ("%s is not a valid IP address", com_argv[i+1]);
			strcpy(my_tcpip_address, com_argv[i+1]);
		}
		else
		{
			Sys_Error ("NET_Init: you must specify an IP address after -ip");
		}
	}
	else
	{
        SDLNet_ResolveHost(&myaddr, NULL, 0);
		strcpy(my_tcpip_address, "INADDR_ANY");
	}

    // open the control socket
	if ((net_controlsocket = SDLN_OpenSocket (0)) == -1)
	{
		Con_Printf("SDLN_Init: Unable to open control socket\n");
		return -1;
	}

    broadcastaddr.sa_family = AF_INET;
    ipaddress = (IPaddress *)&(broadcastaddr.sa_data);
    SDLNet_Write32(INADDR_BROADCAST, &ipaddress->host);
    SDLNet_Write16(net_hostport, &ipaddress->port);

	Con_Printf("SDL_net TCP/IP initialized\n");
	tcpipAvailable = true;

	return net_controlsocket;
}

void SDLN_Shutdown (void)
{
	SDLN_Listen (false);
	SDLN_CloseSocket (net_controlsocket);
}

void SDLN_GetLocalAddress()
{
	if (myaddr.host != INADDR_ANY)
		return;

    SDLNet_ResolveHost(&myaddr, NULL, 0);
}

void SDLN_Listen (qboolean state)
{
	// enable listening
	if (state)
	{
		if (net_acceptsocket != -1)
			return;

		SDLN_GetLocalAddress();
		if ((net_acceptsocket = SDLN_OpenSocket (net_hostport)) == -1)
			Sys_Error ("SDLN_Listen: Unable to open accept socket\n");

        SDLNet_UDP_AddSocket(acceptsocket_set, net_sockets[net_acceptsocket]);
	}
    else
    {
        // disable listening
        if (net_acceptsocket == -1)
            return;

        SDLNet_UDP_DelSocket(acceptsocket_set, net_sockets[net_acceptsocket]);
        SDLN_CloseSocket(net_acceptsocket);

        net_acceptsocket = -1;
    }
}

int  SDLN_OpenSocket (int port)
{

    UDPsocket   newsocket;
    static IPaddress   address;

    if ((newsocket = SDLNet_UDP_Open(port)) == NULL)
        return -1;

// todo check what this does
//	if (pioctlsocket (newsocket, FIONBIO, &_true) == -1)
//		goto ErrorReturn;

    address.host = myaddr.host;
    address.port = SDLNet_Read16(&port);

    if (SDLNet_UDP_Bind(newsocket, 0, &address) != -1)
        return socket_id(newsocket);

	Sys_Error ("Unable to bind to %s", _IPAddrToString(&address));

	SDLNet_UDP_Close(newsocket);
	return -1;
}

int  SDLN_CloseSocket (int socketid)
{
    UDPsocket   socket;

    if (socketid == net_broadcastsocket)
        net_broadcastsocket = -1;

    socket = net_sockets[socketid];

    if (socket == NULL)
        return -1;

    SDLNet_UDP_Close(socket);

    net_sockets[socketid] = NULL;
    return 0;
}

int  SDLN_Connect (int socket, struct qsockaddr *addr)
{
    return 0;
}

int  SDLN_CheckNewConnections (void)
{
	if (net_acceptsocket == -1)
		return -1;

    if (SDLNet_CheckSockets(acceptsocket_set, 0) > 0)
        return net_acceptsocket;

    return -1;
}

UDPpacket *init_packet(UDPpacket *packet, int len)
{
    if (packet == NULL)
        return SDLNet_AllocPacket(len);

    if (packet->maxlen < len)
        SDLNet_ResizePacket(packet, len);

    return packet;
}

int  SDLN_Read (int socketid, byte *buf, int len, struct qsockaddr *addr)
{
    int                 numrecv;
    static UDPpacket    *packet;
    IPaddress           *ipaddress;

    UDPsocket socket = net_sockets[socketid];
    if (socket == NULL)
        return -1;

    packet = init_packet(packet, len);

    numrecv = SDLNet_UDP_Recv(socket, packet);
    if (numrecv == 1)
    {
        memcpy(buf, packet->data, packet->len);

        addr->sa_family = AF_INET;
        ipaddress = (IPaddress *)&(addr->sa_data);
        ipaddress->host = packet->address.host;
        ipaddress->port = packet->address.port;

        return packet->len;
    }

    return numrecv;

}

int  SDLN_Write (int socketid, byte *buf, int len, struct qsockaddr *addr)
{
    int                 numsent;
    static UDPpacket    *packet;
    UDPsocket           socket;
    IPaddress           *ipaddress;

    socket = net_sockets[socketid];

    if (socket == NULL)
        return -1;

    packet = init_packet(packet, len);
    memcpy(packet->data, buf, len);
    packet->len = len;

    ipaddress = (IPaddress *)&(addr->sa_data);
    packet->address.host = ipaddress->host;
    packet->address.port = ipaddress->port;

    numsent = SDLNet_UDP_Send(socket, -1, packet);
    if (numsent == 0)
        return 0;

    return len;
}

int  SDLN_Broadcast (int socketid, byte *buf, int len)
{

    if (socketid != net_broadcastsocket)
    {
        if (net_broadcastsocket != 0)
            Sys_Error("Attempted to use multiple broadcast sockets\n");

        // todo make socket broadcast capable
        Sys_Error("Unable to make socket broadcast capable\n");
    }

    return SDLN_Write(socketid, buf, len, &broadcastaddr);
}

char *SDLN_AddrToString (struct qsockaddr *addr)
{
	int         ip;
    int         port;
    IPaddress   *ipaddress;

    ipaddress = (IPaddress *)&(addr->sa_data);

    ip = SDLNet_Read32(&ipaddress->host);
    port = SDLNet_Read16(&ipaddress->port);

    return _AddrToString(ip, port);
}

int  SDLN_StringToAddr (char *string, struct qsockaddr *addr)
{
	int ha1, ha2, ha3, ha4, hp;
	int hostaddr;
    IPaddress   *ipaddress;

	sscanf(string, "%d.%d.%d.%d:%d", &ha1, &ha2, &ha3, &ha4, &hp);
	hostaddr = (ha1 << 24) | (ha2 << 16) | (ha3 << 8) | ha4;

    addr->sa_family = AF_INET;
    ipaddress = (IPaddress *)&(addr->sa_data);

    SDLNet_Write32(hostaddr, &ipaddress->host);
    SDLNet_Write16(hp, &ipaddress->port);

	return 0;
}

int  SDLN_GetSocketAddr (int socketid, struct qsockaddr *addr)
{
    static UDPsocket   socket;
    IPaddress   *peeraddress;
    IPaddress   *ipaddress;

	Q_memset(addr, 0, sizeof(struct qsockaddr));

    socket = net_sockets[socketid];
    if (socket == NULL)
        return -1;

    peeraddress = SDLNet_UDP_GetPeerAddress(socket, -1);
    if (peeraddress == NULL)
        return -1;

    addr->sa_family = AF_INET;
    ipaddress = (IPaddress *)&(addr->sa_data);
    if (peeraddress->host == 0 || peeraddress->host == inet_addr("127.0.0.1"))
    {
        ipaddress->host = myaddr.host;
        ipaddress->port = myaddr.port;
    }
    else
    {
        ipaddress->host = peeraddress->host;
        ipaddress->port = peeraddress->port;
    }

    return 0;
}

int  SDLN_GetNameFromAddr (struct qsockaddr *addr, char *name)
{
    char        *buf;
    IPaddress   *ipaddress;

    ipaddress = (IPaddress *)&(addr->sa_data);

    buf = (char *)SDLNet_ResolveIP(ipaddress);
    if (buf != NULL) {
        Q_strncpy(name, buf, NET_NAMELEN - 1);
        return 0;
    }

    Q_strcpy(name, SDLN_AddrToString(addr));
    return 0;
}

//=============================================================================
/*
============
PartialIPAddress

this lets you type only as much of the net address as required, using
the local network components to fill in the rest
============
*/
static int PartialIPAddress (char *in, struct qsockaddr *hostaddr)
{
	char buff[256];
	char *b;
	int addr;
	int num;
	int mask;
    int tmp;
	int run;
	int port;
	IPaddress *ipaddress;

	buff[0] = '.';
	b = buff;
	strcpy(buff+1, in);
	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;
	}

	if (*b++ == ':')
		port = Q_atoi(b);
	else
		port = net_hostport;

    tmp = SDLNet_Read32(&myaddr.host);
    tmp = (tmp & mask) | addr;

    hostaddr->sa_family = AF_INET;
    ipaddress = (IPaddress *)&(hostaddr->sa_data);

    SDLNet_Write32(tmp, &ipaddress->host);
    SDLNet_Write16(port, &ipaddress->port);

    return 0;
}

int  SDLN_GetAddrFromName (char *name, struct qsockaddr *addr)
{
    IPaddress   *ipaddress;

	if (name[0] >= '0' && name[0] <= '9')
        return PartialIPAddress (name, addr);

    ipaddress = (IPaddress *)&(addr->sa_data);
    if (SDLNet_ResolveHost((IPaddress *)(&addr->sa_data), name, 26000) == -1)
        return -1;

    addr->sa_family = AF_INET;
    return 0;
}

int  SDLN_AddrCompare (struct qsockaddr *addr1, struct qsockaddr *addr2)
{
    IPaddress   *ipaddr1;
    IPaddress   *ipaddr2;

    if (addr1->sa_family != addr2->sa_family)
		return -1;

    ipaddr1 = (IPaddress *)&(addr1->sa_data);
    ipaddr2 = (IPaddress *)&(addr2->sa_data);

	if (ipaddr1->host != ipaddr2->host)
		return -1;

	if (ipaddr1->port != ipaddr2->port)
		return 1;

	return 0;
}

int  SDLN_GetSocketPort (struct qsockaddr *addr)
{
    IPaddress   *ipaddress;

    ipaddress = (IPaddress *)&(addr->sa_data);
    return SDLNet_Read16(&ipaddress->port);
}

int  SDLN_SetSocketPort (struct qsockaddr *addr, int port)
{
    IPaddress   *ipaddress;

    ipaddress = (IPaddress *)&(addr->sa_data);
    SDLNet_Write16(port, &ipaddress->port);

    return 0;
}