123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366 |
- #include "Precompiled.h"
- #include "globaldata.h"
- #include <stdlib.h>
- #include <string.h>
- #include <stdio.h>
- #include <errno.h>
- #include "i_system.h"
- #include "d_event.h"
- #include "d_net.h"
- #include "m_argv.h"
- #include "doomstat.h"
- #include "i_net.h"
- #include "doomlib.h"
- #include "../Main/Main.h"
- void NetSend (void);
- qboolean NetListen (void);
- int DOOMPORT = 1002;
- unsigned long GetServerIP() { return ::g->sendaddress[::g->doomcom.consoleplayer].sin_addr.s_addr; }
- void (*netget) (void);
- void (*netsend) (void);
- int UDPsocket (void)
- {
- int s;
-
- s = socket (AF_INET, SOCK_DGRAM, IPPROTO_UDP);
- if (s == INVALID_SOCKET) {
- int err = WSAGetLastError ();
- I_Error ("can't create socket: %s",strerror(errno));
- }
- return s;
- }
- void BindToLocalPort( int s, int port )
- {
- int v;
- struct sockaddr_in address;
- memset (&address, 0, sizeof(address));
- address.sin_family = AF_INET;
- address.sin_addr.s_addr = INADDR_ANY;
- address.sin_port = port;
- v = bind (s, (sockaddr*)&address, sizeof(address));
-
-
- }
- void PacketSend (void)
- {
- int c;
- doomdata_t sw;
-
- sw.checksum = htonl(::g->netbuffer->checksum);
- sw.sourceDest = DoomLib::BuildSourceDest(::g->doomcom.remotenode);
- sw.player = ::g->netbuffer->player;
- sw.retransmitfrom = ::g->netbuffer->retransmitfrom;
- sw.starttic = ::g->netbuffer->starttic;
- sw.numtics = ::g->netbuffer->numtics;
- for (c=0 ; c< ::g->netbuffer->numtics ; c++)
- {
- sw.cmds[c].forwardmove = ::g->netbuffer->cmds[c].forwardmove;
- sw.cmds[c].sidemove = ::g->netbuffer->cmds[c].sidemove;
- sw.cmds[c].angleturn = htons(::g->netbuffer->cmds[c].angleturn);
-
- sw.cmds[c].buttons = ::g->netbuffer->cmds[c].buttons;
- }
-
- {
-
- WSABUF buffer;
- buffer.buf = (char*)&sw;
- buffer.len = ::g->doomcom.datalength;
-
-
-
-
- c = DoomLib::Send( buffer.buf, buffer.len, (sockaddr_in*)&::g->sendaddress[::g->doomcom.remotenode], ::g->doomcom.remotenode );
-
- }
- }
- void PacketGet (void)
- {
- int i;
- int c;
- struct sockaddr_in fromaddress;
- int fromlen;
- doomdata_t sw;
- WSABUF buffer;
- DWORD num_recieved, flags = 0;
-
- buffer.buf = (char*)&sw;
- buffer.len = sizeof(sw);
- fromlen = sizeof(fromaddress);
-
-
-
- c = DoomLib::Recv( (char*)&sw, &num_recieved );
-
- if (c == SOCKET_ERROR )
- {
-
- ::g->doomcom.remotenode = -1;
- return;
- }
-
-
-
-
-
-
- int source;
- int dest;
- DoomLib::GetSourceDest( sw.sourceDest, &source, &dest );
- i = source;
-
-
-
-
-
- ::g->doomcom.remotenode = i;
- ::g->doomcom.datalength = (short)num_recieved;
-
- ::g->netbuffer->checksum = ntohl(sw.checksum);
- ::g->netbuffer->player = sw.player;
- ::g->netbuffer->retransmitfrom = sw.retransmitfrom;
- ::g->netbuffer->starttic = sw.starttic;
- ::g->netbuffer->numtics = sw.numtics;
- for (c=0 ; c< ::g->netbuffer->numtics ; c++)
- {
- ::g->netbuffer->cmds[c].forwardmove = sw.cmds[c].forwardmove;
- ::g->netbuffer->cmds[c].sidemove = sw.cmds[c].sidemove;
- ::g->netbuffer->cmds[c].angleturn = ntohs(sw.cmds[c].angleturn);
-
- ::g->netbuffer->cmds[c].buttons = sw.cmds[c].buttons;
- }
- }
- static int I_TrySetupNetwork(void)
- {
-
- return 1;
- }
- void I_InitNetwork (void)
- {
- qboolean trueval = true;
- int i;
- int p;
- int a = 0;
-
- memset (&::g->doomcom, 0, sizeof(::g->doomcom) );
-
- i = M_CheckParm ("-dup");
- if (i && i< ::g->myargc-1)
- {
- ::g->doomcom.ticdup = ::g->myargv[i+1][0]-'0';
- if (::g->doomcom.ticdup < 1)
- ::g->doomcom.ticdup = 1;
- if (::g->doomcom.ticdup > 9)
- ::g->doomcom.ticdup = 9;
- }
- else
- ::g->doomcom.ticdup = 1;
- if (M_CheckParm ("-extratic"))
- ::g->doomcom.extratics = 1;
- else
- ::g->doomcom.extratics = 0;
- p = M_CheckParm ("-port");
- if (p && p<::g->myargc-1)
- {
- DOOMPORT = atoi (::g->myargv[p+1]);
- I_Printf ("using alternate port %i\n",DOOMPORT);
- }
-
-
- i = M_CheckParm ("-net");
- if (!i || !I_TrySetupNetwork())
- {
-
- ::g->netgame = false;
- ::g->doomcom.id = DOOMCOM_ID;
- ::g->doomcom.numplayers = ::g->doomcom.numnodes = 1;
- ::g->doomcom.deathmatch = false;
- ::g->doomcom.consoleplayer = 0;
- return;
- }
- netsend = PacketSend;
- netget = PacketGet;
- ::g->netgame = true;
- {
- ++i;
- ::g->doomcom.numnodes = 0;
- ::g->doomcom.consoleplayer = atoi( ::g->myargv[i] );
-
- ++i;
- ::g->doomcom.numnodes = 0;
- for (; i < ::g->myargc; ++i)
- {
- ::g->sendaddress[::g->doomcom.numnodes].sin_family = AF_INET;
- ::g->sendaddress[::g->doomcom.numnodes].sin_port = htons(DOOMPORT);
- ::g->sendaddress[::g->doomcom.numnodes].sin_addr.s_addr = inet_addr (::g->myargv[i]);
- ::g->doomcom.numnodes++;
- }
-
- ::g->doomcom.id = DOOMCOM_ID;
- ::g->doomcom.numplayers = ::g->doomcom.numnodes;
- }
- if ( globalNetworking ) {
-
- ::g->insocket = UDPsocket ();
- BindToLocalPort (::g->insocket,htons(DOOMPORT));
- ioctlsocket (::g->insocket, FIONBIO, (u_long*)&trueval);
- ::g->sendsocket = UDPsocket ();
- I_Printf( "[+] Setting up sockets for player %d\n", DoomLib::GetPlayer() );
- }
- }
- void I_ShutdownNetwork( void ) {
- if ( globalNetworking ) {
- int curPlayer = DoomLib::GetPlayer();
- for (int player = 0; player < App->Game->Interface.GetNumPlayers(); ++player)
- {
- DoomLib::SetPlayer( player );
- if ( ::g->insocket != INVALID_SOCKET ) {
- I_Printf( "[-] Shut down insocket for player %d\n", DoomLib::GetPlayer() );
- shutdown( ::g->insocket, SD_BOTH );
- closesocket( ::g->insocket );
- }
- if ( ::g->sendsocket != INVALID_SOCKET ) {
- I_Printf( "[-] Shut down sendsocket for player %d\n", DoomLib::GetPlayer() );
- shutdown( ::g->sendsocket, SD_BOTH );
- closesocket( ::g->sendsocket );
- }
- }
- DoomLib::SetPlayer(curPlayer);
- globalNetworking = false;
- }
- }
- void I_NetCmd (void)
- {
- if (::g->doomcom.command == CMD_SEND)
- {
- netsend ();
- }
- else if (::g->doomcom.command == CMD_GET)
- {
- netget ();
- }
- else
- I_Error ("Bad net cmd: %i\n",::g->doomcom.command);
- }
|