Ginger88895
/
warzone2100
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
warzone2100/lib/netplay/netplay.cpp

3735 lines
119 KiB
C++
Raw Blame History

/*
This file is part of Warzone 2100.
Copyright (C) 1999-2004 Eidos Interactive
Copyright (C) 2005-2013 Warzone 2100 Project
Warzone 2100 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.
Warzone 2100 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 Warzone 2100; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
/**
* @file netplay.c
*
* Basic netcode.
*/
#include "lib/framework/frame.h"
#include "lib/framework/wzapp.h"
#include "lib/framework/string_ext.h"
#include "lib/framework/crc.h"
#include "lib/framework/file.h"
#include "lib/gamelib/gtime.h"
#include "src/console.h"
#include "src/component.h" // FIXME: we need to handle this better
#include "src/modding.h" // FIXME: we need to handle this better
#include <time.h> // for stats
#include <physfs.h>
#include <string.h>
#include <memory>
#include "netplay.h"
#include "netlog.h"
#include "netsocket.h"
#include <miniupnpc/miniwget.h>
#include <miniupnpc/miniupnpc.h>
#include <miniupnpc/upnpcommands.h>
#include "lib/exceptionhandler/dumpinfo.h"
#include "src/multistat.h"
#include "src/multijoin.h"
#include "src/multiint.h"
#include "src/multiplay.h"
#include "src/warzoneconfig.h"
#include "src/version.h"
#include "src/loadsave.h"
#ifdef WZ_OS_LINUX
#include <execinfo.h> // Nonfatal runtime backtraces.
#endif //WZ_OS_LINUX
// WARNING !!! This is initialised via configuration.c !!!
char masterserver_name[255] = {'\0'};
static unsigned int masterserver_port = 0, gameserver_port = 0;
#define WZ_SERVER_DISCONNECT 0
#define WZ_SERVER_CONNECT 1
#define WZ_SERVER_UPDATE 3
#define NET_TIMEOUT_DELAY 2500 // we wait this amount of time for socket activity
#define NET_READ_TIMEOUT 0
/*
* === Using new socket code, this might not hold true any longer ===
* NOTE /rant: If the buffer size isn't big enough, it will invalidate the socket.
* Which means that we need to allocate a buffer big enough to handle worst case
* situations.
* reference: MaxMsgSize in netplay.h (currently set to 16K)
*
*/
#define NET_BUFFER_SIZE (MaxMsgSize) // Would be 16K
// ////////////////////////////////////////////////////////////////////////
// Function prototypes
static void NETplayerLeaving(UDWORD player); // Cleanup sockets on player leaving (nicely)
static void NETplayerDropped(UDWORD player); // Broadcast NET_PLAYER_DROPPED & cleanup
static void NETregisterServer(int state);
static void NETallowJoining(void);
static void recvDebugSync(NETQUEUE queue);
static bool onBanList(const char *ip);
static void addToBanList(const char *ip, const char *name);
static void NETfixPlayerCount(void);
/*
* Network globals, these are part of the new network API
*/
SYNC_COUNTER sync_counter; // keeps track on how well we are in sync
// ////////////////////////////////////////////////////////////////////////
// Types
struct Statistic
{
unsigned sent;
unsigned received;
};
struct NETSTATS // data regarding the last one second or so.
{
Statistic rawBytes; // Number of actual bytes, in about 1 sec.
Statistic uncompressedBytes; // Number of bytes sent, before compression, in about 1 sec.
Statistic packets; // Number of calls to writeAll, in about 1 sec.
};
struct NET_PLAYER_DATA
{
uint16_t size;
void* data;
size_t buffer_size;
};
// ////////////////////////////////////////////////////////////////////////
// Variables
NETPLAY NetPlay;
PLAYER_IP *IPlist = NULL;
static bool allow_joining = false;
static bool server_not_there = false;
static GAMESTRUCT gamestruct;
// update flags
bool netPlayersUpdated;
int mapDownloadProgress;
/**
* Socket used for these purposes:
* * Host a game, be a server.
* * Connect to the lobby server.
* * Join a server for a game.
*/
static Socket* tcp_socket = NULL; ///< Socket used to talk to a lobby server (hosts also seem to temporarily act as lobby servers while the client negotiates joining the game), or to listen for clients (if we're the host, in which case we use rs_socket (declaration hidden somewhere inside a function) to talk to the lobby server).
static Socket *bsocket = NULL; ///< Socket used to talk to the host (clients only). If bsocket != NULL, then tcp_socket == NULL.
static Socket *connected_bsocket[MAX_CONNECTED_PLAYERS] = { NULL }; ///< Sockets used to talk to clients (host only).
static SocketSet* socket_set = NULL;
WZ_THREAD *upnpdiscover;
static struct UPNPUrls urls;
static struct IGDdatas data;
// local ip address
static char lanaddr[40];
static char externalIPAddress[40];
/**
* Used for connections with clients.
*/
static Socket* tmp_socket[MAX_TMP_SOCKETS] = { NULL }; ///< Sockets used to talk to clients which have not yet been assigned a player number (host only).
static SocketSet* tmp_socket_set = NULL;
static int32_t NetGameFlags[4] = { 0, 0, 0, 0 };
char iptoconnect[PATH_MAX] = "\0"; // holds IP/hostname from command line
static NETSTATS nStats = {{0, 0}, {0, 0}, {0, 0}};
static NETSTATS nStatsLastSec = {{0, 0}, {0, 0}, {0, 0}};
static NETSTATS nStatsSecondLastSec = {{0, 0}, {0, 0}, {0, 0}};
static const NETSTATS nZeroStats = {{0, 0}, {0, 0}, {0, 0}};
static int nStatsLastUpdateTime = 0;
unsigned NET_PlayerConnectionStatus[CONNECTIONSTATUS_NORMAL][MAX_PLAYERS];
// ////////////////////////////////////////////////////////////////////////////
/************************************************************************************
** NOTE (!) Increment NETCODE_VERSION_MINOR on each release.
**
************************************************************************************
**/
static char const *versionString = version_getVersionString();
static int NETCODE_VERSION_MAJOR = 7;
static int NETCODE_VERSION_MINOR = 0;
bool NETisCorrectVersion(uint32_t game_version_major, uint32_t game_version_minor)
{
return (NETCODE_VERSION_MAJOR == game_version_major && NETCODE_VERSION_MINOR == game_version_minor);
}
int NETGetMajorVersion(void)
{
return NETCODE_VERSION_MAJOR;
}
int NETGetMinorVersion(void)
{
return NETCODE_VERSION_MINOR;
}
// Sets if the game is password protected or not
void NETGameLocked( bool flag)
{
NetPlay.GamePassworded = flag;
bool flagChanged = gamestruct.privateGame != flag;
gamestruct.privateGame = flag;
if (allow_joining && NetPlay.isHost && flagChanged)
{
debug(LOG_NET, "Updating game locked status.");
NETregisterServer(WZ_SERVER_UPDATE);
}
NETlogEntry("Password is", SYNC_FLAG, NetPlay.GamePassworded);
debug(LOG_NET, "Passworded game is %s", NetPlay.GamePassworded ? "TRUE" : "FALSE" );
}
// Sets the game password
void NETsetGamePassword(const char *password)
{
sstrcpy(NetPlay.gamePassword, password);
debug(LOG_NET, "Password entered is: [%s]", NetPlay.gamePassword);
}
// Resets the game password
void NETresetGamePassword(void)
{
sstrcpy(NetPlay.gamePassword, _("Enter password here"));
debug(LOG_NET, "password reset to 'Enter password here'");
NETGameLocked(false);
}
// *********** Socket with buffer that read NETMSGs ******************
static size_t NET_fillBuffer(Socket **pSocket, SocketSet* socket_set, uint8_t *bufstart, int bufsize)
{
Socket *socket = *pSocket;
ssize_t size;
if (!socketReadReady(socket))
{
return 0;
}
size_t rawBytes;
size = readNoInt(socket, bufstart, bufsize, &rawBytes);
if ((size != 0 || !socketReadDisconnected(socket)) && size != SOCKET_ERROR)
{
nStats.rawBytes.received += rawBytes;
nStats.uncompressedBytes.received += size;
nStats.packets.received += 1;
return size;
}
else
{
if (size == 0)
{
debug(LOG_NET, "Connection closed from the other side");
NETlogEntry("Connection closed from the other side..", SYNC_FLAG, selectedPlayer);
}
else
{
debug(LOG_NET, "%s tcp_socket %p is now invalid", strSockError(getSockErr()), socket);
}
// an error occured, or the remote host has closed the connection.
if (socket_set != NULL)
{
SocketSet_DelSocket(socket_set, socket);
}
ASSERT(size <= bufsize, "Socket buffer is too small!");
if (size > bufsize)
{
debug(LOG_ERROR, "Fatal connection error: buffer size of (%d) was too small, current byte count was %ld", bufsize, (long)size);
NETlogEntry("Fatal connection error: buffer size was too small!", SYNC_FLAG, selectedPlayer);
}
if (bsocket == socket)
{
debug(LOG_NET, "Host connection was lost!");
NETlogEntry("Host connection was lost!", SYNC_FLAG, selectedPlayer);
bsocket = NULL;
//Game is pretty much over --should just end everything when HOST dies.
NetPlay.isHostAlive = false;
ingame.localJoiningInProgress = false;
setLobbyError(ERROR_HOSTDROPPED);
NETclose();
return 0;
}
socketClose(socket);
*pSocket = NULL;
}
return 0;
}
void NET_InitPlayer(int i, bool initPosition)
{
NetPlay.players[i].allocated = false;
NetPlay.players[i].autoGame = false;
NetPlay.players[i].heartattacktime = 0;
NetPlay.players[i].heartbeat = true; // we always start with a hearbeat
NetPlay.players[i].kick = false;
if (ingame.localJoiningInProgress)
{ // only clear name outside of games.
NetPlay.players[i].name[0] = '\0';
}
if (initPosition)
{
NetPlay.players[i].colour = i;
setPlayerColour(i, i); // PlayerColour[] in component.c must match this! Why is this in more than one place??!
NetPlay.players[i].position = i;
NetPlay.players[i].team = i;
}
NetPlay.players[i].ready = false;
NetPlay.players[i].needFile = false;
if (NetPlay.bComms)
{
NetPlay.players[i].ai = AI_OPEN;
}
else
{
NetPlay.players[i].ai = 0; // default AI
}
NetPlay.players[i].difficulty = 1; // normal
NetPlay.players[i].wzFile.isCancelled = false;
NetPlay.players[i].wzFile.isSending = false;
ingame.JoiningInProgress[i] = false;
}
void NET_InitPlayers()
{
unsigned int i;
for (i = 0; i < MAX_CONNECTED_PLAYERS; ++i)
{
NET_InitPlayer(i, true);
NetPlay.players[i].name[0] = '\0';
NETinitQueue(NETnetQueue(i));
}
NETinitQueue(NETbroadcastQueue());
NetPlay.hostPlayer = NET_HOST_ONLY; // right now, host starts always at index zero
NetPlay.playercount = 0;
NetPlay.pMapFileHandle = NULL;
debug(LOG_NET, "Players initialized");
}
static void NETSendNPlayerInfoTo(uint32_t *index, uint32_t indexLen, unsigned to)
{
int n;
NETbeginEncode(NETnetQueue(to), NET_PLAYER_INFO);
NETuint32_t(&indexLen);
for (n = 0; n < indexLen; ++n)
{
debug(LOG_NET, "sending player's (%u) info to all players", index[n]);
NETlogEntry(" sending player's info to all players", SYNC_FLAG, index[n]);
NETuint32_t(&index[n]);
NETbool(&NetPlay.players[index[n]].allocated);
NETbool(&NetPlay.players[index[n]].heartbeat);
NETbool(&NetPlay.players[index[n]].kick);
NETstring(NetPlay.players[index[n]].name, sizeof(NetPlay.players[index[n]].name));
NETuint32_t(&NetPlay.players[index[n]].heartattacktime);
NETint32_t(&NetPlay.players[index[n]].colour);
NETint32_t(&NetPlay.players[index[n]].position);
NETint32_t(&NetPlay.players[index[n]].team);
NETbool(&NetPlay.players[index[n]].ready);
NETint8_t(&NetPlay.players[index[n]].ai);
NETint8_t(&NetPlay.players[index[n]].difficulty);
NETuint8_t(&game.skDiff[index[n]]); // This one might be possible to calculate from the other values. // TODO game.skDiff should probably be eliminated somehow.
}
NETend();
}
static void NETSendPlayerInfoTo(uint32_t index, unsigned to)
{
NETSendNPlayerInfoTo(&index, 1, to);
}
static void NETsendPlayerInfo(uint32_t index)
{
NETSendPlayerInfoTo(index, NET_HOST_ONLY);
}
static void NETSendAllPlayerInfoTo(unsigned to)
{
static uint32_t indices[MAX_PLAYERS];
for (int i = 0; i < MAX_PLAYERS; ++i)
{
indices[i] = i;
}
ASSERT_OR_RETURN( , NetPlay.isHost == true, "Invalid call for non-host");
NETSendNPlayerInfoTo(indices, ARRAY_SIZE(indices), to);
}
void NETBroadcastTwoPlayerInfo(uint32_t index1, uint32_t index2)
{
uint32_t indices[2] = {index1, index2};
NETSendNPlayerInfoTo(indices, 2, NET_ALL_PLAYERS);
}
void NETBroadcastPlayerInfo(uint32_t index)
{
NETSendPlayerInfoTo(index, NET_ALL_PLAYERS);
}
static int NET_CreatePlayer(char const *name)
{
int index = -1;
int position = INT_MAX;
// Only look for spots up to the max players allowed on the map.
for (int i = 0; i < game.maxPlayers; ++i)
{
PLAYER const &p = NetPlay.players[i];
if (!p.allocated && p.ai == AI_OPEN && p.position < position)
{
index = i;
position = p.position;
}
}
if (index == -1)
{
debug(LOG_ERROR, "Could not find place for player %s", name);
NETlogEntry("Could not find a place for player!", SYNC_FLAG, index);
return -1;
}
char buf[250] = {'\0'};
ssprintf(buf, "A new player has been created. Player, %s, is set to slot %u", name, index);
debug(LOG_NET, "%s", buf);
NETlogEntry(buf, SYNC_FLAG, index);
NET_InitPlayer(index, false); // re-init everything
NetPlay.players[index].allocated = true;
sstrcpy(NetPlay.players[index].name, name);
++NetPlay.playercount;
++sync_counter.joins;
return index;
}
static void NET_DestroyPlayer(unsigned int index)
{
debug(LOG_NET, "Freeing slot %u for a new player", index);
NETlogEntry("Freeing slot for a new player.", SYNC_FLAG, index);
if (NetPlay.players[index].allocated)
{
NetPlay.players[index].allocated = false;
NetPlay.playercount--;
gamestruct.desc.dwCurrentPlayers = NetPlay.playercount;
if (allow_joining && NetPlay.isHost)
{
// Update player count in the lobby by disconnecting
// and reconnecting
NETregisterServer(WZ_SERVER_UPDATE);
}
}
NET_InitPlayer(index, false); // reinitialize
}
/**
* @note Connection dropped. Handle it gracefully.
* \param index
*/
static void NETplayerClientDisconnect(uint32_t index)
{
if (!NetPlay.isHost)
{
ASSERT(false, "Host only routine detected for client!");
return;
}
if(connected_bsocket[index])
{
debug(LOG_NET, "Player (%u) has left unexpectedly, closing socket %p", index, connected_bsocket[index]);
NETplayerLeaving(index);
NETlogEntry("Player has left unexpectedly.", SYNC_FLAG, index);
// Announce to the world. This was really icky, because we may have been calling the send
// function recursively. We really ought to have had a send queue, and now we finally do...
if (ingame.localJoiningInProgress) // Only if game hasn't actually started yet.
{
NETbeginEncode(NETbroadcastQueue(), NET_PLAYER_DROPPED);
NETuint32_t(&index);
NETend();
}
}
else
{
debug(LOG_ERROR, "Player (%u) has left unexpectedly - but socket already closed?", index);
}
}
/**
* @note When a player leaves nicely (ie, we got a NET_PLAYER_LEAVING
* message), we clean up the socket that we used.
* \param index
*/
static void NETplayerLeaving(UDWORD index)
{
if(connected_bsocket[index])
{
debug(LOG_NET, "Player (%u) has left, closing socket %p", index, connected_bsocket[index]);
NETlogEntry("Player has left nicely.", SYNC_FLAG, index);
// Although we can get a error result from DelSocket, it don't really matter here.
SocketSet_DelSocket(socket_set, connected_bsocket[index]);
socketClose(connected_bsocket[index]);
connected_bsocket[index] = NULL;
}
else
{
debug(LOG_NET, "Player (%u) has left nicely, socket already closed?", index);
}
sync_counter.left++;
MultiPlayerLeave(index); // more cleanup
if (ingame.localJoiningInProgress) // Only if game hasn't actually started yet.
{
NET_DestroyPlayer(index); // sets index player's array to false
}
}
/**
* @note When a player's connection is broken we broadcast the NET_PLAYER_DROPPED
* message.
* \param index
*/
static void NETplayerDropped(UDWORD index)
{
uint32_t id = index;
if (!NetPlay.isHost)
{
ASSERT(false, "Host only routine detected for client!");
return;
}
sync_counter.drops++;
MultiPlayerLeave(id); // more cleanup
if (ingame.localJoiningInProgress) // Only if game hasn't actually started yet.
{
// Send message type specifically for dropped / disconnects
NETbeginEncode(NETbroadcastQueue(), NET_PLAYER_DROPPED);
NETuint32_t(&id);
NETend();
debug(LOG_INFO, "sending NET_PLAYER_DROPPED for player %d", id);
NET_DestroyPlayer(id); // just clears array
}
NETsetPlayerConnectionStatus(CONNECTIONSTATUS_PLAYER_DROPPED, id);
}
/**
* @note Cleanup for when a player is kicked.
* \param index
*/
void NETplayerKicked(UDWORD index)
{
// kicking a player counts as "leaving nicely", since "nicely" in this case
// simply means "there wasn't a connection error."
debug(LOG_INFO, "Player %u was kicked.", index);
sync_counter.kicks++;
NETlogEntry("Player was kicked.", SYNC_FLAG, index);
if (NetPlay.isHost && NetPlay.players[index].allocated)
{
addToBanList(NetPlay.players[index].IPtextAddress, NetPlay.players[index].name);
}
NETplayerLeaving(index); // need to close socket for the player that left.
NETsetPlayerConnectionStatus(CONNECTIONSTATUS_PLAYER_LEAVING, index);
}
// ////////////////////////////////////////////////////////////////////////
// rename the local player
bool NETchangePlayerName(UDWORD index, char *newName)
{
if(!NetPlay.bComms)
{
sstrcpy(NetPlay.players[0].name, newName);
return true;
}
debug(LOG_NET, "Requesting a change of player name for pid=%u to %s", index, newName);
NETlogEntry("Player wants a name change.", SYNC_FLAG, index);
sstrcpy(NetPlay.players[index].name, newName);
if (NetPlay.isHost)
{
NETSendAllPlayerInfoTo(NET_ALL_PLAYERS);
}
else
{
NETsendPlayerInfo(index);
}
return true;
}
void NETfixDuplicatePlayerNames(void)
{
char name[StringSize];
unsigned i, j, pass;
for (i = 1; i != MAX_PLAYERS; ++i)
{
sstrcpy(name, NetPlay.players[i].name);
if (name[0] == '\0' || !NetPlay.players[i].allocated)
{
continue; // Ignore empty names.
}
for (pass = 0; pass != 101; ++pass)
{
if (pass != 0)
{
ssprintf(name, "%s_%X", NetPlay.players[i].name, pass + 1);
}
for (j = 0; j != i; ++j)
{
if (strcmp(name, NetPlay.players[j].name) == 0)
{
break; // Duplicate name.
}
}
if (i == j)
{
break; // Unique name.
}
}
if (pass != 0)
{
NETchangePlayerName(i, name);
}
}
}
// ////////////////////////////////////////////////////////////////////////
// return one of the four user flags in the current sessiondescription.
SDWORD NETgetGameFlags(UDWORD flag)
{
if (flag < 1 || flag > 4)
{
return 0;
}
else
{
return NetGameFlags[flag-1];
}
}
static void NETsendGameFlags(void)
{
debug(LOG_NET, "sending game flags");
NETbeginEncode(NETbroadcastQueue(), NET_GAME_FLAGS);
{
// Send the amount of game flags we're about to send
uint8_t i, count = ARRAY_SIZE(NetGameFlags);
NETuint8_t(&count);
// Send over all game flags
for (i = 0; i < count; ++i)
{
NETint32_t(&NetGameFlags[i]);
}
}
NETend();
}
// ////////////////////////////////////////////////////////////////////////
// Set a game flag
bool NETsetGameFlags(UDWORD flag, SDWORD value)
{
if(!NetPlay.bComms)
{
return true;
}
if (flag > 0 && flag < 5)
{
return (NetGameFlags[flag-1] = value);
}
NETsendGameFlags();
return true;
}
/**
* @note \c game is being sent to the master server (if hosting)
* The implementation of NETsendGAMESTRUCT <em>must</em> guarantee to
* pack it in network byte order (big-endian).
*
* @return true on success, false when a socket error has occurred
*
* @see GAMESTRUCT,NETrecvGAMESTRUCT
*/
static bool NETsendGAMESTRUCT(Socket* sock, const GAMESTRUCT* ourgamestruct)
{
// A buffer that's guaranteed to have the correct size (i.e. it
// circumvents struct padding, which could pose a problem). Initialise
// to zero so that we can be sure we're not sending any (undefined)
// memory content across the network.
char buf[sizeof(ourgamestruct->GAMESTRUCT_VERSION) + sizeof(ourgamestruct->name) + sizeof(ourgamestruct->desc.host) + (sizeof(int32_t) * 8) +
sizeof(ourgamestruct->secondaryHosts) + sizeof(ourgamestruct->extra) + sizeof(ourgamestruct->mapname) + sizeof(ourgamestruct->hostname) + sizeof(ourgamestruct->versionstring) +
sizeof(ourgamestruct->modlist) + (sizeof(uint32_t) * 9) ] = { 0 };
char *buffer = buf;
unsigned int i;
ssize_t result;
// Now dump the data into the buffer
// Copy 32bit large big endian numbers
*(uint32_t*)buffer = htonl(ourgamestruct->GAMESTRUCT_VERSION);
buffer += sizeof(uint32_t);
// Copy a string
strlcpy(buffer, ourgamestruct->name, sizeof(ourgamestruct->name));
buffer += sizeof(ourgamestruct->name);
// Copy 32bit large big endian numbers
*(int32_t*)buffer = htonl(ourgamestruct->desc.dwSize);
buffer += sizeof(int32_t);
*(int32_t*)buffer = htonl(ourgamestruct->desc.dwFlags);
buffer += sizeof(int32_t);
// Copy yet another string
strlcpy(buffer, ourgamestruct->desc.host, sizeof(ourgamestruct->desc.host));
buffer += sizeof(ourgamestruct->desc.host);
// Copy 32bit large big endian numbers
*(int32_t*)buffer = htonl(ourgamestruct->desc.dwMaxPlayers);
buffer += sizeof(int32_t);
*(int32_t*)buffer = htonl(ourgamestruct->desc.dwCurrentPlayers);
buffer += sizeof(int32_t);
for (i = 0; i < ARRAY_SIZE(ourgamestruct->desc.dwUserFlags); ++i)
{
*(int32_t*)buffer = htonl(ourgamestruct->desc.dwUserFlags[i]);
buffer += sizeof(int32_t);
}
// Copy a string
for (i = 0; i <ARRAY_SIZE(ourgamestruct->secondaryHosts); ++i)
{
strlcpy(buffer, ourgamestruct->secondaryHosts[i], sizeof(ourgamestruct->secondaryHosts[i]));
buffer += sizeof(ourgamestruct->secondaryHosts[i]);
}
// Copy a string
strlcpy(buffer, ourgamestruct->extra, sizeof(ourgamestruct->extra));
buffer += sizeof(ourgamestruct->extra);
// Copy a string
strlcpy(buffer, ourgamestruct->mapname, sizeof(ourgamestruct->mapname));
buffer += sizeof(ourgamestruct->mapname);
// Copy a string
strlcpy(buffer, ourgamestruct->hostname, sizeof(ourgamestruct->hostname));
buffer += sizeof(ourgamestruct->hostname);
// Copy a string
strlcpy(buffer, ourgamestruct->versionstring, sizeof(ourgamestruct->versionstring));
buffer += sizeof(ourgamestruct->versionstring);
// Copy a string
strlcpy(buffer, ourgamestruct->modlist, sizeof(ourgamestruct->modlist));
buffer += sizeof(ourgamestruct->modlist);
// Copy 32bit large big endian numbers
*(uint32_t*)buffer = htonl(ourgamestruct->game_version_major);
buffer += sizeof(uint32_t);
// Copy 32bit large big endian numbers
*(uint32_t*)buffer = htonl(ourgamestruct->game_version_minor);
buffer += sizeof(uint32_t);
// Copy 32bit large big endian numbers
*(uint32_t*)buffer = htonl(ourgamestruct->privateGame);
buffer += sizeof(uint32_t);
// Copy 32bit large big endian numbers
*(uint32_t*)buffer = htonl(ourgamestruct->pureGame);
buffer += sizeof(uint32_t);
// Copy 32bit large big endian numbers
*(uint32_t*)buffer = htonl(ourgamestruct->Mods);
buffer += sizeof(uint32_t);
// Copy 32bit large big endian numbers
*(uint32_t*)buffer = htonl(ourgamestruct->gameId);
buffer += sizeof(uint32_t);
// Copy 32bit large big endian numbers
*(uint32_t*)buffer = htonl(ourgamestruct->limits);
buffer += sizeof(uint32_t);
// Copy 32bit large big endian numbers
*(uint32_t*)buffer = htonl(ourgamestruct->future3);
buffer += sizeof(uint32_t);
// Copy 32bit large big endian numbers
*(uint32_t*)buffer = htonl(ourgamestruct->future4);
buffer += sizeof(uint32_t);
debug(LOG_NET, "sending GAMESTRUCT, size: %u", (unsigned int)sizeof(buf));
// Send over the GAMESTRUCT
result = writeAll(sock, buf, sizeof(buf));
if (result == SOCKET_ERROR)
{
const int err = getSockErr();
// If packet could not be sent, we should inform user of the error.
debug(LOG_ERROR, "Failed to send GAMESTRUCT. Reason: %s", strSockError(getSockErr()));
debug(LOG_ERROR, "Please make sure TCP ports %u & %u are open!", masterserver_port, gameserver_port);
setSockErr(err);
return false;
}
return true;
}
/**
* @note \c game is being retrieved from the master server (if browsing the
* lobby). The implementation of NETrecvGAMESTRUCT should assume the data
* to be packed in network byte order (big-endian).
*
* @see GAMESTRUCT,NETsendGAMESTRUCT
*/
static bool NETrecvGAMESTRUCT(GAMESTRUCT* ourgamestruct)
{
// A buffer that's guaranteed to have the correct size (i.e. it
// circumvents struct padding, which could pose a problem).
char buf[sizeof(ourgamestruct->GAMESTRUCT_VERSION) + sizeof(ourgamestruct->name) + sizeof(ourgamestruct->desc.host) + (sizeof(int32_t) * 8) +
sizeof(ourgamestruct->secondaryHosts) + sizeof(ourgamestruct->extra) + sizeof(ourgamestruct->mapname) + sizeof(ourgamestruct->hostname) + sizeof(ourgamestruct->versionstring) +
sizeof(ourgamestruct->modlist) + (sizeof(uint32_t) * 9) ] = { 0 };
char* buffer = buf;
unsigned int i;
ssize_t result = 0;
// Read a GAMESTRUCT from the connection
result = readAll(tcp_socket, buf, sizeof(buf), NET_TIMEOUT_DELAY);
bool failed = false;
if (result == SOCKET_ERROR)
{
debug(LOG_ERROR, "Lobby server connection error: %s", strSockError(getSockErr()));
failed = true;
}
else if ((unsigned)result != sizeof(buf))
{
debug(LOG_ERROR, "GAMESTRUCT recv timed out; received %d bytes; expecting %d", (int)result, (int)sizeof(buf));
failed = true;
}
if (failed)
{
SocketSet_DelSocket(socket_set, tcp_socket); // mark it invalid
socketClose(tcp_socket);
tcp_socket = NULL;
}
// Now dump the data into the game struct
// Copy 32bit large big endian numbers
ourgamestruct->GAMESTRUCT_VERSION = ntohl(*(uint32_t*)buffer);
buffer += sizeof(uint32_t);
// Copy a string
sstrcpy(ourgamestruct->name, buffer);
buffer += sizeof(ourgamestruct->name);
// Copy 32bit large big endian numbers
ourgamestruct->desc.dwSize = ntohl(*(int32_t*)buffer);
buffer += sizeof(int32_t);
ourgamestruct->desc.dwFlags = ntohl(*(int32_t*)buffer);
buffer += sizeof(int32_t);
// Copy yet another string
sstrcpy(ourgamestruct->desc.host, buffer);
buffer += sizeof(ourgamestruct->desc.host);
// Copy 32bit large big endian numbers
ourgamestruct->desc.dwMaxPlayers = ntohl(*(int32_t*)buffer);
buffer += sizeof(int32_t);
ourgamestruct->desc.dwCurrentPlayers = ntohl(*(int32_t*)buffer);
buffer += sizeof(int32_t);
for (i = 0; i < ARRAY_SIZE(ourgamestruct->desc.dwUserFlags); ++i)
{
ourgamestruct->desc.dwUserFlags[i] = ntohl(*(int32_t*)buffer);
buffer += sizeof(int32_t);
}
// Copy a string
for (i = 0; i < ARRAY_SIZE(ourgamestruct->secondaryHosts); ++i)
{
sstrcpy(ourgamestruct->secondaryHosts[i], buffer);
buffer += sizeof(ourgamestruct->secondaryHosts[i]);
}
// Copy a string
sstrcpy(ourgamestruct->extra, buffer);
buffer += sizeof(ourgamestruct->extra);
// Copy a string
sstrcpy(ourgamestruct->mapname, buffer);
buffer += sizeof(ourgamestruct->mapname);
// Copy a string
sstrcpy(ourgamestruct->hostname, buffer);
buffer += sizeof(ourgamestruct->hostname);
// Copy a string
sstrcpy(ourgamestruct->versionstring, buffer);
buffer += sizeof(ourgamestruct->versionstring);
// Copy a string
sstrcpy(ourgamestruct->modlist, buffer);
buffer += sizeof(ourgamestruct->modlist);
// Copy 32bit large big endian numbers
ourgamestruct->game_version_major = ntohl(*(uint32_t*)buffer);
buffer += sizeof(uint32_t);
ourgamestruct->game_version_minor = ntohl(*(uint32_t*)buffer);
buffer += sizeof(uint32_t);
ourgamestruct->privateGame = ntohl(*(uint32_t*)buffer);
buffer += sizeof(uint32_t);
ourgamestruct->pureGame = ntohl(*(uint32_t*)buffer);
buffer += sizeof(uint32_t);
ourgamestruct->Mods = ntohl(*(uint32_t*)buffer);
buffer += sizeof(uint32_t);
ourgamestruct->gameId = ntohl(*(uint32_t*)buffer);
buffer += sizeof(uint32_t);
ourgamestruct->limits = ntohl(*(uint32_t*)buffer);
buffer += sizeof(uint32_t);
ourgamestruct->future3 = ntohl(*(uint32_t*)buffer);
buffer += sizeof(uint32_t);
ourgamestruct->future4 = ntohl(*(uint32_t*)buffer);
buffer += sizeof(uint32_t);
debug(LOG_NET, "received GAMESTRUCT");
return true;
}
static int upnp_init(void *asdf)
{
struct UPNPDev *devlist;
struct UPNPDev *dev;
char *descXML;
int descXMLsize = 0;
char buf[255];
int result;
memset(&urls, 0, sizeof(struct UPNPUrls));
memset(&data, 0, sizeof(struct IGDdatas));
if (NetPlay.isUPNP)
{
debug(LOG_NET, "Searching for UPnP devices for automatic port forwarding...");
devlist = upnpDiscover(3000, NULL, NULL, 0, 0, &result);
debug(LOG_NET, "UPnP device search finished.");
if (devlist)
{
dev = devlist;
while (dev)
{
if (strstr(dev->st, "InternetGatewayDevice"))
break;
dev = dev->pNext;
}
if (!dev)
{
dev = devlist; /* defaulting to first device */
}
debug(LOG_NET, "UPnP device found: %s %s\n", dev->descURL, dev->st);
descXML = (char *)miniwget_getaddr(dev->descURL, &descXMLsize, lanaddr, sizeof(lanaddr), dev->scope_id);
debug(LOG_NET, "LAN address: %s", lanaddr);
if (descXML)
{
parserootdesc (descXML, descXMLsize, &data);
free (descXML); descXML = 0;
GetUPNPUrls (&urls, &data, dev->descURL, dev->scope_id);
}
ssprintf(buf, "UPnP device found: %s %s LAN address %s", dev->descURL, dev->st, lanaddr);
addDumpInfo(buf);
freeUPNPDevlist(devlist);
if (!urls.controlURL || urls.controlURL[0] == '\0')
{
ssprintf(buf, "controlURL not available, UPnP disabled");
addDumpInfo(buf);
// beware of writing a line too long, it screws up console line count. \n is safe for line split
ssprintf(buf, _("Your router doesn't support UPnP, you must manually configure your router & firewall to\nopen port 2100 before you can host a game."));
addConsoleMessage(buf, DEFAULT_JUSTIFY, NOTIFY_MESSAGE);
NetPlay.isUPNP_CONFIGURED = false;
NetPlay.isUPNP_ERROR = true;
return false;
}
NETaddRedirects();
return true;
}
ssprintf(buf, "UPnP device not found.");
addDumpInfo(buf);
debug(LOG_NET, "No UPnP devices found.");
// beware of writing a line too long, it screws up console line count. \n is safe for line split
ssprintf(buf, _("No UPnP device was found. You must manually configure your router & firewall to\nopen port 2100 before you can host a game."));
addConsoleMessage(buf, DEFAULT_JUSTIFY, NOTIFY_MESSAGE);
NetPlay.isUPNP_CONFIGURED = false;
NetPlay.isUPNP_ERROR = true;
return false;
}
else
{
ssprintf(buf, "UPnP detection routine disabled by user.");
addDumpInfo(buf);
debug(LOG_NET, "UPnP detection routine disabled by user.");
return false;
}
}
static bool upnp_add_redirect(int port)
{
char port_str[16];
char buf[512]={'\0'};
int r;
debug(LOG_NET, "upnp_add_redir(%d)", port);
sprintf(port_str, "%d", port);
r = UPNP_AddPortMapping(urls.controlURL, data.first.servicetype,
port_str, port_str, lanaddr, "Warzone 2100", "TCP", 0, "0"); // "0" = lease time unlimited
if (r != UPNPCOMMAND_SUCCESS)
{
ssprintf(buf, _("Could not open require port (%s) on (%s)"), port_str, lanaddr);
debug(LOG_NET, "%s", buf);
addConsoleMessage(buf, DEFAULT_JUSTIFY, NOTIFY_MESSAGE);
// beware of writing a line too long, it screws up console line count. \n is safe for line split
ssprintf(buf, _("You must manually configure your router & firewall to\n open port 2100 before you can host a game."));
addConsoleMessage(buf, DEFAULT_JUSTIFY, NOTIFY_MESSAGE);
return false;
}
r = UPNP_GetExternalIPAddress(urls.controlURL, data.first.servicetype, externalIPAddress);
if(r != UPNPCOMMAND_SUCCESS)
{
ssprintf(externalIPAddress, "???");
}
ssprintf(buf, _("Game configured port (%s) correctly on (%s)\nYour external IP is %s"), port_str, lanaddr, externalIPAddress);
addConsoleMessage(buf, DEFAULT_JUSTIFY, NOTIFY_MESSAGE);
return true;
}
static int upnp_rem_redirect(int port)
{
char port_str[16];
debug(LOG_NET, "upnp_rem_redir(%d)", port);
sprintf(port_str, "%d", port);
return UPNP_DeletePortMapping(urls.controlURL, data.first.servicetype, port_str, "TCP", NULL);
}
void NETaddRedirects(void)
{
if (upnp_add_redirect(gameserver_port))
{
debug(LOG_NET, "successful!");
NetPlay.isUPNP_CONFIGURED = true;
NetPlay.isUPNP_ERROR = false;
}
else
{
debug(LOG_NET, "failed!");
NetPlay.isUPNP_CONFIGURED = false;
NetPlay.isUPNP_ERROR = true;
}
}
void NETremRedirects(void)
{
debug(LOG_NET, "upnp is %d", NetPlay.isUPNP_CONFIGURED);
if (NetPlay.isUPNP_CONFIGURED)
{
int result = upnp_rem_redirect(gameserver_port);
if (!result)
{
debug(LOG_NET, "removed UPnP entry.");
}
else
{
debug(LOG_ERROR, "Failed to remove UPnP entry for the game. You must manually remove it from your router. (%d)", result);
}
}
}
void NETdiscoverUPnPDevices(void)
{
if (!NetPlay.isUPNP_CONFIGURED)
{
upnpdiscover = wzThreadCreate(&upnp_init, NULL);
wzThreadStart(upnpdiscover);
}
}
// ////////////////////////////////////////////////////////////////////////
// setup stuff
int NETinit(bool bFirstCall)
{
debug(LOG_NET, "NETinit");
NETlogEntry("NETinit!", SYNC_FLAG, selectedPlayer);
NET_InitPlayers();
SOCKETinit();
if(bFirstCall)
{
debug(LOG_NET, "NETPLAY: Init called, MORNIN'");
memset(&NetPlay.games, 0, sizeof(NetPlay.games));
// NOTE NetPlay.isUPNP is already set in configuration.c!
NetPlay.bComms = true;
NetPlay.GamePassworded = false;
NetPlay.ShowedMOTD = false;
NetPlay.isHostAlive = false;
NetPlay.gamePassword[0] = '\0';
NetPlay.MOTD = strdup("");
sstrcpy(NetPlay.gamePassword,_("Enter password here"));
NETstartLogging();
}
NetPlay.ShowedMOTD = false;
NetPlay.GamePassworded = false;
memset(&sync_counter, 0x0, sizeof(sync_counter)); //clear counters
return 0;
}
// ////////////////////////////////////////////////////////////////////////
// SHUTDOWN THE CONNECTION.
int NETshutdown(void)
{
debug( LOG_NET, "NETshutdown" );
NETlogEntry("NETshutdown", SYNC_FLAG, selectedPlayer);
if (NetPlay.bComms && NetPlay.isUPNP)
{
NETremRedirects();
NetPlay.isUPNP_CONFIGURED = false;
NetPlay.isUPNP_ERROR = false;
}
NETstopLogging();
if (IPlist)
free(IPlist);
IPlist = NULL;
if (NetPlay.MOTD)
{
free(NetPlay.MOTD);
}
NetPlay.MOTD = NULL;
NETdeleteQueue();
SOCKETshutdown();
// Reset net usage statistics.
nStats = nZeroStats;
nStatsLastSec = nZeroStats;
nStatsSecondLastSec = nZeroStats;
return 0;
}
// ////////////////////////////////////////////////////////////////////////
//close the open game..
int NETclose(void)
{
unsigned int i;
// reset flag
NetPlay.ShowedMOTD = false;
NEThaltJoining();
debug(LOG_NET, "Terminating sockets.");
NetPlay.isHost = false;
server_not_there = false;
allow_joining = false;
for(i = 0; i < MAX_CONNECTED_PLAYERS; i++)
{
if (connected_bsocket[i])
{
debug(LOG_NET, "Closing connected_bsocket[%u], %p", i, connected_bsocket[i]);
socketClose(connected_bsocket[i]);
connected_bsocket[i]=NULL;
}
NET_DestroyPlayer(i);
}
if (tmp_socket_set)
{
debug(LOG_NET, "Freeing tmp_socket_set %p", tmp_socket_set);
deleteSocketSet(tmp_socket_set);
tmp_socket_set=NULL;
}
for (i = 0; i < MAX_TMP_SOCKETS; i++)
{
if (tmp_socket[i])
{
// FIXME: need SocketSet_DelSocket() as well, socket_set or tmp_socket_set?
debug(LOG_NET, "Closing tmp_socket[%d] %p", i, tmp_socket[i]);
socketClose(tmp_socket[i]);
tmp_socket[i]=NULL;
}
}
if (socket_set)
{
// checking to make sure tcp_socket is still valid
if (tcp_socket)
{
SocketSet_DelSocket(socket_set, tcp_socket);
}
if (bsocket)
{
SocketSet_DelSocket(socket_set, bsocket);
}
debug(LOG_NET, "Freeing socket_set %p", socket_set);
deleteSocketSet(socket_set);
socket_set=NULL;
}
if (tcp_socket)
{
debug(LOG_NET, "Closing tcp_socket %p", tcp_socket);
socketClose(tcp_socket);
tcp_socket=NULL;
}
if (bsocket)
{
debug(LOG_NET, "Closing bsocket %p", bsocket);
socketClose(bsocket);
bsocket = NULL;
}
return 0;
}
// ////////////////////////////////////////////////////////////////////////
// ////////////////////////////////////////////////////////////////////////
// Send and Recv functions
// ////////////////////////////////////////////////////////////////////////
// return bytes of data sent recently.
unsigned NETgetStatistic(NetStatisticType type, bool sent, bool isTotal)
{
unsigned Statistic::*statisticType = sent? &Statistic::sent : &Statistic::received;
Statistic NETSTATS::*statsType;
switch (type)
{
case NetStatisticRawBytes: statsType = &NETSTATS::rawBytes; break;
case NetStatisticUncompressedBytes: statsType = &NETSTATS::uncompressedBytes; break;
case NetStatisticPackets: statsType = &NETSTATS::packets; break;
default: ASSERT(false, " "); return 0;
}
int time = wzGetTicks();
if ((unsigned)(time - nStatsLastUpdateTime) >= (unsigned)GAME_TICKS_PER_SEC)
{
nStatsLastUpdateTime = time;
nStatsSecondLastSec = nStatsLastSec;
nStatsLastSec = nStats;
}
if (isTotal)
{
return nStats.*statsType.*statisticType;
}
return nStatsLastSec.*statsType.*statisticType - nStatsSecondLastSec.*statsType.*statisticType;
}
// ////////////////////////////////////////////////////////////////////////
// Send a message to a player, option to guarantee message
bool NETsend(NETQUEUE queue, NetMessage const *message)
{
uint8_t player = queue.index;
ssize_t result = 0;
if(!NetPlay.bComms)
{
return true;
}
Socket **sockets = connected_bsocket;
bool isTmpQueue = false;
switch (queue.queueType)
{
case QUEUE_BROADCAST:
ASSERT_OR_RETURN(false, player == NET_ALL_PLAYERS, "Wrong queue index.");
break;
case QUEUE_NET:
ASSERT_OR_RETURN(false, player < MAX_CONNECTED_PLAYERS, "Wrong queue index.");
break;
case QUEUE_TMP:
sockets = tmp_socket;
isTmpQueue = true;
ASSERT_OR_RETURN(false, player < MAX_TMP_SOCKETS && NetPlay.isHost, "Wrong queue index.");
break;
default:
ASSERT_OR_RETURN(false, false, "Wrong queue type.");
}
if (NetPlay.isHost)
{
int firstPlayer = player == NET_ALL_PLAYERS ? 0 : player;
int lastPlayer = player == NET_ALL_PLAYERS ? MAX_CONNECTED_PLAYERS - 1 : player;
for (player = firstPlayer; player <= lastPlayer; ++player)
{
// We are the host, send directly to player.
if (sockets[player] != NULL && player != queue.exclude)
{
uint8_t *rawData = message->rawDataDup();
ssize_t rawLen = message->rawLen();
size_t compressedRawLen;
result = writeAll(sockets[player], rawData, rawLen, &compressedRawLen);
delete[] rawData; // Done with the data.
if (result == rawLen)
{
nStats.rawBytes.sent += compressedRawLen;
nStats.uncompressedBytes.sent += rawLen;
nStats.packets.sent += 1;
}
else if (result == SOCKET_ERROR)
{
// Write error, most likely client disconnect.
debug(LOG_ERROR, "Failed to send message: %s", strSockError(getSockErr()));
if (!isTmpQueue)
{
NETlogEntry("client disconnect?", SYNC_FLAG, player);
NETplayerClientDisconnect(player);
}
}
}
}
return true;
}
else if (player == NetPlay.hostPlayer)
{
// We are a client, send directly to player, who happens to be the host.
if (bsocket)
{
uint8_t *rawData = message->rawDataDup();
ssize_t rawLen = message->rawLen();
size_t compressedRawLen;
result = writeAll(bsocket, rawData, rawLen, &compressedRawLen);
delete[] rawData; // Done with the data.
if (result == rawLen)
{
nStats.rawBytes.sent += compressedRawLen;
nStats.uncompressedBytes.sent += rawLen;
nStats.packets.sent += 1;
}
else if (result == SOCKET_ERROR)
{
// Write error, most likely host disconnect.
debug(LOG_ERROR, "Failed to send message: %s", strSockError(getSockErr()));
debug(LOG_ERROR, "Host connection was broken, socket %p.", bsocket);
NETlogEntry("write error--client disconnect.", SYNC_FLAG, player);
SocketSet_DelSocket(socket_set, bsocket); // mark it invalid
socketClose(bsocket);
bsocket = NULL;
NetPlay.players[NetPlay.hostPlayer].heartbeat = false; // mark host as dead
//Game is pretty much over --should just end everything when HOST dies.
NetPlay.isHostAlive = false;
}
return result == rawLen;
}
}
else
{
// We are a client and can't send the data directly, ask the host to send the data to the player.
uint8_t sender = selectedPlayer;
NETbeginEncode(NETnetQueue(NET_HOST_ONLY), NET_SEND_TO_PLAYER);
NETuint8_t(&sender);
NETuint8_t(&player);
NETnetMessage(&message);
NETend();
}
return false;
}
void NETflush()
{
if (!NetPlay.bComms)
{
return;
}
NETflushGameQueues();
size_t compressedRawLen;
if (NetPlay.isHost)
{
for (int player = 0; player < MAX_CONNECTED_PLAYERS; ++player)
{
// We are the host, send directly to player.
if (connected_bsocket[player] != NULL)
{
socketFlush(connected_bsocket[player], &compressedRawLen);
nStats.rawBytes.sent += compressedRawLen;
}
}
for (int player = 0; player < MAX_TMP_SOCKETS; ++player)
{
// We are the host, send directly to player.
if (tmp_socket[player] != NULL)
{
socketFlush(tmp_socket[player], &compressedRawLen);
nStats.rawBytes.sent += compressedRawLen;
}
}
}
else
{
if (bsocket != NULL)
{
socketFlush(bsocket, &compressedRawLen);
nStats.rawBytes.sent += compressedRawLen;
}
}
}
///////////////////////////////////////////////////////////////////////////
// Check if a message is a system message
static bool NETprocessSystemMessage(NETQUEUE playerQueue, uint8_t type)
{
switch (type)
{
case NET_SEND_TO_PLAYER:
{
uint8_t sender;
uint8_t receiver;
NetMessage const *message = NULL;
NETbeginDecode(playerQueue, NET_SEND_TO_PLAYER);
NETuint8_t(&sender);
NETuint8_t(&receiver);
NETnetMessage(&message); // Must delete message later.
std::auto_ptr<NetMessage const> deleteLater(message);
if (!NETend())
{
debug(LOG_ERROR, "Incomplete NET_SEND_TO_PLAYER.");
break;
}
if (sender >= MAX_PLAYERS || (receiver >= MAX_PLAYERS && receiver != NET_ALL_PLAYERS))
{
debug(LOG_ERROR, "Bad NET_SEND_TO_PLAYER.");
break;
}
if ((receiver == selectedPlayer || receiver == NET_ALL_PLAYERS) && playerQueue.index == NetPlay.hostPlayer)
{
// Message was sent to us via the host.
if (sender != selectedPlayer) // Make sure host didn't send us our own broadcast messages, which shouldn't happen anyway.
{
NETinsertMessageFromNet(NETnetQueue(sender), message);
NETlogPacket(message->type, message->rawLen(), true);
}
}
else if (NetPlay.isHost && sender == playerQueue.index)
{
if ((( message->type == NET_FIREUP
|| message->type == NET_KICK
|| message->type == NET_PLAYER_LEAVING
|| message->type == NET_PLAYER_DROPPED
|| message->type == NET_REJECTED
|| message->type == NET_PLAYER_JOINED) && sender != NET_HOST_ONLY)
||
(( message->type == NET_HOST_DROPPED
|| message->type == NET_OPTIONS
|| message->type == NET_FILE_REQUESTED
|| message->type == NET_READY_REQUEST
|| message->type == NET_TEAMREQUEST
|| message->type == NET_COLOURREQUEST
|| message->type == NET_POSITIONREQUEST
|| message->type == NET_FILE_CANCELLED
|| message->type == NET_JOIN
|| message->type == NET_PLAYER_INFO) && receiver != NET_HOST_ONLY))
{
char msg[256] = {'\0'};
ssprintf(msg, "Auto-kicking player %u, lacked the required access level for command(%d).", (unsigned int)sender, (int)message->type);
sendTextMessage(msg, true);
NETlogEntry(msg, SYNC_FLAG, sender);
addToBanList(NetPlay.players[sender].IPtextAddress, NetPlay.players[sender].name);
NETplayerDropped(sender);
connected_bsocket[sender] = NULL;
debug(LOG_ERROR, "%s", msg);
break;
}
// We are the host, and player is asking us to send the message to receiver.
NETbeginEncode(NETnetQueue(receiver, sender), NET_SEND_TO_PLAYER);
NETuint8_t(&sender);
NETuint8_t(&receiver);
NETnetMessage(&message);
NETend();
if (receiver == NET_ALL_PLAYERS)
{
NETinsertMessageFromNet(NETnetQueue(sender), message); // Message is also for the host.
NETlogPacket(message->type, message->rawLen(), true);
// Not sure if flushing here can make a difference, maybe it can:
//NETflush(); // Send the message to everyone as fast as possible.
}
}
else
{
debug(LOG_INFO, "Report this: Player %d sent us message type (%d) addressed to %d from %d. We are %d.", (int)playerQueue.index, (int)message->type, (int)receiver, (int)sender, selectedPlayer);
}
break;
}
case NET_SHARE_GAME_QUEUE:
{
uint8_t player = 0;
uint32_t num = 0, n;
NetMessage const *message = NULL;
// Encoded in NETprocessSystemMessage in nettypes.cpp.
NETbeginDecode(playerQueue, NET_SHARE_GAME_QUEUE);
NETuint8_t(&player);
NETuint32_t(&num);
bool isSentByCorrectClient = responsibleFor(playerQueue.index, player);
isSentByCorrectClient = isSentByCorrectClient || (playerQueue.index == NET_HOST_ONLY && playerQueue.index != selectedPlayer); // Let host spoof other people's NET_SHARE_GAME_QUEUE messages, but not our own. This allows the host to spoof a GAME_PLAYER_LEFT message (but spoofing any message when the player is still there will fail with desynch).
if (!isSentByCorrectClient || player >= MAX_PLAYERS)
{
break;
}
for (n = 0; n < num; ++n)
{
NETnetMessage(&message);
NETinsertMessageFromNet(NETgameQueue(player), message);
NETlogPacket(message->type, message->rawLen(), true);
delete message;
message = NULL;
}
if (!NETend())
{
debug(LOG_ERROR, "Bad NET_SHARE_GAME_QUEUE message.");
break;
}
break;
}
case NET_PLAYER_STATS:
{
recvMultiStats(playerQueue);
netPlayersUpdated = true;
break;
}
case NET_PLAYER_INFO:
{
uint32_t indexLen = 0, n;
uint32_t index = MAX_PLAYERS;
int32_t colour = 0;
int32_t position = 0;
int32_t team = 0;
int8_t ai = 0;
int8_t difficulty = 0;
uint8_t skDiff = 0;
bool error = false;
NETbeginDecode(playerQueue, NET_PLAYER_INFO);
NETuint32_t(&indexLen);
if (indexLen > MAX_PLAYERS || (playerQueue.index != NET_HOST_ONLY && indexLen > 1))
{
debug(LOG_ERROR, "MSG_PLAYER_INFO: Bad number of players updated: %u", indexLen);
NETend();
break;
}
for (n = 0; n < indexLen; ++n)
{
bool wasAllocated = false;
char oldName[sizeof(NetPlay.players[index].name)];
// Retrieve the player's ID
NETuint32_t(&index);
// Bail out if the given ID number is out of range
if (index >= MAX_CONNECTED_PLAYERS || (playerQueue.index != NetPlay.hostPlayer && (playerQueue.index != index || !NetPlay.players[index].allocated)))
{
debug(LOG_ERROR, "MSG_PLAYER_INFO from %u: Player ID (%u) out of range (max %u)", playerQueue.index, index, (unsigned int)MAX_CONNECTED_PLAYERS);
error = true;
break;
}
// Retrieve the rest of the data
wasAllocated = NetPlay.players[index].allocated;
NETbool(&NetPlay.players[index].allocated);
NETbool(&NetPlay.players[index].heartbeat);
NETbool(&NetPlay.players[index].kick);
strncpy(oldName, NetPlay.players[index].name, sizeof(NetPlay.players[index].name));
NETstring(NetPlay.players[index].name, sizeof(NetPlay.players[index].name));
NETuint32_t(&NetPlay.players[index].heartattacktime);
NETint32_t(&colour);
NETint32_t(&position);
NETint32_t(&team);
NETbool(&NetPlay.players[index].ready);
NETint8_t(&ai);
NETint8_t(&difficulty);
NETuint8_t(&skDiff);
// Don't let anyone except the host change these, otherwise it will end up inconsistent at some point, and the game gets really messed up.
if (playerQueue.index == NetPlay.hostPlayer)
{
NetPlay.players[index].colour = colour;
NetPlay.players[index].position = position;
NetPlay.players[index].team = team;
NetPlay.players[index].ai = ai;
NetPlay.players[index].difficulty = difficulty;
game.skDiff[index] = skDiff; // This one might be possible to calculate from the other values. // TODO game.skDiff should probably be eliminated somehow.
}
debug(LOG_NET, "%s for player %u (%s)", n == 0? "Receiving MSG_PLAYER_INFO" : " and", (unsigned int)index, NetPlay.players[index].allocated ? "human" : "AI");
// update the color to the local array
setPlayerColour(index, NetPlay.players[index].colour);
if (wasAllocated && NetPlay.players[index].allocated && strncmp(oldName, NetPlay.players[index].name, sizeof(NetPlay.players[index].name)) != 0)
{
printConsoleNameChange(oldName, NetPlay.players[index].name);
}
}
NETend();
// If we're the game host make sure to send the updated
// data to all other clients as well.
if (NetPlay.isHost && !error)
{
NETBroadcastPlayerInfo(index);
NETfixDuplicatePlayerNames();
}
netPlayersUpdated = true;
break;
}
case NET_PLAYER_JOINED:
{
uint8_t index;
NETbeginDecode(playerQueue, NET_PLAYER_JOINED);
NETuint8_t(&index);
NETend();
debug(LOG_NET, "Receiving NET_PLAYER_JOINED for player %u using socket %p",
(unsigned int)index, bsocket);
MultiPlayerJoin(index);
netPlayersUpdated = true;
break;
}
// This message type is when player is leaving 'nicely', and socket is still valid.
case NET_PLAYER_LEAVING:
{
uint32_t index;
NETbeginDecode(playerQueue, NET_PLAYER_LEAVING);
NETuint32_t(&index);
NETend();
if (playerQueue.index != NetPlay.hostPlayer && index != playerQueue.index)
{
debug(LOG_ERROR, "Player %d left, but accidentally set player %d as leaving.", playerQueue.index, index);
index = playerQueue.index;
}
if(connected_bsocket[index])
{
debug(LOG_NET, "Receiving NET_PLAYER_LEAVING for player %u on socket %p", (unsigned int)index, connected_bsocket[index]);
}
else
{ // dropped from join screen most likely
debug(LOG_NET, "Receiving NET_PLAYER_LEAVING for player %u (no socket?)", (unsigned int)index);
}
if (NetPlay.isHost)
{
debug(LOG_NET, "Broadcast leaving message to everyone else");
NETbeginEncode(NETbroadcastQueue(), NET_PLAYER_LEAVING);
NETuint32_t(&index);
NETend();
}
debug(LOG_INFO, "Player %u has left the game.", index);
NETplayerLeaving(index); // need to close socket for the player that left.
NETsetPlayerConnectionStatus(CONNECTIONSTATUS_PLAYER_LEAVING, index);
break;
}
case NET_GAME_FLAGS:
{
debug(LOG_NET, "Receiving game flags");
NETbeginDecode(playerQueue, NET_GAME_FLAGS);
{
static unsigned int max_flags = ARRAY_SIZE(NetGameFlags);
// Retrieve the amount of game flags that we should receive
uint8_t i, count;
NETuint8_t(&count);
// Make sure that we won't get buffer overflows by checking that we
// have enough space to store the given amount of game flags.
if (count > max_flags)
{
debug(LOG_NET, "NET_GAME_FLAGS: More game flags sent (%u) than our buffer can hold (%u)", (unsigned int)count, max_flags);
count = max_flags;
}
// Retrieve all game flags
for (i = 0; i < count; ++i)
{
NETint32_t(&NetGameFlags[i]);
}
}
NETend();
if (NetPlay.isHost)
{
NETsendGameFlags();
}
break;
}
case NET_DEBUG_SYNC:
{
recvDebugSync(playerQueue);
break;
}
default:
return false;
}
NETpop(playerQueue);
return true;
}
/*
* Checks to see if a human player is still with us.
* @note: resuscitation isn't possible with current code, so once we lose
* the socket, then we have no way to connect with them again. Future
* item to enhance.
*/
static void NETcheckPlayers(void)
{
if (!NetPlay.isHost)
{
ASSERT(false, "Host only routine detected for client or not hosting yet!");
return;
}
for (int i = 0; i< MAX_PLAYERS ; i++)
{
if (NetPlay.players[i].allocated == 0) continue; // not allocated means that it most likely it is a AI player
if (NetPlay.players[i].heartbeat == 0 && NetPlay.players[i].heartattacktime == 0) // looks like they are dead
{
NetPlay.players[i].heartattacktime = realTime; // mark when this occured
}
else
{
if (NetPlay.players[i].heartattacktime)
{
if (NetPlay.players[i].heartattacktime + (15 * GAME_TICKS_PER_SEC) < realTime) // wait 15 secs
{
debug(LOG_NET, "Kicking due to client heart attack");
NetPlay.players[i].kick = true; // if still dead, then kick em.
}
}
}
if (NetPlay.players[i].kick)
{
debug(LOG_NET, "Kicking player %d", i);
kickPlayer(i, "you are unwanted by the host.", ERROR_KICKED);
}
}
}
// ////////////////////////////////////////////////////////////////////////
// Receive a message over the current connection. We return true if there
// is a message for the higher level code to process, and false otherwise.
// We should not block here.
bool NETrecvNet(NETQUEUE *queue, uint8_t *type)
{
uint32_t current;
if (!NetPlay.bComms)
{
return false;
}
if (NetPlay.isHost)
{
NETfixPlayerCount();
NETallowJoining();
NETcheckPlayers(); // make sure players are still alive & well
}
if (socket_set == NULL || checkSockets(socket_set, NET_READ_TIMEOUT) <= 0)
{
goto checkMessages;
}
for (current = 0; current < MAX_CONNECTED_PLAYERS; ++current)
{
Socket **pSocket = NetPlay.isHost ? &connected_bsocket[current] : &bsocket;
uint8_t buffer[NET_BUFFER_SIZE];
size_t dataLen;
if (!NetPlay.isHost && current != NET_HOST_ONLY)
{
continue; // Don't have a socket open to this player.
}
if (*pSocket == NULL)
{
continue;
}
dataLen = NET_fillBuffer(pSocket, socket_set, buffer, sizeof(buffer));
if (dataLen > 0)
{
// we received some data, add to buffer
NETinsertRawData(NETnetQueue(current), buffer, dataLen);
}
else if (*pSocket == NULL)
{
// If there is a error in NET_fillBuffer() then socket is already invalid.
// This means that the player dropped / disconnected for whatever reason.
debug(LOG_INFO, "Player, (player %u) seems to have dropped/disconnected.", (unsigned)current);
if (NetPlay.isHost)
{
// Send message type specifically for dropped / disconnects
NETplayerDropped(current);
connected_bsocket[current] = NULL; // clear their socket
}
else
{
// lobby errors were set in NET_fillBuffer()
return false;
}
}
}
checkMessages:
for (current = 0; current < MAX_CONNECTED_PLAYERS; ++current)
{
*queue = NETnetQueue(current);
while (NETisMessageReady(*queue))
{
*type = NETgetMessage(*queue)->type;
if (!NETprocessSystemMessage(*queue, *type))
{
return true; // We couldn't process the message, let the caller deal with it..
}
}
}
return false;
}
bool NETrecvGame(NETQUEUE *queue, uint8_t *type)
{
for (unsigned current = 0; current < MAX_PLAYERS; ++current)
{
*queue = NETgameQueue(current);
while (!checkPlayerGameTime(current)) // Check for any messages that are scheduled to be read now.
{
if (!NETisMessageReady(*queue))
{
return false; // Still waiting for messages from this player, and all players should process messages in the same order. Will have to freeze the game while waiting.
}
*type = NETgetMessage(*queue)->type;
if (*type == GAME_GAME_TIME)
{
recvPlayerGameTime(*queue);
NETpop(*queue);
continue;
}
return true; // Have a message ready to read now.
}
}
return false; // No messages sceduled to be read yet. Game can continue.
}
// ////////////////////////////////////////////////////////////////////////
// File Transfer programs.
/** Send file. It returns % of file sent when 100 it's complete. Call until it returns 100.
* @TODO: more error checking (?) different file types (?)
* Maybe should close file handle, and seek each time?
*
* @NOTE: MAX_FILE_TRANSFER_PACKET is set to 2k per packet since 7*2 = 14K which is pretty
* much our limit. Don't screw with that without having a bigger buffer!
* NET_BUFFER_SIZE is at 16k. (also remember text chat, plus all the other cruff)
*/
#define MAX_FILE_TRANSFER_PACKET 2048
int NETsendFile(char *fileName, Sha256 const &fileHash, UDWORD player)
{
uint32_t bytesToRead = 0;
uint8_t sendto = 0;
uint8_t inBuff[MAX_FILE_TRANSFER_PACKET];
// We are not the host, so we don't care. (in fact, this would be a error)
if (!NetPlay.isHost)
{
debug(LOG_ERROR, "trying to send a file and we are not the host!");
return true;
}
memset(inBuff, 0x0, sizeof(inBuff));
// read some bytes.
bytesToRead = PHYSFS_read(NetPlay.players[player].wzFile.pFileHandle, inBuff, 1, MAX_FILE_TRANSFER_PACKET);
ASSERT_OR_RETURN(100, (int32_t)bytesToRead >= 0, "Error reading file.");
sendto = (uint8_t) player;
NETbeginEncode(NETnetQueue(sendto), NET_FILE_PAYLOAD);
NETint32_t(&NetPlay.players[player].wzFile.fileSize_32); // total bytes in this file. (we don't support 64bit yet)
NETuint32_t(&bytesToRead); // bytes in this packet
NETint32_t(&NetPlay.players[player].wzFile.currPos); // start byte
if (NetPlay.players[player].wzFile.currPos == 0)
{
NETstring(fileName, 256); //256 = max filename size
NETbin(const_cast<uint8_t *>(fileHash.bytes), fileHash.Bytes); // const_cast ok since we're encoding, not decoding.
}
NETbin(inBuff, bytesToRead);
NETend();
NetPlay.players[player].wzFile.currPos += bytesToRead; // update position!
if(NetPlay.players[player].wzFile.currPos == NetPlay.players[player].wzFile.fileSize_32)
{
PHYSFS_close(NetPlay.players[player].wzFile.pFileHandle);
NetPlay.players[player].wzFile.isSending = false; // we are done sending to this client.
NetPlay.players[player].needFile = false;
}
return (NetPlay.players[player].wzFile.currPos * 100) / NetPlay.players[player].wzFile.fileSize_32;
}
/* @TODO more error checking (?) different file types (?) */
// recv file. it returns % of the file so far recvd.
UBYTE NETrecvFile(NETQUEUE queue)
{
uint32_t bytesToRead = 0;
int32_t fileSize = 0, currPos = 0;
uint8_t outBuff[MAX_FILE_TRANSFER_PACKET];
static bool isLoop = false;
memset(outBuff, 0x0, sizeof(outBuff));
//read incoming bytes.
NETbeginDecode(queue, NET_FILE_PAYLOAD);
NETint32_t(&fileSize); // total bytes in this file.
NETuint32_t(&bytesToRead); // bytes in this packet
NETint32_t(&currPos); // start byte
if (currPos == 0) // first packet!
{
char mapName[256];
Sha256 fileHash;
memset(mapName, 0x0, sizeof(mapName));
fileHash.setZero();
// Read filename and hash (only valid on 1st packet)
NETstring(mapName, 256);
NETbin(fileHash.bytes, fileHash.Bytes);
removeWildcards(mapName);
char fileName[256];
if (strlen(mapName) >= 3 && mapName[strlen(mapName) - 3] == '-' && mapName[strlen(mapName) - 2] == 'T' && unsigned(mapName[strlen(mapName) - 1] - '1') < 3)
{
mapName[strlen(mapName) - 3] = '\0'; // Cut off "-T1", "-T2" or "-T3".
}
snprintf(fileName, sizeof(fileName), "maps/%dc-%s-%s.wz", game.maxPlayers, mapName, fileHash.toString().c_str()); // Wonder whether game.maxPlayers is initialised already?
debug(LOG_INFO, "Creating new file %s hash %s", fileName, fileHash.toString().c_str());
if (PHYSFS_exists(fileName))
{
PHYSFS_file *fin;
fin = PHYSFS_openRead(fileName);
if (!fin)
{
NETend();
// the file exists, but we can't open it, and I have no clue how to fix this...
debug(LOG_FATAL, "PHYSFS_openRead(\"%s\") failed with error: %s\n", fileName, PHYSFS_getLastError());
debug(LOG_NET, "We are leaving 'nicely' after a fatal error");
NETbeginEncode(NETnetQueue(NET_HOST_ONLY), NET_PLAYER_LEAVING);
{
uint32_t id = selectedPlayer;
NETuint32_t(&id);
}
NETend();
abort();
}
Sha256 ourHash = findHashOfFile(fileName);
if (ourHash == fileHash)
{
uint32_t reason = ALREADY_HAVE_FILE;
debug(LOG_NET, "We already have the file %s! ", fileName);
PHYSFS_close(fin);
NETend();
NETbeginEncode(NETnetQueue(NET_HOST_ONLY), NET_FILE_CANCELLED);
NETuint32_t(&selectedPlayer);
NETuint32_t(&reason);
NETend();
if (!isLoop)
{
isLoop = true;
}
else
{
uint32_t reason = STUCK_IN_FILE_LOOP;
NETend();
// we should never get here, it means, that the game can't detect the level, but we have the file.
// so we kick this player out.
NETbeginEncode(NETnetQueue(NET_HOST_ONLY), NET_FILE_CANCELLED);
NETuint32_t(&selectedPlayer);
NETuint32_t(&reason);
NETend();
PHYSFS_close(NetPlay.pMapFileHandle);
NetPlay.pMapFileHandle = NULL;
debug(LOG_FATAL, "Something is really wrong with the file's (%s) data, game can't detect it?", fileName);
}
return 100;
}
PHYSFS_close(fin);
debug(LOG_NET, "We already have the file %s, but wrong hash, ours %s vs theirs %s. Redownloading", fileName, ourHash.toString().c_str(), fileHash.toString().c_str());
}
NetPlay.pMapFileHandle = PHYSFS_openWrite(fileName); // create a new file.
sstrcpy(NetPlay.mapFileName, fileName);
}
debug(LOG_NET, "New file position is %d", currPos);
if (!NetPlay.pMapFileHandle) // file can't be opened
{
debug(LOG_FATAL, "Fatal error while creating file: %s", PHYSFS_getLastError());
debug(LOG_FATAL, "Either we do not have write permission, or the host sent us a invalid file!");
abort();
}
if (bytesToRead > sizeof(outBuff))
{
debug(LOG_ERROR, "Error receiving file from host.");
NETend();
return 100;
}
NETbin(outBuff, bytesToRead);
NETend();
//write packet to the file.
PHYSFS_write(NetPlay.pMapFileHandle, outBuff, bytesToRead, 1);
if (currPos + bytesToRead == fileSize) // last packet
{
int noError = PHYSFS_close(NetPlay.pMapFileHandle);
if (noError == 0)
{
debug(LOG_ERROR, "Could not close file handle after trying to save map: %s", PHYSFS_getLastError());
}
NetPlay.pMapFileHandle = NULL;
PHYSFS_File *file = PHYSFS_openRead(NetPlay.mapFileName);
int actualFileSize = PHYSFS_fileLength(file);
PHYSFS_close(file);
NetPlay.mapFileName[0] = '\0';
ASSERT(actualFileSize == fileSize, "Downloaded map too small! Got %d, expected %d!", actualFileSize, fileSize);
}
//return the percentage count
return ((currPos + bytesToRead) * 100) / fileSize;
}
static ssize_t readLobbyResponse(Socket* sock, unsigned int timeout)
{
uint32_t lobbyStatusCode;
uint32_t MOTDLength;
uint32_t buffer[2];
ssize_t result, received = 0;
// Get status and message length
result = readAll(sock, &buffer, sizeof(buffer), timeout);
if (result != sizeof(buffer))
goto error;
received += result;
lobbyStatusCode = ntohl(buffer[0]);
MOTDLength = ntohl(buffer[1]);
// Get status message
free(NetPlay.MOTD);
NetPlay.MOTD = (char *)malloc(MOTDLength + 1);
result = readAll(sock, NetPlay.MOTD, MOTDLength, timeout);
if (result != MOTDLength)
goto error;
received += result;
// NUL terminate string
NetPlay.MOTD[MOTDLength] = '\0';
if (lobbyStatusCode / 100 != 2) // Check whether status code is 2xx (success)
{
debug(LOG_ERROR, "Lobby error (%u): %s", (unsigned int)lobbyStatusCode, NetPlay.MOTD);
return received;
}
debug(LOG_NET, "Lobby success (%u): %s", (unsigned int)lobbyStatusCode, NetPlay.MOTD);
return received;
error:
if (result == SOCKET_ERROR)
{
free(NetPlay.MOTD);
if (asprintf(&NetPlay.MOTD, "Error while connecting to the lobby server: %s\nMake sure port %d can receive incoming connections.", strSockError(getSockErr()), gameserver_port) == -1)
NetPlay.MOTD = NULL;
debug(LOG_ERROR, "%s", NetPlay.MOTD);
}
else
{
free(NetPlay.MOTD);
if (asprintf(&NetPlay.MOTD, "Disconnected from lobby server. Failed to register game.") == -1)
NetPlay.MOTD = NULL;
debug(LOG_ERROR, "%s", NetPlay.MOTD);
}
return SOCKET_ERROR;
}
static void NETregisterServer(int state)
{
static Socket* rs_socket = NULL;
static int registered = 0;
if (server_not_there)
{
return;
}
if (state != registered)
{
switch(state)
{
// Update player counts
case WZ_SERVER_UPDATE:
{
if (!NETsendGAMESTRUCT(rs_socket, &gamestruct))
{
socketClose(rs_socket);
rs_socket = NULL;
}
}
break;
// Register a game with the lobby
case WZ_SERVER_CONNECT:
{
uint32_t gameId = 0;
SocketAddress *const hosts = resolveHost(masterserver_name, masterserver_port);
if (hosts == NULL)
{
debug(LOG_ERROR, "Cannot resolve masterserver \"%s\": %s", masterserver_name, strSockError(getSockErr()));
free(NetPlay.MOTD);
if (asprintf(&NetPlay.MOTD, _("Could not resolve masterserver name (%s)!"), masterserver_name) == -1)
NetPlay.MOTD = NULL;
server_not_there = true;
return;
}
// Close an existing socket.
if (rs_socket != NULL)
{
socketClose(rs_socket);
rs_socket = NULL;
}
// try each address from resolveHost until we successfully connect.
rs_socket = socketOpenAny(hosts, 1500);
deleteSocketAddress(hosts);
// No address succeeded.
if (rs_socket == NULL)
{
debug(LOG_ERROR, "Cannot connect to masterserver \"%s:%d\": %s", masterserver_name, masterserver_port, strSockError(getSockErr()));
free(NetPlay.MOTD);
if (asprintf(&NetPlay.MOTD, _("Error connecting to the lobby server: %s.\nMake sure port %d can receive incoming connections.\nIf you're using a router configure it to use UPnP\n or to forward the port to your system."),
strSockError(getSockErr()), masterserver_port) == -1)
NetPlay.MOTD = NULL;
server_not_there = true;
return;
}
// Get a game ID
if (writeAll(rs_socket, "gaId", sizeof("gaId")) == SOCKET_ERROR
|| readAll(rs_socket, &gameId, sizeof(gameId), 10000) != sizeof(gameId))
{
free(NetPlay.MOTD);
if (asprintf(&NetPlay.MOTD, "Failed to retrieve a game ID: %s", strSockError(getSockErr())) == -1)
NetPlay.MOTD = NULL;
debug(LOG_ERROR, "%s", NetPlay.MOTD);
// The socket has been invalidated, so get rid of it. (using them now may cause SIGPIPE).
socketClose(rs_socket);
rs_socket = NULL;
server_not_there = true;
return;
}
gamestruct.gameId = ntohl(gameId);
debug(LOG_NET, "Using game ID: %u", (unsigned int)gamestruct.gameId);
// Register our game with the server
if (writeAll(rs_socket, "addg", sizeof("addg")) == SOCKET_ERROR
// and now send what the server wants
|| !NETsendGAMESTRUCT(rs_socket, &gamestruct))
{
debug(LOG_ERROR, "Failed to register game with server: %s", strSockError(getSockErr()));
socketClose(rs_socket);
server_not_there = true;
rs_socket = NULL;
}
if (readLobbyResponse(rs_socket, NET_TIMEOUT_DELAY) == SOCKET_ERROR)
{
socketClose(rs_socket);
server_not_there = true;
rs_socket = NULL;
return;
}
// Preserves another register
registered = state;
}
break;
// Unregister the game (close the socket)
case WZ_SERVER_DISCONNECT:
{
if (rs_socket != NULL)
{
// we don't need this anymore, so clean up
socketClose(rs_socket);
rs_socket = NULL;
server_not_there = true;
}
// Preserves another unregister
registered = state;
}
break;
}
}
}
// ////////////////////////////////////////////////////////////////////////
// Check player "slots" & update player count if needed.
void NETfixPlayerCount(void)
{
int maxPlayers = game.maxPlayers;
int playercount = 0;
for (int index = 0; index < game.maxPlayers; ++index)
{
if (NetPlay.players[index].ai == AI_CLOSED)
{
--maxPlayers;
}
else if (NetPlay.players[index].ai != AI_OPEN || NetPlay.players[index].allocated)
{
++playercount;
}
}
if (allow_joining && NetPlay.isHost && (NetPlay.playercount != playercount || gamestruct.desc.dwMaxPlayers != maxPlayers))
{
debug(LOG_NET, "Updating player count from %d/%d to %d/%d", (int)NetPlay.playercount, gamestruct.desc.dwMaxPlayers, playercount, maxPlayers);
gamestruct.desc.dwCurrentPlayers = NetPlay.playercount = playercount;
gamestruct.desc.dwMaxPlayers = maxPlayers;
NETregisterServer(WZ_SERVER_UPDATE);
}
}
// ////////////////////////////////////////////////////////////////////////
// Host a game with a given name and player name. & 4 user game flags
static void NETallowJoining(void)
{
unsigned int i;
char buffer[10] = {'\0'};
char* p_buffer;
int32_t result;
bool connectFailed = true;
int32_t major, minor;
ssize_t recv_result = 0;
if (allow_joining == false) return;
ASSERT(NetPlay.isHost, "Cannot receive joins if not host!");
NETregisterServer(WZ_SERVER_CONNECT);
// This is here since we need to get the status, before we can show the info.
// FIXME: find better location to stick this?
if (!NetPlay.ShowedMOTD)
{
ShowMOTD();
NetPlay.ShowedMOTD = true;
}
if (tmp_socket_set == NULL)
{
// initialize server socket set
// FIXME: why is this not done in NETinit()?? - Per
tmp_socket_set = allocSocketSet();
if (tmp_socket_set == NULL)
{
debug(LOG_ERROR, "Cannot create socket set: %s", strSockError(getSockErr()));
return;
}
}
// Find the first empty socket slot
for (i = 0; i < MAX_TMP_SOCKETS; ++i)
{
if (tmp_socket[i] == NULL)
{
break;
}
}
if (i == MAX_TMP_SOCKETS)
{
// this should *never* happen, it would mean we are going to reuse a socket already in use.
debug(LOG_ERROR, "all temp sockets are used up!");
return;
}
// See if there's an incoming connection
if (tmp_socket[i] == NULL // Make sure that we're not out of sockets
&& (tmp_socket[i] = socketAccept(tcp_socket)) != NULL)
{
NETinitQueue(NETnetTmpQueue(i));
SocketSet_AddSocket(tmp_socket_set, tmp_socket[i]);
p_buffer = buffer;
// We check for socket activity (connection), and then we check if we got data, since it is possible to have a connection
// and have no data waiting.
if (checkSockets(tmp_socket_set, NET_TIMEOUT_DELAY) > 0
&& socketReadReady(tmp_socket[i])
&& (recv_result = readNoInt(tmp_socket[i], p_buffer, 8))
&& recv_result != SOCKET_ERROR)
{
// A 2.3.7 client sends a "list" command first, just drop the connection.
if (strcmp(buffer, "list") == 0)
{
debug(LOG_INFO, "An old client tried to connect, closing the socket.");
NETlogEntry("Dropping old client.", SYNC_FLAG, i);
connectFailed = true;
}
else
{
// New clients send NETCODE_VERSION_MAJOR and NETCODE_VERSION_MINOR
// Check these numbers with our own.
memcpy(&major, p_buffer, sizeof(int32_t));
major = ntohl(major);
p_buffer += sizeof(int32_t);
memcpy(&minor, p_buffer, sizeof(int32_t));
minor = ntohl(minor);
if (NETisCorrectVersion(major, minor))
{
result = htonl(ERROR_NOERROR);
memcpy(&buffer, &result, sizeof(result));
writeAll(tmp_socket[i], &buffer, sizeof(result));
socketBeginCompression(tmp_socket[i]);
// Connection is successful.
connectFailed = false;
}
else
{
debug(LOG_ERROR, "Received an invalid version \"%d.%d\".", major, minor);
result = htonl(ERROR_WRONGVERSION);
memcpy(&buffer, &result, sizeof(result));
writeAll(tmp_socket[i], &buffer, sizeof(result));
NETlogEntry("Invalid game version", SYNC_FLAG, i);
connectFailed = true;
}
if ((int)NetPlay.playercount == gamestruct.desc.dwMaxPlayers)
{
// early player count test, in case they happen to get in before updates.
// Tell the player that we are full.
uint8_t rejected = ERROR_FULL;
NETbeginEncode(NETnetTmpQueue(i), NET_REJECTED);
NETuint8_t(&rejected);
NETend();
NETflush();
connectFailed = true;
}
}
}
else
{
debug(LOG_NET, "Failed to process joining, socket not ready or no data, recv_result is :%d", (int)recv_result);
connectFailed = true;
}
// Remove a failed connection.
if (connectFailed)
{
debug(LOG_NET, "freeing temp socket %p (%d)", tmp_socket[i], __LINE__);
SocketSet_DelSocket(tmp_socket_set, tmp_socket[i]);
socketClose(tmp_socket[i]);
tmp_socket[i] = NULL;
}
}
if (checkSockets(tmp_socket_set, NET_READ_TIMEOUT) > 0)
{
for(i = 0; i < MAX_TMP_SOCKETS; ++i)
{
if ( tmp_socket[i] != NULL
&& socketReadReady(tmp_socket[i]))
{
uint8_t buffer[NET_BUFFER_SIZE];
ssize_t size = readNoInt(tmp_socket[i], buffer, sizeof(buffer));
if ((size == 0 && socketReadDisconnected(tmp_socket[i])) || size == SOCKET_ERROR)
{
// disconnect or programmer error
if (size == 0)
{
debug(LOG_NET, "Client socket disconnected.");
}
else
{
debug(LOG_NET, "Client socket encountered error: %s", strSockError(getSockErr()));
}
NETlogEntry("Client socket disconnected (allowJoining)", SYNC_FLAG, i);
debug(LOG_NET, "freeing temp socket %p (%d)", tmp_socket[i], __LINE__);
SocketSet_DelSocket(tmp_socket_set, tmp_socket[i]);
socketClose(tmp_socket[i]);
tmp_socket[i] = NULL;
continue;
}
NETinsertRawData(NETnetTmpQueue(i), buffer, size);
if (NETisMessageReady(NETnetTmpQueue(i)) && NETgetMessage(NETnetTmpQueue(i))->type == NET_JOIN)
{
uint8_t j;
uint8_t index;
uint8_t rejected = 0;
int tmp;
char name[64];
char ModList[modlist_string_size] = { '\0' };
char GamePassword[password_string_size] = { '\0' };
NETbeginDecode(NETnetTmpQueue(i), NET_JOIN);
NETstring(name, sizeof(name));
NETstring(ModList, sizeof(ModList));
NETstring(GamePassword, sizeof(GamePassword));
NETend();
tmp = NET_CreatePlayer(name);
if (tmp == -1)
{
debug(LOG_ERROR, "freeing temp socket %p, couldn't create player!", tmp_socket[i]);
// Tell the player that we are full.
uint8_t rejected = ERROR_FULL;
NETbeginEncode(NETnetTmpQueue(i), NET_REJECTED);
NETuint8_t(&rejected);
NETend();
NETflush();
NETpop(NETnetTmpQueue(i));
SocketSet_DelSocket(tmp_socket_set, tmp_socket[i]);
socketClose(tmp_socket[i]);
tmp_socket[i] = NULL;
sync_counter.cantjoin++;
return;
}
NETpop(NETnetTmpQueue(i));
index = tmp;
debug(LOG_NET, "freeing temp socket %p (%d), creating permanent socket.", tmp_socket[i], __LINE__);
SocketSet_DelSocket(tmp_socket_set, tmp_socket[i]);
connected_bsocket[index] = tmp_socket[i];
tmp_socket[i] = NULL;
SocketSet_AddSocket(socket_set, connected_bsocket[index]);
NETmoveQueue(NETnetTmpQueue(i), NETnetQueue(index));
// Copy players ip Address.
sstrcpy(NetPlay.players[index].IPtextAddress, getSocketTextAddress(connected_bsocket[index]));
if (onBanList(NetPlay.players[index].IPtextAddress))
{
char buf[256] = {'\0'};
ssprintf(buf, "** A player that you have kicked tried to rejoin the game, and was rejected. IP: %s", NetPlay.players[index].IPtextAddress);
debug(LOG_INFO, "%s", buf);
NETlogEntry(buf, SYNC_FLAG, i);
// Player has been kicked before, kick again.
rejected = (uint8_t)ERROR_KICKED;
}
else if (NetPlay.GamePassworded && strcmp(NetPlay.gamePassword, GamePassword) != 0)
{
// Wrong password. Reject.
rejected = (uint8_t)ERROR_WRONGPASSWORD;
}
else if ((int)NetPlay.playercount > gamestruct.desc.dwMaxPlayers)
{
// Game full. Reject.
rejected = (uint8_t)ERROR_FULL;
}
else if (strcmp(getModList(), ModList) != 0)
{
// Incompatible mods. Reject.
rejected = (uint8_t)ERROR_WRONGDATA;
}
if (rejected)
{
char buf[256] = {'\0'};
ssprintf(buf, "**Rejecting player(%s), reason (%u). ", NetPlay.players[index].IPtextAddress, (unsigned int) rejected);
debug(LOG_INFO, "%s", buf);
NETlogEntry(buf, SYNC_FLAG, index);
NETbeginEncode(NETnetQueue(index), NET_REJECTED);
NETuint8_t(&rejected);
NETend();
NETflush();
allow_joining = false; // no need to inform master server
NET_DestroyPlayer(index);
allow_joining = true;
SocketSet_DelSocket(socket_set, connected_bsocket[index]);
socketClose(connected_bsocket[index]);
connected_bsocket[index] = NULL;
return;
}
NETbeginEncode(NETnetQueue(index), NET_ACCEPTED);
NETuint8_t(&index);
NETend();
// First send info about players to newcomer.
NETSendAllPlayerInfoTo(index);
// then send info about newcomer to all players.
NETBroadcastPlayerInfo(index);
char buf[250] = {'\0'};
snprintf(buf, sizeof(buf), "Player %s has joined, IP is: %s", name, NetPlay.players[index].IPtextAddress);
debug(LOG_INFO, "%s", buf);
NETlogEntry(buf, SYNC_FLAG, index);
debug(LOG_NET, "Player, %s, with index of %u has joined using socket %p", name, (unsigned int)index, connected_bsocket[index]);
// Increment player count
gamestruct.desc.dwCurrentPlayers++;
MultiPlayerJoin(index);
// Narrowcast to new player that everyone has joined.
for (j = 0; j < MAX_CONNECTED_PLAYERS; ++j)
{
if (index != j) // We will broadcast the index == j case.
{
if (NetPlay.players[j].allocated)
{
NETbeginEncode(NETnetQueue(index), NET_PLAYER_JOINED);
NETuint8_t(&j);
NETend();
}
}
}
// Broadcast to everyone that a new player has joined
NETbeginEncode(NETbroadcastQueue(), NET_PLAYER_JOINED);
NETuint8_t(&index);
NETend();
for (j = 0; j < MAX_CONNECTED_PLAYERS; ++j)
{
NETBroadcastPlayerInfo(j);
}
NETfixDuplicatePlayerNames();
// Send the updated GAMESTRUCT to the masterserver
NETregisterServer(WZ_SERVER_UPDATE);
// reset flags for new players
NetPlay.players[index].wzFile.isCancelled = false;
NetPlay.players[index].wzFile.isSending = false;
NetPlay.players[index].needFile = false;
}
}
}
}
}
bool NEThostGame(const char* SessionName, const char* PlayerName,
SDWORD one, SDWORD two, SDWORD three, SDWORD four,
UDWORD plyrs) // # of players.
{
unsigned int i;
debug(LOG_NET, "NEThostGame(%s, %s, %d, %d, %d, %d, %u)", SessionName, PlayerName,
one, two, three, four, plyrs);
mapDownloadProgress = 100;
netPlayersUpdated = true;
NET_InitPlayers();
for (unsigned n = 0; n < MAX_PLAYERS_IN_GUI; ++n)
{
changeColour(n, rand()%(n + 1), true); // Put colours in random order.
}
if(!NetPlay.bComms)
{
selectedPlayer = 0;
NetPlay.isHost = true;
NetPlay.players[0].allocated = true;
NetPlay.players[0].connection = -1;
NetPlay.playercount = 1;
debug(LOG_NET, "Hosting but no comms");
// Now switch player color of the host to what they normally use for MP games
if (war_getMPcolour() >= 0)
{
changeColour(NET_HOST_ONLY, war_getMPcolour(), true);
}
return true;
}
// tcp_socket is the connection to the lobby server (or machine)
if (!tcp_socket)
tcp_socket = socketListen(gameserver_port);
if(tcp_socket == NULL)
{
debug(LOG_ERROR, "Cannot connect to master self: %s", strSockError(getSockErr()));
return false;
}
debug(LOG_NET, "New tcp_socket = %p", tcp_socket);
// Host needs to create a socket set for MAX_PLAYERS
if(!socket_set) socket_set = allocSocketSet();
if (socket_set == NULL)
{
debug(LOG_ERROR, "Cannot create socket set: %s", strSockError(getSockErr()));
return false;
}
// allocate socket storage for all possible players
for (i = 0; i < MAX_CONNECTED_PLAYERS; ++i)
{
connected_bsocket[i] = NULL;
NETinitQueue(NETnetQueue(i));
}
NetPlay.isHost = true;
NETlogEntry("Hosting game, resetting ban list.", SYNC_FLAG, 0);
if (IPlist)
{
free(IPlist);
IPlist = NULL;
}
sstrcpy(gamestruct.name, SessionName);
memset(&gamestruct.desc, 0, sizeof(gamestruct.desc));
gamestruct.desc.dwSize = sizeof(gamestruct.desc);
//gamestruct.desc.guidApplication = GAME_GUID;
memset(gamestruct.desc.host, 0, sizeof(gamestruct.desc.host));
gamestruct.desc.dwCurrentPlayers = 1;
gamestruct.desc.dwMaxPlayers = plyrs;
gamestruct.desc.dwFlags = 0;
gamestruct.desc.dwUserFlags[0] = one;
gamestruct.desc.dwUserFlags[1] = two;
gamestruct.desc.dwUserFlags[2] = three;
gamestruct.desc.dwUserFlags[3] = four;
memset(gamestruct.secondaryHosts, 0, sizeof(gamestruct.secondaryHosts));
sstrcpy(gamestruct.extra, "Extra"); // extra string (future use)
sstrcpy(gamestruct.mapname, game.map); // map we are hosting
sstrcpy(gamestruct.hostname, PlayerName);
sstrcpy(gamestruct.versionstring, versionString); // version (string)
sstrcpy(gamestruct.modlist, getModList()); // List of mods
gamestruct.GAMESTRUCT_VERSION = 3; // version of this structure
gamestruct.game_version_major = NETCODE_VERSION_MAJOR; // Netcode Major version
gamestruct.game_version_minor = NETCODE_VERSION_MINOR; // NetCode Minor version
// gamestruct.privateGame = 0; // if true, it is a private game
gamestruct.pureGame = 0; // NO mods allowed if true
gamestruct.Mods = 0; // number of concatenated mods?
gamestruct.gameId = 0;
gamestruct.limits = 0x0; // used for limits
gamestruct.future3 = 0xBAD03; // for future use
gamestruct.future4 = 0xBAD04; // for future use
selectedPlayer = NET_CreatePlayer(PlayerName);
ASSERT_OR_RETURN(false, selectedPlayer < MAX_PLAYERS, "Failed to create player");
realSelectedPlayer = selectedPlayer;
NetPlay.isHost = true;
NetPlay.isHostAlive = true;
NetPlay.hostPlayer = NET_HOST_ONLY;
ASSERT(selectedPlayer == NET_HOST_ONLY, "For now, host must start at player index zero, was %d", (int)selectedPlayer);
MultiPlayerJoin(selectedPlayer);
// Now switch player color of the host to what they normally use for SP games
if (war_getMPcolour() >= 0)
{
changeColour(NET_HOST_ONLY, war_getMPcolour(), true);
}
allow_joining = true;
NETregisterServer(WZ_SERVER_DISCONNECT);
debug(LOG_NET, "Hosting a server. We are player %d.", selectedPlayer);
return true;
}
// ////////////////////////////////////////////////////////////////////////
// Stop the dplay interface from accepting more players.
bool NEThaltJoining(void)
{
debug(LOG_NET, "temporarily locking game to prevent more players");
allow_joining = false;
// disconnect from the master server
NETregisterServer(WZ_SERVER_DISCONNECT);
return true;
}
// ////////////////////////////////////////////////////////////////////////
// find games on open connection
bool NETfindGame(void)
{
SocketAddress* hosts;
unsigned int gamecount = 0;
uint32_t gamesavailable;
int result = 0;
debug(LOG_NET, "Looking for games...");
if (getLobbyError() == ERROR_INVALID || getLobbyError() == ERROR_KICKED || getLobbyError() == ERROR_HOSTDROPPED)
{
return false;
}
setLobbyError(ERROR_NOERROR);
NetPlay.games[0].desc.dwSize = 0;
NetPlay.games[0].desc.dwCurrentPlayers = 0;
NetPlay.games[0].desc.dwMaxPlayers = 0;
if(!NetPlay.bComms)
{
selectedPlayer = NET_HOST_ONLY; // Host is always 0
NetPlay.isHost = true;
NetPlay.hostPlayer = NET_HOST_ONLY;
return true;
}
if ((hosts = resolveHost(masterserver_name, masterserver_port)) == NULL)
{
debug(LOG_ERROR, "Cannot resolve hostname \"%s\": %s", masterserver_name, strSockError(getSockErr()));
setLobbyError(ERROR_CONNECTION);
return false;
}
if (tcp_socket != NULL)
{
debug(LOG_NET, "Deleting tcp_socket %p", tcp_socket);
if (socket_set)
{
SocketSet_DelSocket(socket_set, tcp_socket);
}
socketClose(tcp_socket);
tcp_socket = NULL;
}
tcp_socket = socketOpenAny(hosts, 15000);
deleteSocketAddress(hosts);
hosts = NULL;
if (tcp_socket == NULL)
{
debug(LOG_ERROR, "Cannot connect to \"%s:%d\": %s", masterserver_name, masterserver_port, strSockError(getSockErr()));
setLobbyError(ERROR_CONNECTION);
return false;
}
debug(LOG_NET, "New tcp_socket = %p", tcp_socket);
// client machines only need 1 socket set
socket_set = allocSocketSet();
if (socket_set == NULL)
{
debug(LOG_ERROR, "Cannot create socket set: %s", strSockError(getSockErr()));
setLobbyError(ERROR_CONNECTION);
return false;
}
debug(LOG_NET, "Created socket_set %p", socket_set);
SocketSet_AddSocket(socket_set, tcp_socket);
debug(LOG_NET, "Sending list cmd");
if (writeAll(tcp_socket, "list", sizeof("list")) != SOCKET_ERROR
&& (result = readAll(tcp_socket, &gamesavailable, sizeof(gamesavailable), NET_TIMEOUT_DELAY)) == sizeof(gamesavailable))
{
gamesavailable = MIN(ntohl(gamesavailable), ARRAY_SIZE(NetPlay.games));
}
else
{
if (result == SOCKET_ERROR)
{
debug(LOG_NET, "Server socket ecountered error: %s", strSockError(getSockErr()));
}
else
{
debug(LOG_NET, "Server didn't respond (timeout)");
}
SocketSet_DelSocket(socket_set, tcp_socket); // mark it invalid
socketClose(tcp_socket);
tcp_socket = NULL;
// when we fail to receive a game count, bail out
setLobbyError(ERROR_CONNECTION);
return false;
}
debug(LOG_NET, "receiving info on %u game(s)", (unsigned int)gamesavailable);
// Clear old games from list.
memset(NetPlay.games, 0x00, sizeof(NetPlay.games));
while (gamecount < gamesavailable)
{
// Attempt to receive a game description structure
if (!NETrecvGAMESTRUCT(&NetPlay.games[gamecount]))
{
debug(LOG_NET, "only %u game(s) received", (unsigned int)gamecount);
// If we fail, success depends on the amount of games that we've read already
SocketSet_DelSocket(socket_set, tcp_socket); // mark it invalid
socketClose(tcp_socket);
tcp_socket = NULL;
return gamecount;
}
if (NetPlay.games[gamecount].desc.host[0] == '\0')
{
memset(NetPlay.games[gamecount].desc.host, 0, sizeof(NetPlay.games[gamecount].desc.host));
strncpy(NetPlay.games[gamecount].desc.host, getSocketTextAddress(tcp_socket), sizeof(NetPlay.games[gamecount].desc.host) - 1);
}
++gamecount;
}
if (readLobbyResponse(tcp_socket, NET_TIMEOUT_DELAY) == SOCKET_ERROR)
{
socketClose(tcp_socket);
tcp_socket = NULL;
addConsoleMessage(_("Failed to get a lobby response!"), DEFAULT_JUSTIFY, NOTIFY_MESSAGE);
return true; // while there was a problem, this isn't fatal for the function
}
SocketSet_DelSocket(socket_set, tcp_socket); // mark it invalid (we are done with it)
socketClose(tcp_socket);
tcp_socket = NULL;
addConsoleMessage(NetPlay.MOTD, DEFAULT_JUSTIFY, SYSTEM_MESSAGE);
return true;
}
// ////////////////////////////////////////////////////////////////////////
// ////////////////////////////////////////////////////////////////////////
// Functions used to setup and join games.
bool NETjoinGame(const char* host, uint32_t port, const char* playername)
{
SocketAddress *hosts = NULL;
unsigned int i;
char buffer[sizeof(int32_t) * 2] = { 0 };
char* p_buffer;
uint32_t result;
if (port == 0)
{
port = gameserver_port;
}
debug(LOG_NET, "resetting sockets.");
NETclose(); // just to be sure :)
debug(LOG_NET, "Trying to join [%s]:%d ...", host, port);
mapDownloadProgress = 100;
netPlayersUpdated = true;
hosts = resolveHost(host, port);
if (hosts == NULL)
{
debug(LOG_ERROR, "Cannot resolve hostname \"%s\": %s", host, strSockError(getSockErr()));
return false;
}
if (tcp_socket != NULL)
{
socketClose(tcp_socket);
}
tcp_socket = socketOpenAny(hosts, 15000);
deleteSocketAddress(hosts);
if (tcp_socket == NULL)
{
debug(LOG_ERROR, "Cannot connect to [%s]:%d, %s", host, port, strSockError(getSockErr()));
return false;
}
// client machines only need 1 socket set
socket_set = allocSocketSet();
if (socket_set == NULL)
{
debug(LOG_ERROR, "Cannot create socket set: %s", strSockError(getSockErr()));
return false;
}
debug(LOG_NET, "Created socket_set %p", socket_set);
// tcp_socket is used to talk to host machine
SocketSet_AddSocket(socket_set, tcp_socket);
// Send NETCODE_VERSION_MAJOR and NETCODE_VERSION_MINOR
p_buffer = buffer;
*(int32_t*)p_buffer = htonl(NETCODE_VERSION_MAJOR);
p_buffer += sizeof(uint32_t);
*(int32_t*)p_buffer = htonl(NETCODE_VERSION_MINOR);
if (writeAll(tcp_socket, buffer, sizeof(buffer)) == SOCKET_ERROR
|| readAll(tcp_socket, &result, sizeof(result), 1500) != sizeof(result))
{
debug(LOG_ERROR, "Couldn't send my version.");
return false;
}
result = ntohl(result);
if (result != ERROR_NOERROR)
{
debug(LOG_ERROR, "Receveid error %d", result);
SocketSet_DelSocket(socket_set, tcp_socket);
socketClose(tcp_socket);
tcp_socket = NULL;
deleteSocketSet(socket_set);
socket_set = NULL;
setLobbyError((LOBBY_ERROR_TYPES)result);
return false;
}
// Allocate memory for a new socket
NETinitQueue(NETnetQueue(NET_HOST_ONLY));
// NOTE: tcp_socket = bsocket now!
bsocket = tcp_socket;
tcp_socket = NULL;
socketBeginCompression(bsocket);
// Send a join message to the host
NETbeginEncode(NETnetQueue(NET_HOST_ONLY), NET_JOIN);
NETstring(playername, 64);
NETstring(getModList(), modlist_string_size);
NETstring(NetPlay.gamePassword, sizeof(NetPlay.gamePassword));
NETend();
if (bsocket == NULL)
{
return false; // Connection dropped while sending NET_JOIN.
}
socketFlush(bsocket); // Make sure the message was completely sent.
i = wzGetTicks();
// Loop until we've been accepted into the game
for (;;)
{
NETQUEUE queue;
uint8_t type;
// FIXME: shouldn't there be some sort of rejection message?
if (wzGetTicks() > i + 5000)
{
// timeout
return false;
}
if (bsocket == NULL)
{
return false; // Connection dropped.
}
if (!NETrecvNet(&queue, &type))
{
continue;
}
if (type == NET_ACCEPTED)
{
// :)
uint8_t index;
NETbeginDecode(queue, NET_ACCEPTED);
// Retrieve the player ID the game host arranged for us
NETuint8_t(&index);
NETend();
NETpop(queue);
selectedPlayer = index;
realSelectedPlayer = selectedPlayer;
debug(LOG_NET, "NET_ACCEPTED received. Accepted into the game - I'm player %u using bsocket %p", (unsigned int)index, bsocket);
NetPlay.isHost = false;
NetPlay.isHostAlive = true;
if (index >= MAX_CONNECTED_PLAYERS)
{
debug(LOG_ERROR, "Bad player number (%u) received from host!", index);
return false;
}
NetPlay.players[index].allocated = true;
sstrcpy(NetPlay.players[index].name, playername);
NetPlay.players[index].heartbeat = true;
return true;
}
else if (type == NET_REJECTED)
{
uint8_t rejection = 0;
NETbeginDecode(queue, NET_REJECTED);
NETuint8_t(&rejection);
NETend();
NETpop(queue);
debug(LOG_NET, "NET_REJECTED received. Error code: %u", (unsigned int) rejection);
setLobbyError((LOBBY_ERROR_TYPES)rejection);
NETclose();
return false;
}
else
{
debug(LOG_ERROR, "Unexpected %s.", messageTypeToString(type));
NETpop(queue);
}
}
}
/*!
* Set the masterserver name
* \param hostname The hostname of the masterserver to connect to
*/
void NETsetMasterserverName(const char* hostname)
{
sstrcpy(masterserver_name, hostname);
}
/**
* @return The hostname of the masterserver we will connect to.
*/
const char* NETgetMasterserverName()
{
return masterserver_name;
}
/*!
* Set the masterserver port
* \param port The port of the masterserver to connect to
*/
void NETsetMasterserverPort(unsigned int port)
{
masterserver_port = port;
}
/**
* @return The port of the masterserver we will connect to.
*/
unsigned int NETgetMasterserverPort()
{
return masterserver_port;
}
/*!
* Set the port we shall host games on
* \param port The port to listen to
*/
void NETsetGameserverPort(unsigned int port)
{
gameserver_port = port;
}
/**
* @return The port we will host games on.
*/
unsigned int NETgetGameserverPort()
{
return gameserver_port;
}
void NETsetPlayerConnectionStatus(CONNECTION_STATUS status, unsigned player)
{
unsigned n;
const int timeouts[] = {GAME_TICKS_PER_SEC*10, GAME_TICKS_PER_SEC*10, GAME_TICKS_PER_SEC, GAME_TICKS_PER_SEC/6};
ASSERT(ARRAY_SIZE(timeouts) == CONNECTIONSTATUS_NORMAL, "Connection status timeout array too small.");
if (player == NET_ALL_PLAYERS)
{
for (n = 0; n < MAX_PLAYERS; ++n)
{
NETsetPlayerConnectionStatus(status, n);
}
return;
}
if (status == CONNECTIONSTATUS_NORMAL)
{
for (n = 0; n < CONNECTIONSTATUS_NORMAL; ++n)
{
NET_PlayerConnectionStatus[n][player] = 0;
}
return;
}
NET_PlayerConnectionStatus[status][player] = realTime + timeouts[status];
}
bool NETcheckPlayerConnectionStatus(CONNECTION_STATUS status, unsigned player)
{
unsigned n;
if (player == NET_ALL_PLAYERS)
{
for (n = 0; n < MAX_PLAYERS; ++n)
{
if (NETcheckPlayerConnectionStatus(status, n))
{
return true;
}
}
return false;
}
if (status == CONNECTIONSTATUS_NORMAL)
{
for (n = 0; n < CONNECTIONSTATUS_NORMAL; ++n)
{
if (NETcheckPlayerConnectionStatus((CONNECTION_STATUS)n, player))
{
return true;
}
}
return false;
}
return realTime < NET_PlayerConnectionStatus[status][player];
}
struct SyncDebugEntry
{
char const *function;
};
struct SyncDebugString : public SyncDebugEntry
{
void set(uint32_t &crc, char const *f, char const *string)
{
function = f;
crc = crcSum(crc, function, strlen(function) + 1);
crc = crcSum(crc, string, strlen(string) + 1);
}
int snprint(char *buf, size_t bufSize, char const *&string) const
{
int ret = snprintf(buf, bufSize, "[%s] %s\n", function, string);
string += strlen(string) + 1;
return ret;
}
};
struct SyncDebugValueChange : public SyncDebugEntry
{
void set(uint32_t &crc, char const *f, char const *vn, int nv, int i)
{
function = f;
variableName = vn;
newValue = nv;
id = i;
uint32_t valueBytes = htonl(newValue);
crc = crcSum(crc, function, strlen(function) + 1);
crc = crcSum(crc, variableName, strlen(variableName) + 1);
crc = crcSum(crc, &valueBytes, 4);
}
int snprint(char *buf, size_t bufSize) const
{
if (id != -1)
{
return snprintf(buf, bufSize, "[%s] %d %s = %d\n", function, id, variableName, newValue);
}
return snprintf(buf, bufSize, "[%s] %s = %d\n", function, variableName, newValue);
}
int newValue;
int id;
char const *variableName;
};
struct SyncDebugIntList : public SyncDebugEntry
{
void set(uint32_t &crc, char const *f, char const *s, int const *ints, size_t num)
{
function = f;
string = s;
uint32_t valueBytes[40];
numInts = std::min(num, ARRAY_SIZE(valueBytes));
for (unsigned n = 0; n < numInts; ++n)
{
valueBytes[n] = htonl(ints[n]);
}
crc = crcSum(crc, valueBytes, 4*numInts);
}
int snprint(char *buf, size_t bufSize, int const *&ints) const
{
size_t index = 0;
if (index < bufSize)
{
index += snprintf(buf + index, bufSize - index, "[%s] ", function);
}
if (index < bufSize)
{
switch (numInts)
{
case 0: index += snprintf(buf + index, bufSize - index, "%s", string); break;
case 1: index += snprintf(buf + index, bufSize - index, string, ints[0]); break;
case 2: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1]); break;
case 3: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2]); break;
case 4: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3]); break;
case 5: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4]); break;
case 6: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5]); break;
case 7: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6]); break;
case 8: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7]); break;
case 9: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8]); break;
case 10: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9]); break;
case 11: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10]); break;
case 12: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11]); break;
case 13: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12]); break;
case 14: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13]); break;
case 15: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14]); break;
case 16: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15]); break;
case 17: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16]); break;
case 18: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17]); break;
case 19: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18]); break;
case 20: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19]); break;
case 21: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20]); break;
case 22: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21]); break;
case 23: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22]); break;
case 24: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23]); break;
case 25: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24]); break;
case 26: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25]); break;
case 27: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26]); break;
case 28: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27]); break;
case 29: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28]); break;
case 30: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28], ints[29]); break;
case 31: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28], ints[29], ints[30]); break;
case 32: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28], ints[29], ints[30], ints[31]); break;
case 33: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28], ints[29], ints[30], ints[31], ints[32]); break;
case 34: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28], ints[29], ints[30], ints[31], ints[32], ints[33]); break;
case 35: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28], ints[29], ints[30], ints[31], ints[32], ints[33], ints[34]); break;
case 36: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28], ints[29], ints[30], ints[31], ints[32], ints[33], ints[34], ints[35]); break;
case 37: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28], ints[29], ints[30], ints[31], ints[32], ints[33], ints[34], ints[35], ints[36]); break;
case 38: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28], ints[29], ints[30], ints[31], ints[32], ints[33], ints[34], ints[35], ints[36], ints[37]); break;
case 39: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28], ints[29], ints[30], ints[31], ints[32], ints[33], ints[34], ints[35], ints[36], ints[37], ints[38]); break;
case 40: index += snprintf(buf + index, bufSize - index, string, ints[0], ints[1], ints[2], ints[3], ints[4], ints[5], ints[6], ints[7], ints[8], ints[9], ints[10], ints[11], ints[12], ints[13], ints[14], ints[15], ints[16], ints[17], ints[18], ints[19], ints[20], ints[21], ints[22], ints[23], ints[24], ints[25], ints[26], ints[27], ints[28], ints[29], ints[30], ints[31], ints[32], ints[33], ints[34], ints[35], ints[36], ints[37], ints[38], ints[39]); break;
default: index += snprintf(buf + index, bufSize - index, "Too many ints in intlist."); break;
}
}
if (index < bufSize)
{
index += snprintf(buf + index, bufSize - index, "\n");
}
ints += numInts;
return index;
}
char const *string;
unsigned numInts;
};
struct SyncDebugLog
{
SyncDebugLog() : time(0), crc(0x00000000) {}
void clear()
{
log.clear();
time = 0;
crc = 0x00000000;
//printf("Freeing %d strings, %d valueChanges, %d intLists, %d chars, %d ints\n", (int)strings.size(), (int)valueChanges.size(), (int)intLists.size(), (int)chars.size(), (int)ints.size());
strings.clear();
valueChanges.clear();
intLists.clear();
chars.clear();
ints.clear();
}
void string(char const *f, char const *s)
{
size_t offset = chars.size();
chars.resize(chars.size() + strlen(s) + 1);
char *buf = &chars[offset];
strcpy(buf, s);
strings.resize(strings.size() + 1);
strings.back().set(crc, f, buf);
log.push_back('s');
}
void valueChange(char const *f, char const *vn, int nv, int i)
{
valueChanges.resize(valueChanges.size() + 1);
valueChanges.back().set(crc, f, vn, nv, i);
log.push_back('v');
}
void intList(char const *f, char const *s, int *begin, size_t num)
{
size_t offset = ints.size();
ints.resize(ints.size() + num);
int *buf = &ints[offset];
std::copy(begin, begin + num, buf);
intLists.resize(intLists.size() + 1);
intLists.back().set(crc, f, s, buf, num);
log.push_back('i');
}
int snprint(char *buf, size_t bufSize)
{
SyncDebugString const *stringPtr = strings.empty()? NULL : &strings[0]; // .empty() check, since &strings[0] is undefined if strings is empty(), even if it's likely to work, anyway.
SyncDebugValueChange const *valueChangePtr = valueChanges.empty()? NULL : &valueChanges[0];
SyncDebugIntList const *intListPtr = intLists.empty()? NULL : &intLists[0];
char const *charPtr = chars.empty()? NULL : &chars[0];
int const *intPtr = ints.empty()? NULL : &ints[0];
int index = 0;
for (size_t n = 0; n < log.size() && (size_t)index < bufSize; ++n)
{
char type = log[n];
switch (type)
{
case 's':
index += stringPtr++->snprint(buf + index, bufSize - index, charPtr);
break;
case 'v':
index += valueChangePtr++->snprint(buf + index, bufSize - index);
break;
case 'i':
index += intListPtr++->snprint(buf + index, bufSize - index, intPtr);
break;
default:
abort();
break;
}
}
return index;
}
uint32_t getGameTime() const
{
return time;
}
uint32_t getCrc() const
{
return ~crc; // Invert bits, since everyone else seems to do that with CRCs...
}
unsigned getNumEntries() const
{
return log.size();
}
void setGameTime(uint32_t newTime)
{
time = newTime;
}
void setCrc(uint32_t newCrc)
{
crc = ~newCrc; // Invert bits, since everyone else seems to do that with CRCs...
}
private:
std::vector<char> log;
uint32_t time;
uint32_t crc;
std::vector<SyncDebugString> strings;
std::vector<SyncDebugValueChange> valueChanges;
std::vector<SyncDebugIntList> intLists;
std::vector<char> chars;
std::vector<int> ints;
private:
SyncDebugLog(SyncDebugLog const &)/* = delete*/;
SyncDebugLog &operator =(SyncDebugLog const &)/* = delete*/;
};
#define MAX_LEN_LOG_LINE 512 // From debug.c - no use printing something longer.
#define MAX_SYNC_HISTORY 12
static unsigned syncDebugNext = 0;
static SyncDebugLog syncDebugLog[MAX_SYNC_HISTORY];
static uint32_t syncDebugExtraGameTime;
static uint32_t syncDebugExtraCrc;
static uint32_t syncDebugNumDumps = 0;
void _syncDebug(const char *function, const char *str, ...)
{
#ifdef WZ_CC_MSVC
char const *f = function; while (*f != '\0') if (*f++ == ':') function = f; // Strip "Class::" from "Class::myFunction".
#endif
va_list ap;
char outputBuffer[MAX_LEN_LOG_LINE];
va_start(ap, str);
vssprintf(outputBuffer, str, ap);
va_end(ap);
syncDebugLog[syncDebugNext].string(function, outputBuffer);
}
void _syncDebugIntList(const char *function, const char *str, int *ints, size_t numInts)
{
#ifdef WZ_CC_MSVC
char const *f = function; while (*f != '\0') if (*f++ == ':') function = f; // Strip "Class::" from "Class::myFunction".
#endif
syncDebugLog[syncDebugNext].intList(function, str, ints, numInts);
}
void _syncDebugBacktrace(const char *function)
{
#ifdef WZ_CC_MSVC
char const *f = function; while (*f != '\0') if (*f++ == ':') function = f; // Strip "Class::" from "Class::myFunction".
#endif
uint32_t backupCrc = syncDebugLog[syncDebugNext].getCrc(); // Ignore CRC changes from _syncDebug(), since identical backtraces can be printed differently.
#ifdef WZ_OS_LINUX
void *btv[20];
unsigned num = backtrace(btv, sizeof(btv)/sizeof(*btv));
char **btc = backtrace_symbols(btv, num);
unsigned i;
for (i = 1; i + 2 < num; ++i) // =1: Don't print "src/warzone2100(syncDebugBacktrace+0x16) [0x6312d1]". +2: Don't print last two lines of backtrace such as "/lib/libc.so.6(__libc_start_main+0xe6) [0x7f91e040ea26]", since the address varies (even with the same binary).
{
_syncDebug("BT", "%s", btc[i]);
}
free(btc);
#else
_syncDebug("BT", "Sorry, syncDebugBacktrace() not implemented on your system. Called from %s.", function);
#endif
// Use CRC of something platform-independent, to avoid false positive desynchs.
backupCrc = ~crcSum(~backupCrc, function, strlen(function) + 1);
syncDebugLog[syncDebugNext].setCrc(backupCrc);
}
uint32_t syncDebugGetCrc()
{
return syncDebugLog[syncDebugNext].getCrc();
}
void syncDebugSetCrc(uint32_t crc)
{
syncDebugLog[syncDebugNext].setCrc(crc);
}
void resetSyncDebug()
{
for (unsigned i = 0; i < MAX_SYNC_HISTORY; ++i)
{
syncDebugLog[i].clear();
}
syncDebugExtraGameTime = 0;
syncDebugExtraCrc = 0xFFFFFFFF;
syncDebugNext = 0;
syncDebugNumDumps = 0;
}
GameCrcType nextDebugSync()
{
uint32_t ret = syncDebugLog[syncDebugNext].getCrc();
// Save gameTime, so we know which CRC to compare with, later.
syncDebugLog[syncDebugNext].setGameTime(gameTime);
// Go to next position, and free it ready for use.
syncDebugNext = (syncDebugNext + 1)%MAX_SYNC_HISTORY;
syncDebugLog[syncDebugNext].clear();
return (GameCrcType)ret;
}
static void dumpDebugSync(uint8_t *buf, size_t bufLen, uint32_t time, unsigned player)
{
char fname[100];
PHYSFS_file *fp;
ssprintf(fname, "logs/desync%u_p%u.txt", time, player);
fp = openSaveFile(fname);
PHYSFS_write(fp, buf, bufLen, 1);
PHYSFS_close(fp);
debug(LOG_ERROR, "Dumped player %u's sync error at gameTime %u to file: %s%s", player, time, PHYSFS_getRealDir(fname), fname);
}
static void sendDebugSync(uint8_t *buf, uint32_t bufLen, uint32_t time)
{
// Save our own, before sending, so that if we have 2 clients running on the same computer, to guarantee that it is done saving before the other client saves on top.
dumpDebugSync(buf, bufLen, time, selectedPlayer);
NETbeginEncode(NETbroadcastQueue(), NET_DEBUG_SYNC);
NETuint32_t(&time);
NETuint32_t(&bufLen);
NETbin(buf, bufLen);
NETend();
}
static uint8_t debugSyncTmpBuf[2000000];
static void recvDebugSync(NETQUEUE queue)
{
uint32_t time = 0;
uint32_t bufLen = 0;
NETbeginDecode(queue, NET_DEBUG_SYNC);
NETuint32_t(&time);
NETuint32_t(&bufLen);
bufLen = MIN(bufLen, ARRAY_SIZE(debugSyncTmpBuf));
NETbin(debugSyncTmpBuf, bufLen);
NETend();
dumpDebugSync(debugSyncTmpBuf, bufLen, time, queue.index);
}
bool checkDebugSync(uint32_t checkGameTime, GameCrcType checkCrc)
{
if (checkGameTime == syncDebugLog[syncDebugNext].getGameTime()) // Can't happen - and syncDebugGameTime[] == 0, until just before sending the CRC, anyway.
{
debug(LOG_ERROR, "Huh? We aren't done yet...");
return true;
}
unsigned logIndex;
for (logIndex = 0; logIndex < MAX_SYNC_HISTORY; ++logIndex)
{
if (syncDebugLog[logIndex].getGameTime() == checkGameTime)
{
if ((GameCrcType)syncDebugLog[logIndex].getCrc() == checkCrc)
{
return true; // Check passed. (So far... There might still be more players to compare CRCs with.)
}
break; // Check failed!
}
}
if (logIndex >= MAX_SYNC_HISTORY && syncDebugExtraGameTime == checkGameTime)
{
if ((GameCrcType)syncDebugExtraCrc == checkCrc)
{
return true;
}
}
if (logIndex >= MAX_SYNC_HISTORY)
{
return false; // Couldn't check. May have dumped already, or MAX_SYNC_HISTORY isn't big enough compared to the maximum latency.
}
size_t bufIndex = 0;
// Dump our version, and also erase it, so we only dump it at most once.
debug(LOG_ERROR, "Inconsistent sync debug at gameTime %u. My version has %u entries, CRC = 0x%08X.", syncDebugLog[logIndex].getGameTime(), syncDebugLog[logIndex].getNumEntries(), syncDebugLog[logIndex].getCrc());
bufIndex += snprintf((char *)debugSyncTmpBuf + bufIndex, ARRAY_SIZE(debugSyncTmpBuf) - bufIndex, "===== BEGIN gameTime=%u, %u entries, CRC 0x%08X =====\n", syncDebugLog[logIndex].getGameTime(), syncDebugLog[logIndex].getNumEntries(), syncDebugLog[logIndex].getCrc());
bufIndex = MIN(bufIndex, ARRAY_SIZE(debugSyncTmpBuf)); // snprintf will not overflow debugSyncTmpBuf, but returns as much as it would have printed if possible.
bufIndex += syncDebugLog[logIndex].snprint((char *)debugSyncTmpBuf + bufIndex, ARRAY_SIZE(debugSyncTmpBuf) - bufIndex);
bufIndex = MIN(bufIndex, ARRAY_SIZE(debugSyncTmpBuf)); // snprintf will not overflow debugSyncTmpBuf, but returns as much as it would have printed if possible.
bufIndex += snprintf((char *)debugSyncTmpBuf + bufIndex, ARRAY_SIZE(debugSyncTmpBuf) - bufIndex, "===== END gameTime=%u, %u entries, CRC 0x%08X =====\n", syncDebugLog[logIndex].getGameTime(), syncDebugLog[logIndex].getNumEntries(), syncDebugLog[logIndex].getCrc());
bufIndex = MIN(bufIndex, ARRAY_SIZE(debugSyncTmpBuf)); // snprintf will not overflow debugSyncTmpBuf, but returns as much as it would have printed if possible.
if (syncDebugNumDumps < 2)
{
++syncDebugNumDumps;
sendDebugSync(debugSyncTmpBuf, bufIndex, syncDebugLog[logIndex].getGameTime());
}
// Backup correct CRC for checking against remaining players, even though we erased the logs (which were dumped already).
syncDebugExtraGameTime = syncDebugLog[logIndex].getGameTime();
syncDebugExtraCrc = syncDebugLog[logIndex].getCrc();
// Finish erasing our version.
syncDebugLog[logIndex].clear();
return false; // Ouch.
}
const char *messageTypeToString(unsigned messageType_)
{
MESSAGE_TYPES messageType = (MESSAGE_TYPES)messageType_; // Cast to enum, so switch gives a warning if new message types are added without updating the switch.
switch (messageType)
{
// Search: ^\s*([\w_]+).*
// Replace: case \1: return "\1";
// Search: (case ...............................) *(return "[\w_]+";)
// Replace: \t\t\1\2
// Net-related messages.
case NET_MIN_TYPE: return "NET_MIN_TYPE";
case NET_PING: return "NET_PING";
case NET_PLAYER_STATS: return "NET_PLAYER_STATS";
case NET_TEXTMSG: return "NET_TEXTMSG";
case NET_PLAYERRESPONDING: return "NET_PLAYERRESPONDING";
case NET_OPTIONS: return "NET_OPTIONS";
case NET_KICK: return "NET_KICK";
case NET_FIREUP: return "NET_FIREUP";
case NET_COLOURREQUEST: return "NET_COLOURREQUEST";
case NET_AITEXTMSG: return "NET_AITEXTMSG";
case NET_BEACONMSG: return "NET_BEACONMSG";
case NET_TEAMREQUEST: return "NET_TEAMREQUEST";
case NET_JOIN: return "NET_JOIN";
case NET_ACCEPTED: return "NET_ACCEPTED";
case NET_PLAYER_INFO: return "NET_PLAYER_INFO";
case NET_PLAYER_JOINED: return "NET_PLAYER_JOINED";
case NET_PLAYER_LEAVING: return "NET_PLAYER_LEAVING";
case NET_PLAYER_DROPPED: return "NET_PLAYER_DROPPED";
case NET_GAME_FLAGS: return "NET_GAME_FLAGS";
case NET_READY_REQUEST: return "NET_READY_REQUEST";
case NET_REJECTED: return "NET_REJECTED";
case NET_POSITIONREQUEST: return "NET_POSITIONREQUEST";
case NET_DATA_CHECK: return "NET_DATA_CHECK";
case NET_HOST_DROPPED: return "NET_HOST_DROPPED";
case NET_SEND_TO_PLAYER: return "NET_SEND_TO_PLAYER";
case NET_SHARE_GAME_QUEUE: return "NET_SHARE_GAME_QUEUE";
case NET_FILE_REQUESTED: return "NET_FILE_REQUESTED";
case NET_FILE_CANCELLED: return "NET_FILE_CANCELLED";
case NET_FILE_PAYLOAD: return "NET_FILE_PAYLOAD";
case NET_DEBUG_SYNC: return "NET_DEBUG_SYNC";
case NET_MAX_TYPE: return "NET_MAX_TYPE";
// Game-state-related messages, must be processed by all clients at the same game time.
case GAME_MIN_TYPE: return "GAME_MIN_TYPE";
case GAME_DROIDINFO: return "GAME_DROIDINFO";
case GAME_STRUCTUREINFO: return "GAME_STRUCTUREINFO";
case GAME_RESEARCHSTATUS: return "GAME_RESEARCHSTATUS";
case GAME_TEMPLATE: return "GAME_TEMPLATE";
case GAME_TEMPLATEDEST: return "GAME_TEMPLATEDEST";
case GAME_ALLIANCE: return "GAME_ALLIANCE";
case GAME_GIFT: return "GAME_GIFT";
case GAME_LASSAT: return "GAME_LASSAT";
case GAME_GAME_TIME: return "GAME_GAME_TIME";
case GAME_PLAYER_LEFT: return "GAME_PLAYER_LEFT";
case GAME_DROIDDISEMBARK: return "GAME_DROIDDISEMBARK";
case GAME_SYNC_REQUEST: return "GAME_SYNC_REQUEST";
// The following messages are used for debug mode.
case GAME_DEBUG_MODE: return "GAME_DEBUG_MODE";
case GAME_DEBUG_ADD_DROID: return "GAME_DEBUG_ADD_DROID";
case GAME_DEBUG_ADD_STRUCTURE: return "GAME_DEBUG_ADD_STRUCTURE";
case GAME_DEBUG_ADD_FEATURE: return "GAME_DEBUG_ADD_FEATURE";
case GAME_DEBUG_REMOVE_DROID: return "GAME_DEBUG_REMOVE_DROID";
case GAME_DEBUG_REMOVE_STRUCTURE: return "GAME_DEBUG_REMOVE_STRUCTURE";
case GAME_DEBUG_REMOVE_FEATURE: return "GAME_DEBUG_REMOVE_FEATURE";
case GAME_DEBUG_FINISH_RESEARCH: return "GAME_DEBUG_FINISH_RESEARCH";
// End of redundant messages.
case GAME_MAX_TYPE: return "GAME_MAX_TYPE";
}
return "(UNUSED)";
}
/**
* Check if ip is on the banned list.
* \param ip IP address converted to text
*/
static bool onBanList(const char *ip)
{
int i;
if (!IPlist) return false; //if no bans are added, then don't check.
for(i = 0; i < MAX_BANS ; i++)
{
if (strcmp(ip, IPlist[i].IPAddress) == 0)
{
return true;
}
}
return false;
}
/**
* Create the banned list.
* \param ip IP address in text format
* \param name Name of the player we are banning
*/
static void addToBanList(const char *ip, const char *name)
{
static int numBans = 0;
if (!IPlist)
{
IPlist = (PLAYER_IP *)malloc(sizeof(PLAYER_IP) * MAX_BANS + 1);
if (!IPlist)
{
debug(LOG_FATAL, "Out of memory!");
abort();
}
numBans = 0;
}
memset(IPlist, 0x0, sizeof(PLAYER_IP) * MAX_BANS);
sstrcpy(IPlist[numBans].IPAddress, ip);
sstrcpy(IPlist[numBans].pname, name);
numBans++;
sync_counter.banned++;
if (numBans > MAX_BANS)
{
debug(LOG_INFO, "We have exceeded %d bans, resetting to 0", MAX_BANS);
numBans = 0;
}
}
Reference in New Issue View Git Blame Copy Permalink