truelight@0: #include "stdafx.h"
truelight@0: #include "ttd.h"
dominik@105: #include "gui.h"
truelight@0: #include "command.h"
truelight@0: #include "player.h"
darkvater@144: #include "console.h"
signde@239: #include "economy.h"
truelight@0: 
truelight@0: #if defined(WIN32)
truelight@0: #	include <windows.h>
truelight@0: #	include <winsock.h>
truelight@0: 
truelight@0: # pragma comment (lib, "ws2_32.lib")
truelight@0: # define ENABLE_NETWORK
truelight@0: # define GET_LAST_ERROR() WSAGetLastError()
truelight@0: # define EWOULDBLOCK WSAEWOULDBLOCK
truelight@0: #endif
truelight@0: 
truelight@0: #if defined(UNIX)
truelight@0: // Make compatible with WIN32 names
truelight@0: #	define SOCKET int
truelight@0: #	define INVALID_SOCKET -1
truelight@0: // we need different defines for MorphOS and AmigaOS
truelight@0: #if !defined(__MORPHOS__) && !defined(__AMIGA__)
truelight@0: #	define ioctlsocket ioctl
truelight@0: # define closesocket close
truelight@0: # define GET_LAST_ERROR() errno
truelight@0: #endif
truelight@0: // Need this for FIONREAD on solaris
truelight@0: #	define BSD_COMP
truelight@0: #	include <unistd.h>
truelight@0: #	include <sys/ioctl.h>
truelight@0: 
truelight@0: // Socket stuff
truelight@0: #	include <sys/socket.h>
truelight@0: #	include <netinet/in.h>
truelight@0: #	include <arpa/inet.h>
truelight@0: # 	include <errno.h>
truelight@0: # 	include <sys/time.h>
truelight@0: // NetDB
truelight@0: #   include <netdb.h>
truelight@0: 
truelight@0: # ifndef TCP_NODELAY
truelight@0: #  define TCP_NODELAY 0x0001
truelight@0: # endif
truelight@0: 
truelight@0: #endif
truelight@0: 
truelight@0: 
truelight@0: #if defined(__MORPHOS__) || defined(__AMIGA__)
truelight@0: #	include <exec/types.h>
truelight@0: #	include <proto/exec.h> 		// required for Open/CloseLibrary()
truelight@0: #	if defined(__MORPHOS__)
truelight@0: #		include <sys/filio.h> 	// FION#? defines
truelight@0: #	else // __AMIGA__
truelight@0: #		include	<proto/socket.h>
truelight@0: #	endif
truelight@0: 
truelight@0: // make source compatible with bsdsocket.library functions
truelight@0: # define closesocket(s)     						CloseSocket(s)
truelight@0: # define GET_LAST_ERROR() 							Errno()
truelight@0: #	define ioctlsocket(s,request,status)  IoctlSocket((LONG)s,(ULONG)request,(char*)status)
truelight@0: 
truelight@0: struct Library *SocketBase = NULL;
darkvater@144: 
darkvater@173: #if !defined(__MORPHOS__)
darkvater@144: // usleep() implementation
darkvater@144: #include <devices/timer.h>
darkvater@144: #include <dos/dos.h>
darkvater@144: 
darkvater@144: struct Device       *TimerBase    = NULL;
darkvater@144: struct MsgPort      *TimerPort    = NULL;
darkvater@144: struct timerequest  *TimerRequest = NULL;
darkvater@173: #endif
darkvater@144: 
truelight@0: #endif /* __MORPHOS__ || __AMIGA__ */
truelight@0: 
truelight@0: 
truelight@0: #define SEND_MTU 1460
truelight@0: 
truelight@0: #if defined(ENABLE_NETWORK)
truelight@0: 
signde@206: enum {
signde@206: 	PACKET_TYPE_WELCOME = 0,
signde@206: 	PACKET_TYPE_READY,
signde@206: 	PACKET_TYPE_ACK,
signde@206: 	PACKET_TYPE_SYNC,
signde@208: 	PACKET_TYPE_FSYNC,
signde@206: 	PACKET_TYPE_XMIT,
signde@206: 	PACKET_TYPE_COMMAND,
signde@239: 	PACKET_TYPE_EVENT,
signde@206: };
signde@206: 
truelight@0: // sent from client -> server whenever the client wants to exec a command.
truelight@0: // send from server -> client when another player execs a command.
truelight@0: typedef struct CommandPacket {
truelight@0: 	byte packet_length;
truelight@0: 	byte packet_type;
truelight@0: 	uint16 cmd;
truelight@0: 	uint32 p1,p2;
truelight@0: 	TileIndex tile;
truelight@0: 	byte player;// player id, this is checked by the server.
truelight@0: 	byte when;  // offset from the current max_frame value minus 1. this is set by the server.
dominik@281: 	uint32 dp[8];
truelight@0: } CommandPacket;
truelight@0: 
signde@239: typedef struct EventPacket {
signde@239: 	byte packet_length;
signde@239: 	byte packet_type;
signde@239: 	byte event_type;
signde@239: 	byte data_start;
signde@239: } EventPacket;
signde@239: 
truelight@0: #define COMMAND_PACKET_BASE_SIZE (sizeof(CommandPacket) - 8 * sizeof(uint32))
truelight@0: 
truelight@0: // sent from server -> client periodically to tell the client about the current tick in the server
truelight@0: // and how far the client may progress.
truelight@0: typedef struct SyncPacket {
truelight@0: 	byte packet_length;
truelight@0: 	byte packet_type;
truelight@0: 	byte frames; // how many more frames may the client execute? this is relative to the old value of max.
truelight@0: 	byte server; // where is the server currently executing? this is negatively relative to the old value of max.
truelight@0: 	uint32 random_seed_1; // current random state at server. used to detect out of sync.
truelight@0: 	uint32 random_seed_2;
truelight@0: } SyncPacket;
truelight@0: 
signde@208: typedef struct FrameSyncPacket {
signde@208: 	byte packet_length;
signde@208: 	byte packet_type;
signde@208: 	byte frames; // where is the server currently executing? this is negatively relative to the old value of max.
signde@208: } FrameSyncPacket;
signde@208: 
truelight@0: // sent from server -> client as an acknowledgement that the server received the command.
truelight@0: // the command will be executed at the current value of "max".
truelight@0: typedef struct AckPacket {
truelight@0: 	byte packet_length;
truelight@0: 	byte packet_type;
signde@208: 	int16 when;
truelight@0: } AckPacket;
truelight@0: 
truelight@185: typedef struct ReadyPacket {
truelight@185: 	byte packet_length;
truelight@185: 	byte packet_type;
truelight@185: } ReadyPacket;
truelight@185: 
truelight@0: typedef struct FilePacketHdr {
truelight@0: 	byte packet_length;
truelight@0: 	byte packet_type;
truelight@0: } FilePacketHdr;
truelight@0: 
truelight@0: // sent from server to client when the client has joined.
truelight@0: typedef struct WelcomePacket {
truelight@0: 	byte packet_length;
truelight@0: 	byte packet_type;
signde@206: 	uint32 player_seeds[MAX_PLAYERS][2];
signde@206: 	uint32 frames_max;
signde@206: 	uint32 frames_srv;
signde@206: 	uint32 frames_cnt;
truelight@0: } WelcomePacket;
truelight@0: 
truelight@0: typedef struct Packet Packet;
truelight@0: struct Packet {
truelight@0: 	Packet *next; // this one has to be the first element.
truelight@0: 	uint siz;
truelight@0: 	byte buf[SEND_MTU]; // packet payload
truelight@0: };
truelight@0: 
truelight@0: typedef struct ClientState {
truelight@0: 	int socket;
truelight@0: 	bool inactive; // disable sending of commands/syncs to client
truelight@0: 	bool writable;
truelight@185: 	bool ready;
truelight@185: 	uint timeout;
truelight@0: 	uint xmitpos;
truelight@0: 
truelight@0: 	uint eaten;
truelight@0: 	Packet *head, **last;
truelight@0: 
truelight@0: 	uint buflen;											// receive buffer len
signde@206: 	byte buf[1024];										// receive buffer
truelight@0: } ClientState;
truelight@0: 
truelight@0: 
truelight@0: typedef struct QueuedCommand QueuedCommand;
truelight@0: struct QueuedCommand {
truelight@0: 	QueuedCommand *next;
truelight@0: 	CommandPacket cp;
truelight@0: 	CommandCallback *callback;
truelight@0: 	uint32 cmd;
signde@206: 	uint32 frame;
truelight@0: };
truelight@0: 
truelight@0: typedef struct CommandQueue CommandQueue;
truelight@0: struct CommandQueue {
truelight@0: 	QueuedCommand *head, **last;
truelight@0: };
truelight@0: 
truelight@0: #define MAX_CLIENTS (MAX_PLAYERS + 1)
truelight@0: 
truelight@0: // packets waiting to be executed, for each of the players.
truelight@0: // this list is sorted in frame order, so the item on the front will be executed first.
truelight@0: static CommandQueue _command_queue;
truelight@0: 
truelight@0: // in the client, this is the list of commands that have not yet been acked.
truelight@0: // when it is acked, it will be moved to the appropriate position at the end of the player queue.
truelight@0: static CommandQueue _ack_queue;
truelight@0: 
truelight@0: static ClientState _clients[MAX_CLIENTS];
truelight@0: static int _num_clients;
truelight@0: 
truelight@0: // keep a history of the 16 most recent seeds to be able to capture out of sync errors.
truelight@0: static uint32 _my_seed_list[16][2];
truelight@185: static bool _network_ready_sent;
signde@208: static uint32 _frame_fsync_last;
truelight@0: 
truelight@0: typedef struct FutureSeeds {
signde@206: 	uint32 frame;
truelight@0: 	uint32 seed[2];
truelight@0: } FutureSeeds;
truelight@0: 
truelight@0: // remember some future seeds that the server sent to us.
truelight@0: static FutureSeeds _future_seed[8];
darkvater@175: static uint _num_future_seed;
truelight@0: 
dominik@105: static SOCKET _listensocket; // tcp socket
truelight@0: 
dominik@105: static SOCKET _udp_client_socket; // udp server socket
dominik@105: static SOCKET _udp_server_socket; // udp client socket
truelight@0: 
truelight@0: typedef struct UDPPacket {
truelight@0: 	byte command_code;
truelight@0: 	byte data_len;
truelight@0: 	byte command_check;
truelight@0: 	byte data[255];
truelight@0: } UDPPacket;
truelight@0: 
truelight@0: enum {
truelight@0: 	NET_UDPCMD_SERVERSEARCH = 1,
truelight@0: 	NET_UDPCMD_SERVERACTIVE,
dominik@105: 	NET_UDPCMD_GETSERVERINFO,
dominik@105: 	NET_UDPCMD_SERVERINFO,
truelight@0: };
truelight@0: 
dominik@105: void NetworkUDPSend(bool client, struct sockaddr_in recv,struct UDPPacket packet);
darkvater@213: static void HandleCommandPacket(ClientState *cs, CommandPacket *np);
signde@206: static void CloseClient(ClientState *cs);
signde@206: void NetworkSendWelcome(ClientState *cs, bool direct);
truelight@0: 
dominik@105: uint32 _network_ip_list[10]; // network ip list
truelight@0: 
truelight@0: // this is set to point to the savegame
truelight@0: static byte *_transmit_file;
truelight@0: static size_t _transmit_file_size;
truelight@0: 
truelight@0: static FILE *_recv_file;
truelight@0: 
dominik@105: /* multi os compatible sleep function */
dominik@105: void CSleep(int milliseconds) {
dominik@105: #if defined(WIN32)
dominik@105: Sleep(milliseconds);
dominik@105: #endif
dominik@105: #if defined(UNIX)
truelight@193: #if !defined(__BEOS__) && !defined(__MORPHOS__) && !defined(__AMIGAOS__)
dominik@105: usleep(milliseconds*1000);
dominik@105: #endif
dominik@105: #ifdef __BEOS__
dominik@105: snooze(milliseconds*1000);
dominik@105: #endif
truelight@193: #if defined(__MORPHOS__)
darkvater@173: usleep(milliseconds*1000);
darkvater@173: #endif
truelight@193: #if defined(__AMIGAOS__) && !defined(__MORPHOS__)
truelight@193: {
darkvater@144: 	ULONG signals;
darkvater@144: 	ULONG TimerSigBit = 1 << TimerPort->mp_SigBit;
darkvater@144: 
darkvater@144: 	// send IORequest
darkvater@144: 	TimerRequest->tr_node.io_Command = TR_ADDREQUEST;
darkvater@144: 	TimerRequest->tr_time.tv_secs    = (milliseconds * 1000) / 1000000;
darkvater@144: 	TimerRequest->tr_time.tv_micro   = (milliseconds * 1000) % 1000000;
darkvater@144: 	SendIO((struct IORequest *)TimerRequest);
darkvater@144: 
darkvater@144: 	if ( !((signals = Wait(TimerSigBit|SIGBREAKF_CTRL_C)) & TimerSigBit) ) {
darkvater@144: 		AbortIO((struct IORequest *)TimerRequest);
darkvater@144: 	}
darkvater@144: 	WaitIO((struct IORequest *)TimerRequest);
darkvater@144: }
darkvater@173: #endif // __AMIGAOS__ && !__MORPHOS__
dominik@105: #endif
dominik@105: }
dominik@105: 
truelight@0: //////////////////////////////////////////////////////////////////////
truelight@0: 
dominik@105: // ****************************** //
darkvater@172: // * Network Error Handlers     * //
darkvater@172: // ****************************** //
darkvater@172: 
truelight@185: static void NetworkHandleSaveGameError()
truelight@185: {
darkvater@172: 		_networking_sync = false;
darkvater@172: 		_networking_queuing = true;
darkvater@172: 		_switch_mode = SM_MENU;
darkvater@172: 		_switch_mode_errorstr = STR_NETWORK_ERR_SAVEGAMEERROR;
darkvater@172: }
darkvater@172: 
truelight@185: static void NetworkHandleConnectionLost()
truelight@185: {
darkvater@172: 		_networking_sync = false;
darkvater@172: 		_networking_queuing = true;
darkvater@172: 		_switch_mode = SM_MENU;
darkvater@172: 		_switch_mode_errorstr = STR_NETWORK_ERR_LOSTCONNECTION;
darkvater@172: }
darkvater@211: 
truelight@185: static void NetworkHandleDeSync()
truelight@185: {
signde@269: 	DEBUG(net, 0) ("NET: error: network sync error at frame %i", _frame_counter);
truelight@185: 	{
truelight@185: 		int i;
signde@269: 		for (i=15; i>=0; i--) DEBUG(net,0) ("NET frame %i: [0]=%i, [1]=%i",_frame_counter-(i+1),_my_seed_list[i][0],_my_seed_list[i][1]);
signde@269: 		for (i=0; i<8; i++) DEBUG(net,0) ("NET frame %i: [0]=%i, [1]=%i",_frame_counter+i,_future_seed[i].seed[0],_future_seed[i].seed[1]);
truelight@185: 	}
truelight@185: 	_networking_sync = false;
truelight@185: 	_networking_queuing = true;
truelight@185: 	_switch_mode = SM_MENU;
truelight@185: 	_switch_mode_errorstr = STR_NETWORK_ERR_DESYNC;
darkvater@172: }
darkvater@172: 
darkvater@172: // ****************************** //
dominik@105: // * TCP Packets and Handlers   * //
dominik@105: // ****************************** //
dominik@105: 
truelight@0: static QueuedCommand *AllocQueuedCommand(CommandQueue *nq)
truelight@0: {
truelight@0: 	QueuedCommand *qp = (QueuedCommand*)calloc(sizeof(QueuedCommand), 1);
truelight@0: 	assert(qp);
truelight@0: 	*nq->last = qp;
truelight@0: 	nq->last = &qp->next;
truelight@0: 	return qp;
truelight@0: }
truelight@0: 
darkvater@211: static void QueueClear(CommandQueue *nq)
darkvater@211: {
signde@206: 	QueuedCommand *qp;
signde@206: 	while ((qp=nq->head)) {
signde@206: 		// unlink it.
signde@206: 		if (!(nq->head = qp->next)) nq->last = &nq->head;
signde@206: 		free(qp);
signde@206: 		}
signde@206: 	nq->last = &nq->head;
signde@206: }
signde@206: 
signde@208: static int GetNextSyncFrame()
signde@208: {
signde@208: 	uint32 newframe;
signde@262: 	if (_frame_fsync_last == 0) return -11;
signde@262: 	newframe = (_frame_fsync_last + 11); // do not use a multiple of 4 since that screws up sync-packets
signde@208: 	return (_frame_counter_max - newframe);
signde@208: 
signde@208: }
signde@208: 
truelight@0: // go through the player queues for each player and see if there are any pending commands
truelight@0: // that should be executed this frame. if there are, execute them.
truelight@0: void NetworkProcessCommands()
truelight@0: {
truelight@0: 	CommandQueue *nq;
truelight@0: 	QueuedCommand *qp;
truelight@260: 	byte old_player;
truelight@0: 
truelight@0: 	// queue mode ?
truelight@0: 	if (_networking_queuing)
truelight@0: 		return;
truelight@0: 
truelight@0: 	nq = &_command_queue;
truelight@0: 	while ( (qp=nq->head) && (!_networking_sync || qp->frame <= _frame_counter)) {
truelight@0: 		// unlink it.
truelight@0: 		if (!(nq->head = qp->next)) nq->last = &nq->head;
truelight@0: 
truelight@0: 		if (qp->frame < _frame_counter && _networking_sync) {
signde@239: 			DEBUG(net,0) ("warning: !qp->cp.frame < _frame_counter, %d < %d [%d]\n", qp->frame, _frame_counter, _frame_counter_srv+4);
truelight@0: 		}
truelight@0: 
truelight@0: 		// run the command
truelight@260: 		old_player = _current_player;
truelight@0: 		_current_player = qp->cp.player;
truelight@0: 		memcpy(_decode_parameters, qp->cp.dp, (qp->cp.packet_length - COMMAND_PACKET_BASE_SIZE));
truelight@185: 
truelight@0: 		DoCommandP(qp->cp.tile, qp->cp.p1, qp->cp.p2, qp->callback, qp->cmd | CMD_DONT_NETWORK);
truelight@0: 		free(qp);
truelight@260: 		_current_player = old_player;
truelight@0: 	}
truelight@0: 
truelight@0: 	if (!_networking_server) {
truelight@0: 		// remember the random seed so we can check if we're out of sync.
truelight@0: 		_my_seed_list[_frame_counter & 15][0] = _sync_seed_1;
truelight@0: 		_my_seed_list[_frame_counter & 15][1] = _sync_seed_2;
truelight@0: 
truelight@0: 		while (_num_future_seed) {
truelight@0: 			assert(_future_seed[0].frame >= _frame_counter);
truelight@0: 			if (_future_seed[0].frame != _frame_counter) break;
darkvater@172: 			if (_future_seed[0].seed[0] != _sync_seed_1 ||_future_seed[0].seed[1] != _sync_seed_2) NetworkHandleDeSync();
tron@425: 			memmove(_future_seed, _future_seed + 1, --_num_future_seed * sizeof(FutureSeeds));
truelight@0: 		}
truelight@0: 	}
truelight@0: }
truelight@0: 
truelight@0: // send a packet to a client
truelight@0: static void SendBytes(ClientState *cs, void *bytes, uint len)
truelight@0: {
truelight@0: 	byte *b = (byte*)bytes;
truelight@0: 	uint n;
truelight@0: 	Packet *p;
truelight@0: 
truelight@0: 	assert(len != 0);
truelight@0: 
truelight@0: 	// see if there's space in the last packet?
truelight@0: 	if (!cs->head || (p = (Packet*)cs->last, p->siz == sizeof(p->buf)))
truelight@0: 		p = NULL;
truelight@0: 
truelight@0: 	do {
truelight@0: 		if (!p) {
truelight@0: 			// need to allocate a new packet buffer.
truelight@0: 			p = (Packet*)malloc(sizeof(Packet));
truelight@0: 
truelight@0: 			// insert at the end of the linked list.
truelight@0: 			*cs->last = p;
truelight@0: 			cs->last = &p->next;
truelight@0: 			p->next = NULL;
truelight@0: 			p->siz = 0;
truelight@0: 		}
truelight@0: 
truelight@0: 		// copy bytes to packet.
truelight@0: 		n = minu(sizeof(p->buf) - p->siz, len);
truelight@0: 		memcpy(p->buf + p->siz, b, n);
truelight@0: 		p->siz += n;
truelight@0: 		b += n;
truelight@0: 		p = NULL;
truelight@0: 	} while (len -= n);
truelight@0: }
truelight@0: 
signde@206: // send data direct to a client
signde@206: static void SendDirectBytes(ClientState *cs, void *bytes, uint len)
signde@206: {
signde@206: 	char *buf = (char*)bytes;
signde@206: 	uint n;
signde@206: 
signde@206: 	n = send(cs->socket, buf, len, 0);
signde@206: 	if (n == -1) {
signde@206: 				int err = GET_LAST_ERROR();
signde@269: 				DEBUG(net, 0) ("NET: %i] send() failed with error %d", _frame_counter, err);
signde@206: 				CloseClient(cs);
signde@206: 			}
signde@206: }
signde@206: 
truelight@0: // client:
truelight@0: //   add it to the client's ack queue, and send the command to the server
truelight@0: // server:
truelight@0: //   add it to the server's player queue, and send it to all clients.
truelight@0: void NetworkSendCommand(TileIndex tile, uint32 p1, uint32 p2, uint32 cmd, CommandCallback *callback)
truelight@0: {
truelight@0: 	int nump;
truelight@0: 	QueuedCommand *qp;
truelight@0: 	ClientState *cs;
signde@275: 	CommandPacket cp;
truelight@0: 
darkvater@213: 	if (!(cmd & CMD_NET_INSTANT)) {
darkvater@213: 		qp = AllocQueuedCommand(_networking_server ? &_command_queue : &_ack_queue);
darkvater@213: 	} else {
darkvater@213: 		qp = (QueuedCommand*)calloc(sizeof(QueuedCommand), 1);
darkvater@213: 		}
signde@206: 	qp->cp.packet_type = PACKET_TYPE_COMMAND;
truelight@0: 	qp->cp.tile = tile;
truelight@0: 	qp->cp.p1 = p1;
signde@275: 	qp->cp.p2 = p2;	
truelight@0: 	qp->cp.cmd = (uint16)cmd;
truelight@0: 	qp->cp.player = _local_player;
truelight@0: 	qp->cp.when = 0;
truelight@0: 	qp->cmd = cmd;
truelight@0: 	qp->callback = callback;
truelight@0: 
truelight@0: 	// so the server knows when to execute it.
signde@208: 	qp->frame = _frame_counter_max - GetNextSyncFrame();
truelight@0: 
truelight@0: 	// calculate the amount of extra bytes.
dominik@281: 	nump = 8;
truelight@0: 	while ( nump != 0 && ((uint32*)_decode_parameters)[nump-1] == 0) nump--;
truelight@0: 	qp->cp.packet_length = COMMAND_PACKET_BASE_SIZE + nump * sizeof(uint32);
truelight@0: 	if (nump != 0) memcpy(qp->cp.dp, _decode_parameters, nump * sizeof(uint32));
truelight@0: 
signde@275: 	cp = qp->cp;
signde@275: 
signde@275: 	// convert to little endian
signde@275: 	cp.tile = TO_LE16(cp.tile);
signde@275: 	cp.p1 = TO_LE32(cp.p1);
signde@275: 	cp.p2 = TO_LE32(cp.p2);
signde@275: 	cp.cmd = TO_LE16(cp.cmd);
signde@275: 
truelight@0: 	// send it to the peers
signde@275: 	for(cs=_clients; cs->socket != INVALID_SOCKET; cs++) if (!cs->inactive) SendBytes(cs, &cp, cp.packet_length);
truelight@0: 
darkvater@213: 	if (cmd & CMD_NET_INSTANT) {
darkvater@213: 		free(qp);
darkvater@213: 	}
truelight@0: }
truelight@0: 
signde@239: void NetworkSendEvent(uint16 type, uint16 data_len, void * data)
signde@239: {
signde@239: 	EventPacket * ep;
signde@239: 	ClientState *cs;
truelight@260: 
signde@239: 	// encode the event ... add its data
signde@239: 	ep=malloc(data_len+sizeof(EventPacket)-1);
signde@239: 	ep->event_type = type;
signde@239: 	ep->packet_length = data_len+sizeof(EventPacket)-1;
signde@239: 	ep->packet_type = PACKET_TYPE_EVENT;
signde@239: 	memcpy(&ep->data_start,data,data_len);
signde@239: 
signde@239: 	// send it to the peers
signde@239: 	for(cs=_clients; cs->socket != INVALID_SOCKET; cs++) if (!cs->inactive) SendBytes(cs, ep, ep->packet_length);
signde@239: 
signde@239: 	// free the temp packet
signde@239: 	free(ep);
signde@239: }
signde@239: 
truelight@0: // client:
truelight@0: //   server sends a command from another player that we should execute.
truelight@0: //   put it in the command queue.
truelight@0: //
truelight@0: // server:
truelight@0: //   client sends a command that it wants to execute.
truelight@0: //   fill the when field so the client knows when to execute it.
truelight@0: //   put it in the appropriate player queue.
truelight@0: //   send it to all other clients.
truelight@0: //   send an ack packet to the actual client.
truelight@0: 
truelight@0: static void HandleCommandPacket(ClientState *cs, CommandPacket *np)
truelight@0: {
truelight@0: 	QueuedCommand *qp;
truelight@0: 	ClientState *c;
truelight@0: 	AckPacket ap;
darkvater@213: 	uint16 cmd;
truelight@0: 
signde@269: 	DEBUG(net, 2) ("NET: %i] cmd size %d", _frame_counter, np->packet_length);
truelight@0: 	assert(np->packet_length >= COMMAND_PACKET_BASE_SIZE);
truelight@0: 
signde@275: 	cmd = FROM_LE16(np->cmd);
darkvater@213: 
darkvater@213: 	if (!(cmd & CMD_NET_INSTANT)) {
darkvater@213: 		// put it into the command queue
darkvater@213: 		qp = AllocQueuedCommand(&_command_queue);
darkvater@213: 	} else {
darkvater@213: 		qp = (QueuedCommand*)calloc(sizeof(QueuedCommand), 1);
darkvater@213: 	}
truelight@0: 	qp->cp = *np;
darkvater@222: 
signde@208: 	qp->frame = _frame_counter_max - GetNextSyncFrame();
truelight@0: 
truelight@0: 	qp->callback = NULL;
truelight@0: 
truelight@0: 	// extra params
truelight@0: 	memcpy(&qp->cp.dp, np->dp, np->packet_length - COMMAND_PACKET_BASE_SIZE);
truelight@0: 
signde@206: 	ap.packet_type = PACKET_TYPE_ACK;
signde@275: 	ap.when = TO_LE16(GetNextSyncFrame());
signde@206: 	ap.packet_length = sizeof(AckPacket);
signde@269: 	DEBUG(net,4)("NET: %i] NewACK: frame=%i %i",_frame_counter, ap.when,_frame_counter_max - GetNextSyncFrame());
truelight@0: 
truelight@0: 	// send it to the peers
truelight@0: 	if (_networking_server) {
truelight@0: 		for(c=_clients; c->socket != INVALID_SOCKET; c++) {
truelight@0: 			if (c == cs) {
darkvater@213: 				if (!(cmd & CMD_NET_INSTANT)) SendDirectBytes(c, &ap, ap.packet_length);
truelight@0: 			} else {
truelight@0: 				if (!cs->inactive) SendBytes(c, &qp->cp, qp->cp.packet_length);
truelight@0: 			}
truelight@0: 		}
truelight@0: 	}
truelight@0: 
truelight@0: // convert from little endian to big endian?
truelight@0: #if defined(TTD_BIG_ENDIAN)
signde@275: 	qp->cp.cmd = FROM_LE16(qp->cp.cmd);
signde@275: 	qp->cp.tile = FROM_LE16(qp->cp.tile);
signde@275: 	qp->cp.p1 = FROM_LE32(qp->cp.p1);
signde@275: 	qp->cp.p2 = FROM_LE32(qp->cp.p2);
truelight@0: #endif
truelight@0: 
truelight@0: 	qp->cmd = qp->cp.cmd;
darkvater@213: 
darkvater@213: 	if (cmd & CMD_NET_INSTANT) {
darkvater@213: 		byte p = _current_player;
darkvater@213: 		_current_player = qp->cp.player;
darkvater@213: 		memcpy(_decode_parameters, qp->cp.dp, (qp->cp.packet_length - COMMAND_PACKET_BASE_SIZE));
darkvater@213: 		DoCommandP(qp->cp.tile, qp->cp.p1, qp->cp.p2, qp->callback, qp->cmd | CMD_DONT_NETWORK);
darkvater@213: 		free(qp);
darkvater@213: 		_current_player = p;
darkvater@213: 		}
truelight@0: }
truelight@0: 
signde@239: static void HandleEventPacket(EventPacket *ep)
signde@239: {
signde@239: 	switch (ep->event_type) {
signde@239: 		case NET_EVENT_SUBSIDY:
signde@239: 			RemoteSubsidyAdd((Subsidy *)&ep->data_start);
signde@239: 			break;
signde@239: 	}
signde@239: }
signde@239: 
truelight@0: // sent from server -> client periodically to tell the client about the current tick in the server
truelight@0: // and how far the client may progress.
truelight@0: static void HandleSyncPacket(SyncPacket *sp)
truelight@0: {
truelight@0: 	uint32 s1,s2;
truelight@0: 
truelight@0: 	_frame_counter_srv = _frame_counter_max - sp->server;
truelight@0: 	_frame_counter_max += sp->frames;
truelight@0: 
truelight@185: 	// reset network ready packet state
truelight@185: 	_network_ready_sent = false;
truelight@0: 
truelight@0: 	// queueing only?
truelight@0: 	if (_networking_queuing || _frame_counter == 0)
truelight@0: 		return;
truelight@0: 
signde@275: 	s1 = FROM_LE32(sp->random_seed_1);
signde@275: 	s2 = FROM_LE32(sp->random_seed_2);
truelight@0: 
signde@269: 	DEBUG(net, 3) ("NET: %i] sync seeds: 1=%i 2=%i",_frame_counter, sp->random_seed_1, sp->random_seed_2);
truelight@185: 
truelight@0: 	if (_frame_counter_srv <= _frame_counter) {
truelight@0: 		// we are ahead of the server check if the seed is in our list.
truelight@0: 		if (_frame_counter_srv + 16 > _frame_counter) {
truelight@0: 			// the random seed exists in our array check it.
darkvater@172: 			if (s1 != _my_seed_list[_frame_counter_srv & 0xF][0] || s2 != _my_seed_list[_frame_counter_srv & 0xF][1]) NetworkHandleDeSync();
truelight@0: 		}
truelight@0: 	} else {
truelight@0: 		// the server's frame has not been executed yet. store the server's seed in a list.
truelight@0: 		if (_num_future_seed < lengthof(_future_seed)) {
truelight@0: 			_future_seed[_num_future_seed].frame = _frame_counter_srv;
truelight@0: 			_future_seed[_num_future_seed].seed[0] = s1;
truelight@0: 			_future_seed[_num_future_seed].seed[1] = s2;
truelight@0: 			_num_future_seed++;
truelight@0: 		}
truelight@0: 	}
truelight@0: }
truelight@0: 
signde@208: static void HandleFSyncPacket(FrameSyncPacket *fsp)
signde@208: {
signde@269: 	DEBUG(net,3)("NET: %i] FSYNC: srv=%i %i",_frame_counter, fsp->frames,(_frame_counter_max - fsp->frames));
signde@269: 	if (fsp->frames < 1) return;
signde@208: 	_frame_fsync_last = _frame_counter_srv = _frame_counter_max - fsp->frames;
signde@208: }
signde@208: 
truelight@0: // sent from server -> client as an acknowledgement that the server received the command.
truelight@0: // the command will be executed at the current value of "max".
signde@206: static void HandleAckPacket(AckPacket * ap)
truelight@0: {
truelight@0: 	QueuedCommand *q;
truelight@0: 	// move a packet from the ack queue to the end of this player's queue.
truelight@0: 	q = _ack_queue.head;
truelight@0: 	assert(q);
truelight@0: 	if (!(_ack_queue.head = q->next)) _ack_queue.last = &_ack_queue.head;
truelight@0: 	q->next = NULL;
signde@275: 
signde@275: 	q->frame = (_frame_counter_max - (FROM_LE16(ap->when)));
truelight@0: 
truelight@0: 	*_command_queue.last = q;
truelight@0: 	_command_queue.last = &q->next;
truelight@0: 
signde@269: 	DEBUG(net, 2) ("NET %i] ack [frame=%i]",_frame_counter,q->frame);
truelight@0: }
truelight@0: 
truelight@0: static void HandleFilePacket(FilePacketHdr *fp)
truelight@0: {
truelight@0: 	int n = fp->packet_length - sizeof(FilePacketHdr);
dominik@280: 	char tempfile[512];
dominik@280: 
dominik@280: 	sprintf(tempfile, "%s/networkc.tmp",  _path.personal_dir);
dominik@279: 
truelight@0: 	if (n == 0) {
truelight@0: 		assert(_networking_queuing);
truelight@0: 		assert(!_networking_sync);
truelight@0: 		// eof
truelight@0: 		if (_recv_file) { fclose(_recv_file); _recv_file = NULL; }
truelight@0: 
truelight@0: 		// attempt loading the game.
truelight@0: 		_game_mode = GM_NORMAL;
dominik@279: 		if (SaveOrLoad(tempfile, SL_LOAD) != SL_OK) {
darkvater@172: 				NetworkCoreDisconnect();
darkvater@172: 				NetworkHandleSaveGameError();
darkvater@172: 				return;
darkvater@172: 				}
truelight@0: 		// sync to server.
truelight@0: 		_networking_queuing = false;
dominik@105: 		NetworkStartSync(false);
truelight@0: 
truelight@0: 		if (_network_playas == 0) {
truelight@0: 			// send a command to make a new player
truelight@0: 			_local_player = 0;
truelight@0: 			NetworkSendCommand(0, 0, 0, CMD_PLAYER_CTRL, NULL);
darkvater@1: 			_local_player = OWNER_SPECTATOR;
truelight@0: 		} else {
truelight@0: 			// take control over an existing company
truelight@0: 			if (DEREF_PLAYER(_network_playas-1)->is_active)
truelight@0: 				_local_player = _network_playas-1;
truelight@0: 			else
darkvater@1: 				_local_player = OWNER_SPECTATOR;
truelight@0: 		}
truelight@0: 
truelight@0: 	} else {
truelight@0: 		if(!_recv_file) {
dominik@279: 			_recv_file = fopen(tempfile, "wb");
truelight@0: 			if (!_recv_file) error("can't open savefile");
truelight@0: 		}
truelight@0: 		fwrite( (char*)fp + sizeof(*fp), n, 1, _recv_file);
truelight@0: 	}
truelight@0: }
truelight@0: 
darkvater@211: static void HandleWelcomePacket(WelcomePacket *wp)
darkvater@211: {
signde@206: 	int i;
signde@206: 	for (i=0; i<MAX_PLAYERS; i++) {
signde@275: 
signde@275: 		_player_seeds[i][0] = FROM_LE32(wp->player_seeds[i][0]);
signde@275: 		_player_seeds[i][1] = FROM_LE32(wp->player_seeds[i][1]);
signde@206: 		}
signde@206: 	if (wp->frames_srv != 0) {
signde@275: 		_frame_counter_max = FROM_LE32(wp->frames_max);
signde@275: 		_frame_counter_srv = FROM_LE32(wp->frames_srv);
signde@206: 	}
signde@206: 	if (wp->frames_cnt != 0) {
signde@275: 		_frame_counter = FROM_LE32(wp->frames_cnt);
signde@206: 	}
signde@206: }
signde@206: 
signde@206: static void HandleReadyPacket(ReadyPacket *rp, ClientState *cs)
signde@206: {
signde@206: 	cs->ready=true;
signde@206: 	cs->timeout=_network_client_timeout;
signde@269: 	DEBUG(net,1) ("NET: %i] ready packet recv", _frame_counter);
signde@206: }
signde@206: 
signde@206: 
truelight@0: static void CloseClient(ClientState *cs)
truelight@0: {
truelight@0: 	Packet *p, *next;
truelight@0: 
truelight@185: 	DEBUG(net, 1) ("[NET][TCP] closed client connection");
truelight@0: 
truelight@0: 	assert(cs->socket != INVALID_SOCKET);
truelight@0: 
truelight@0: 	closesocket(cs->socket);
truelight@0: 
truelight@0: 	// free buffers
truelight@0: 	for(p = cs->head; p; p=next) {
truelight@0: 		next = p->next;
truelight@0: 		free(p);
truelight@0: 	}
truelight@0: 
truelight@0: 	// copy up structs...
truelight@0: 	while ((cs+1)->socket != INVALID_SOCKET) {
truelight@0: 		*cs = *(cs+1);
truelight@0: 		cs++;
truelight@0: 	}
truelight@0: 	cs->socket = INVALID_SOCKET;
truelight@0: 
dominik@105: 	if (_networking_server) _network_game.players_on--;
dominik@105: 
truelight@0: 	_num_clients--;
truelight@0: }
truelight@0: 
truelight@0: #define NETWORK_BUFFER_SIZE 4096
truelight@0: static bool ReadPackets(ClientState *cs)
truelight@0: {
truelight@0: 	byte network_buffer[NETWORK_BUFFER_SIZE];
truelight@0: 	uint pos,size;
truelight@0: 	unsigned long recv_bytes;
truelight@0: 
truelight@0: 	size = cs->buflen;
truelight@0: 
truelight@0: 	for(;;) {
truelight@0: 		if (size != 0) memcpy(network_buffer, cs->buf, size);
truelight@0: 
truelight@0: 		recv_bytes = recv(cs->socket, (char*)network_buffer + size, sizeof(network_buffer) - size, 0);
truelight@0: 		if ( recv_bytes == (unsigned long)-1) {
truelight@0: 			int err = GET_LAST_ERROR();
truelight@0: 			if (err == EWOULDBLOCK) break;
truelight@185: 			DEBUG(net, 0) ("[NET] recv() failed with error %d", err);
truelight@0: 			CloseClient(cs);
truelight@0: 			return false;
truelight@0: 		}
truelight@0: 		// no more bytes for now?
truelight@0: 		if (recv_bytes == 0)
truelight@0: 			break;
truelight@0: 
truelight@0: 		size += recv_bytes; // number of bytes read.
truelight@0: 		pos = 0;
truelight@0: 		while (size >= 2) {
truelight@0: 			byte *packet = network_buffer + pos;
truelight@0: 			// whole packet not there yet?
truelight@0: 			if (size < packet[0]) break;
truelight@0: 			size -= packet[0];
truelight@0: 			pos += packet[0];
truelight@0: 			switch(packet[1]) {
signde@206: 			case PACKET_TYPE_WELCOME:
signde@206: 				HandleWelcomePacket((WelcomePacket *)packet);
signde@206: 				break;
signde@206: 			case PACKET_TYPE_COMMAND:
truelight@0: 				HandleCommandPacket(cs, (CommandPacket*)packet);
truelight@0: 				break;
signde@206: 			case PACKET_TYPE_SYNC:
truelight@0: 				assert(_networking_sync || _networking_queuing);
truelight@0: 				assert(!_networking_server);
truelight@0: 				HandleSyncPacket((SyncPacket*)packet);
truelight@0: 				break;
signde@208: 			case PACKET_TYPE_FSYNC:
signde@208: 				HandleFSyncPacket((FrameSyncPacket *)packet);
signde@208: 				break;
signde@206: 			case PACKET_TYPE_ACK:
truelight@0: 				assert(!_networking_server);
signde@206: 				HandleAckPacket((AckPacket*)packet);
truelight@0: 				break;
signde@206: 			case PACKET_TYPE_XMIT:
truelight@0: 				HandleFilePacket((FilePacketHdr*)packet);
truelight@0: 				break;
signde@206: 			case PACKET_TYPE_READY:
signde@206: 				HandleReadyPacket((ReadyPacket*)packet, cs);
truelight@185: 				break;
signde@239: 			case PACKET_TYPE_EVENT:
signde@239: 				HandleEventPacket((EventPacket*)packet);
signde@239: 				break;
truelight@0: 			default:
signde@269: 				DEBUG (net,0) ("NET: %i] unknown packet type",_frame_counter);
truelight@0: 			}
truelight@0: 		}
truelight@0: 
darkvater@175: 		assert(size < sizeof(cs->buf));
truelight@0: 
truelight@0: 		memcpy(cs->buf, network_buffer + pos, size);
truelight@0: 	}
truelight@0: 
truelight@0: 	cs->buflen = size;
truelight@0: 
truelight@0: 	return true;
truelight@0: }
truelight@0: 
truelight@0: 
truelight@0: static bool SendPackets(ClientState *cs)
truelight@0: {
truelight@0: 	Packet *p;
truelight@0: 	int n;
truelight@0: 	uint nskip = cs->eaten, nsent = nskip;
truelight@0: 
truelight@0: 	// try sending as much as possible.
truelight@0: 	for(p=cs->head; p ;p = p->next) {
truelight@0: 		if (p->siz) {
truelight@0: 			assert(nskip < p->siz);
truelight@0: 
truelight@0: 			n = send(cs->socket, p->buf + nskip, p->siz - nskip, 0);
truelight@0: 			if (n == -1) {
truelight@0: 				int err = GET_LAST_ERROR();
truelight@0: 				if (err == EWOULDBLOCK) break;
truelight@185: 				DEBUG(net, 0) ("[NET] send() failed with error %d", err);
truelight@0: 				CloseClient(cs);
truelight@0: 				return false;
truelight@0: 			}
truelight@0: 			nsent += n;
truelight@0: 			// send was not able to send it all? then we assume that the os buffer is full and break.
truelight@0: 			if (nskip + n != p->siz)
truelight@0: 				break;
truelight@0: 			nskip = 0;
truelight@0: 		}
truelight@0: 	}
truelight@0: 
truelight@0: 	// nsent bytes in the linked list are not invalid. free as many buffers as possible.
truelight@0: 	// don't actually free the last buffer.
truelight@0: 	while (nsent) {
truelight@0: 		p = cs->head;
truelight@0: 		assert(p->siz != 0);
truelight@0: 
truelight@0: 		// some bytes of the packet are still unsent.
truelight@0: 		if ( (int)(nsent - p->siz) < 0)
truelight@0: 			break;
truelight@0: 		nsent -= p->siz;
truelight@0: 		p->siz = 0;
truelight@0: 		if (p->next) {
truelight@0: 			cs->head = p->next;
truelight@0: 			free(p);
truelight@0: 		}
truelight@0: 	}
truelight@0: 
truelight@0: 	cs->eaten = nsent;
truelight@0: 
truelight@0: 	return true;
truelight@0: }
truelight@0: 
truelight@0: // transmit the file..
truelight@0: static void SendXmit(ClientState *cs)
truelight@0: {
truelight@0: 	uint pos, n;
truelight@0: 	FilePacketHdr hdr;
truelight@0: 	int p;
truelight@0: 
truelight@0: 	// if too many unsent bytes left in buffer, don't send more.
truelight@0: 	if (cs->head && cs->head->next)
truelight@0: 		return;
truelight@0: 
truelight@0: 	pos = cs->xmitpos - 1;
truelight@0: 
truelight@0: 	p = 20;
truelight@0: 	do {
truelight@0: 		// compute size of data to xmit
truelight@0: 		n = minu(_transmit_file_size - pos, 248);
truelight@0: 
truelight@0: 		hdr.packet_length = n + sizeof(hdr);
signde@206: 		hdr.packet_type = PACKET_TYPE_XMIT;
truelight@0: 		SendBytes(cs, &hdr, sizeof(hdr));
truelight@0: 
truelight@0: 		if (n == 0) {
truelight@0: 			pos = -1; // eof
truelight@0: 			break;
truelight@0: 		}
truelight@0: 		SendBytes(cs, _transmit_file + pos, n);
truelight@0: 		pos += n;
truelight@0: 	} while (--p);
truelight@0: 
truelight@0: 	cs->xmitpos = pos + 1;
truelight@0: 
signde@206: 	if (cs->xmitpos == 0) {
signde@206: 		NetworkSendWelcome(cs,false);
signde@206: 	}
signde@206: 
truelight@185: 	DEBUG(net, 2) ("[NET] client xmit at %d", pos + 1);
truelight@0: }
truelight@0: 
truelight@0: static ClientState *AllocClient(SOCKET s)
truelight@0: {
truelight@0: 	ClientState *cs;
truelight@0: 
truelight@0: 	if (_num_clients == MAX_CLIENTS)
truelight@0: 		return NULL;
truelight@0: 
dominik@105: 	if (_networking_server) _network_game.players_on++;
dominik@105: 
truelight@0: 	cs = &_clients[_num_clients++];
truelight@0: 	memset(cs, 0, sizeof(*cs));
truelight@0: 	cs->last = &cs->head;
truelight@0: 	cs->socket = s;
truelight@185: 	cs->timeout = _network_client_timeout;
truelight@0: 	return cs;
truelight@0: }
truelight@0: 
truelight@185: void NetworkSendReadyPacket()
truelight@185: {
signde@206: 	if ((!_network_ready_sent) && (_frame_counter + _network_ready_ahead >= _frame_counter_max)) {
darkvater@288: 		ReadyPacket rp;
truelight@185: 
signde@269: 		DEBUG(net,1) ("NET: %i] ready packet sent", _frame_counter);
signde@269: 
darkvater@288: 		rp.packet_type = PACKET_TYPE_READY;
darkvater@288: 		rp.packet_length = sizeof(rp);
darkvater@288: 		SendBytes(_clients, &rp, sizeof(rp));
truelight@193: 		_network_ready_sent = true;
truelight@185: 	}
truelight@185: }
truelight@0: 
signde@206: void NetworkSendSyncPackets()
signde@206: {
signde@206: 	ClientState *cs;
signde@206: 	uint32 new_max;
signde@206: 	SyncPacket sp;
signde@206: 
signde@206: 	new_max = _frame_counter + (int)_network_sync_freq;
signde@206: 
signde@269: 	DEBUG(net,3) ("NET: %i] serv: sync max=%i, seed1=%i, seed2=%i",_frame_counter,new_max,_sync_seed_1,_sync_seed_2);
signde@206: 
signde@206: 	sp.packet_length = sizeof(sp);
signde@206: 	sp.packet_type = PACKET_TYPE_SYNC;
signde@206: 	sp.frames = new_max - _frame_counter_max;
signde@206: 	sp.server = _frame_counter_max - _frame_counter;
signde@206: 	sp.random_seed_1 = TO_LE32(_sync_seed_1);
signde@206: 	sp.random_seed_2 = TO_LE32(_sync_seed_2);
signde@206: 	_frame_counter_max = new_max;
signde@206: 
signde@206: 	// send it to all the clients and mark them unready
signde@206: 	for(cs=_clients;cs->socket != INVALID_SOCKET; cs++) {
signde@206: 		cs->ready=false;
signde@208: 		SendBytes(cs, &sp, sp.packet_length);
signde@208: 	}
signde@208: 
signde@208: }
signde@208: 
signde@208: void NetworkSendFrameSyncPackets()
signde@208: {
signde@208: 	ClientState *cs;
signde@208: 	FrameSyncPacket fsp;
signde@208: 	if ((_frame_counter + 4) < _frame_counter_max) if ((_frame_fsync_last + 4 < _frame_counter)) {
signde@208: 		// this packet mantains some information about on which frame the server is
signde@208: 		fsp.frames = _frame_counter_max - _frame_counter;
signde@208: 		fsp.packet_type = PACKET_TYPE_FSYNC;
signde@208: 		fsp.packet_length = sizeof (FrameSyncPacket);
signde@208: 		// send it to all the clients and mark them unready
signde@208: 		for(cs=_clients;cs->socket != INVALID_SOCKET; cs++) {
signde@208: 			SendBytes(cs, &fsp, fsp.packet_length);
signde@208: 		}
signde@208: 		_frame_fsync_last = _frame_counter;
signde@206: 	}
signde@206: 
signde@206: }
signde@206: 
signde@206: void NetworkSendWelcome(ClientState *cs, bool direct) {
signde@206: 	WelcomePacket wp;
signde@206: 	int i;
signde@206: 	wp.packet_type = PACKET_TYPE_WELCOME;
signde@206: 	wp.packet_length = sizeof(WelcomePacket);
signde@206: 	for (i=0; i<MAX_PLAYERS; i++) {
signde@275: 		wp.player_seeds[i][0]=TO_LE32(_player_seeds[i][0]);
signde@275: 		wp.player_seeds[i][1]=TO_LE32(_player_seeds[i][1]);
signde@206: 		}
signde@206: 	if (direct) {
signde@206: 		wp.frames_max=0;
signde@206: 		wp.frames_srv=0;
signde@275: 		wp.frames_cnt=TO_LE32(_frame_counter);
signde@206: 		SendDirectBytes(cs,(void *)&wp,wp.packet_length);
signde@206: 	} else {
signde@275: 		wp.frames_max=TO_LE32(_frame_counter_max);
signde@275: 		wp.frames_srv=TO_LE32(_frame_counter_srv);
signde@206: 		wp.frames_cnt=0;
signde@206: 		SendBytes(cs,(void *)&wp,wp.packet_length);
signde@206: 	}
signde@206: }
signde@206: 
truelight@0: static void NetworkAcceptClients()
truelight@0: {
truelight@0: 	struct sockaddr_in sin;
truelight@0: 	SOCKET s;
truelight@0: 	ClientState *cs;
truelight@0: #ifndef __MORPHOS__
truelight@0: 	int sin_len;
truelight@0: #else
truelight@0: 	LONG sin_len; // for some reason we need a 'LONG' under MorphOS
truelight@0: #endif
truelight@0: 
truelight@0: 	assert(_listensocket != INVALID_SOCKET);
truelight@0: 
truelight@0: 	for(;;) {
truelight@0: 		sin_len = sizeof(sin);
truelight@0: 		s = accept(_listensocket, (struct sockaddr*)&sin, &sin_len);
truelight@0: 		if (s == INVALID_SOCKET) return;
truelight@0: 
truelight@0: 		// set nonblocking mode for client socket
truelight@0: 		{ unsigned long blocking = 1; ioctlsocket(s, FIONBIO, &blocking); }
truelight@0: 
signde@269: 		DEBUG(net, 1) ("NET: %i] got client from %s", _frame_counter, inet_ntoa(sin.sin_addr));
truelight@0: 
truelight@0: 		// set nodelay
truelight@0: 		{int b = 1; setsockopt(s, IPPROTO_TCP, TCP_NODELAY, (const char*)&b, sizeof(b));}
truelight@0: 
truelight@0: 		cs = AllocClient(s);
truelight@0: 		if (cs == NULL) {
truelight@0: 			// no more clients allowed?
truelight@0: 			closesocket(s);
truelight@0: 			continue;
truelight@0: 		}
truelight@0: 
truelight@0: 		if (_networking_sync) {
truelight@0: 			// a new client has connected. it needs a snapshot.
truelight@0: 			cs->inactive = true;
truelight@0: 		}
truelight@0: 	}
truelight@0: 
truelight@0: 	// when a new client has joined. it needs different information depending on if it's at the game menu or in an active game.
truelight@0: 	// Game menu:
truelight@0: 	//  - list of players already in the game (name, company name, face, color)
truelight@0: 	//  - list of game settings and patch settings
truelight@0: 	// Active game:
truelight@0: 	//  - the state of the world (includes player name, company name, player face, player color)
truelight@0: 	//  - list of the patch settings
truelight@0: 
truelight@0: 	// Networking can be in several "states".
truelight@0: 	//  * not sync - games don't need to be in sync, and frame counter is not synced. for example intro screen. all commands are executed immediately.
truelight@0: 	//  * sync - games are in sync
truelight@0: }
truelight@0: 
truelight@0: static void SendQueuedCommandsToNewClient(ClientState *cs)
truelight@0: {
truelight@0: 	// send the commands in the server queue to the new client.
truelight@0: 	QueuedCommand *qp;
truelight@0: 	SyncPacket sp;
signde@206: 	uint32 frame;
truelight@0: 
signde@269: 	DEBUG(net, 2) ("NET: %i] sending queued commands to client",_frame_counter);
truelight@0: 
truelight@0: 	sp.packet_length = sizeof(sp);
signde@206: 	sp.packet_type = PACKET_TYPE_SYNC;
truelight@0: 	sp.random_seed_1 = sp.random_seed_2 = 0;
truelight@0: 	sp.server = 0;
truelight@0: 
truelight@0: 	frame = _frame_counter;
truelight@0: 
truelight@0: 	for(qp=_command_queue.head; qp; qp = qp->next) {
signde@269: 		DEBUG(net, 4) ("NET: %i] sending cmd to be executed at %d (old %d)", _frame_counter, qp->frame, frame);
truelight@0: 		if (qp->frame > frame) {
truelight@0: 			assert(qp->frame <= _frame_counter_max);
truelight@0: 			sp.frames = qp->frame - frame;
truelight@0: 			frame = qp->frame;
truelight@0: 			SendBytes(cs, &sp, sizeof(sp));
truelight@0: 		}
truelight@0: 		SendBytes(cs, &qp->cp, qp->cp.packet_length);
truelight@0: 	}
truelight@0: 
truelight@0: 	if (frame < _frame_counter_max) {
signde@269: 		DEBUG(net, 4) ("NET: %i] sending queued sync %d (%d)",_frame_counter, _frame_counter_max, frame);
truelight@0: 		sp.frames = _frame_counter_max - frame;
truelight@0: 		SendBytes(cs, &sp, sizeof(sp));
truelight@0: 	}
truelight@0: 
truelight@0: }
truelight@0: 
darkvater@211: bool NetworkCheckClientReady()
darkvater@211: {
signde@206: 	bool ready_all = true;
signde@206: 	uint16 count = 0;
signde@206: 	ClientState *cs;
signde@206: 
signde@206: 	for(cs=_clients;cs->socket != INVALID_SOCKET; cs++) {
signde@206: 		count++;
signde@206: 		ready_all = ready_all && (cs->ready || cs->inactive || (cs->xmitpos>0));
signde@206: 		if (!cs->ready) cs->timeout-=1;
signde@206: 		if (cs->timeout == 0) {
signde@206: 			SET_DPARAM16(0,count);
signde@206: 			ShowErrorMessage(-1,STR_NETWORK_ERR_TIMEOUT,0,0);
signde@206: 			CloseClient(cs);
signde@206: 			}
signde@206: 		}
signde@206: 	return ready_all;
signde@206: }
signde@206: 
dominik@105: // ************************** //
dominik@105: // * TCP Networking         * //
dominik@105: // ************************** //
dominik@105: 
darkvater@211: unsigned long NetworkResolveHost(const char *hostname)
darkvater@211: {
darkvater@144: 	struct hostent* remotehost;
darkvater@144: 
darkvater@144: 	if ((hostname[0]<0x30) || (hostname[0]>0x39)) {
darkvater@144: 		// seems to be an hostname [first character is no number]
darkvater@144: 		remotehost = gethostbyname(hostname);
darkvater@144: 		if (remotehost == NULL) {
truelight@185: 			DEBUG(net, 1) ("[NET][IP] cannot resolve %s", hostname);
darkvater@144: 			return 0;
darkvater@144: 		} else {
truelight@185: 			DEBUG(net, 1) ("[NET][IP] resolved %s to %s",hostname, inet_ntoa(*(struct in_addr *) remotehost->h_addr_list[0]));
darkvater@144: 			return inet_addr(inet_ntoa(*(struct in_addr *) remotehost->h_addr_list[0]));
darkvater@144: 			}
darkvater@144: 	} else {
darkvater@144: 		// seems to be an ip [first character is a number]
darkvater@144: 		return inet_addr(hostname);
darkvater@144: 		}
darkvater@144: 
darkvater@144: }
darkvater@144: 
dominik@105: bool NetworkConnect(const char *hostname, int port)
dominik@105: {
dominik@105: 	SOCKET s;
dominik@105: 	struct sockaddr_in sin;
dominik@105: 	int b;
dominik@105: 
truelight@185: 	DEBUG(net, 1) ("[NET][TCP] Connecting to %s %d", hostname, port);
dominik@105: 
dominik@105: 	s = socket(AF_INET, SOCK_STREAM, 0);
dominik@105: 	if (s == INVALID_SOCKET) error("socket() failed");
dominik@105: 
dominik@105: 	b = 1;
dominik@105: 	setsockopt(s, IPPROTO_TCP, TCP_NODELAY, (const char*)&b, sizeof(b));
truelight@193: 
dominik@105: 	sin.sin_family = AF_INET;
darkvater@144: 	sin.sin_addr.s_addr = NetworkResolveHost(hostname);
dominik@105: 	sin.sin_port = htons(port);
dominik@105: 
dominik@105: 	if (connect(s, (struct sockaddr*) &sin, sizeof(sin)) != 0) {
dominik@105: 		NetworkClose(true);
dominik@105: 		return false;
dominik@105: 		}
dominik@105: 
dominik@105: 	// set nonblocking mode for socket..
dominik@105: 	{ unsigned long blocking = 1; ioctlsocket(s, FIONBIO, &blocking); }
dominik@105: 
dominik@105: 	// in client mode, only the first client field is used. it's pointing to the server.
dominik@105: 	AllocClient(s);
dominik@105: 
dominik@105: 	// queue packets.. because we're waiting for the savegame.
dominik@105: 	_networking_queuing = true;
dominik@105: 	_frame_counter_max = 0;
dominik@105: 
dominik@105: 	return true;
dominik@105: }
dominik@105: 
dominik@105: void NetworkListen()
dominik@105: {
truelight@193: 
dominik@105: 	SOCKET ls;
dominik@105: 	struct sockaddr_in sin;
dominik@105: 	int port;
dominik@105: 
dominik@105: 	port = _network_server_port;
dominik@105: 
truelight@185: 	DEBUG(net, 1) ("[NET][TCP] listening on port %d", port);
dominik@105: 
dominik@105: 	ls = socket(AF_INET, SOCK_STREAM, 0);
dominik@105: 	if (ls == INVALID_SOCKET)
dominik@105: 		error("socket() on listen socket failed");
truelight@193: 
dominik@105: 	// reuse the socket
dominik@105: 	{
dominik@105: 		int reuse = 1; if (setsockopt(ls, SOL_SOCKET, SO_REUSEADDR, (const char*)&reuse, sizeof(reuse)) == -1)
dominik@105: 			error("setsockopt() on listen socket failed");
dominik@105: 	}
dominik@105: 
dominik@105: 	// set nonblocking mode for socket
dominik@105: 	{ unsigned long blocking = 1; ioctlsocket(ls, FIONBIO, &blocking); }
dominik@105: 
dominik@105: 	sin.sin_family = AF_INET;
dominik@105: 	sin.sin_addr.s_addr = 0;
dominik@105: 	sin.sin_port = htons(port);
dominik@105: 
dominik@105: 	if (bind(ls, (struct sockaddr*)&sin, sizeof(sin)) != 0)
dominik@105: 		error("bind() failed");
dominik@105: 
dominik@105: 	if (listen(ls, 1) != 0)
dominik@105: 		error("listen() failed");
dominik@105: 
dominik@105: 	_listensocket = ls;
dominik@105: }
dominik@105: 
truelight@0: void NetworkReceive()
truelight@0: {
truelight@0: 	ClientState *cs;
truelight@0: 	int n;
truelight@0: 	fd_set read_fd, write_fd;
truelight@0: 	struct timeval tv;
truelight@193: 
truelight@0: 	FD_ZERO(&read_fd);
truelight@0: 	FD_ZERO(&write_fd);
truelight@0: 
truelight@0: 	for(cs=_clients;cs->socket != INVALID_SOCKET; cs++) {
truelight@0: 		FD_SET(cs->socket, &read_fd);
truelight@0: 		FD_SET(cs->socket, &write_fd);
truelight@0: 	}
truelight@0: 
truelight@0: 	// take care of listener port
truelight@0: 	if (_networking_server) {
truelight@0: 		FD_SET(_listensocket, &read_fd);
truelight@0: 	}
truelight@0: 
truelight@0: 	tv.tv_sec = tv.tv_usec = 0; // don't block at all.
truelight@0: #if !defined(__MORPHOS__) && !defined(__AMIGA__)
truelight@0: 	n = select(FD_SETSIZE, &read_fd, &write_fd, NULL, &tv);
truelight@0: #else
truelight@0: 	n = WaitSelect(FD_SETSIZE, &read_fd, &write_fd, NULL, &tv, NULL);
truelight@0: #endif
truelight@185: 	if ((n == -1) && (!_networking_server)) NetworkHandleConnectionLost();
truelight@0: 
truelight@0: 	// accept clients..
truelight@0: 	if (_networking_server && FD_ISSET(_listensocket, &read_fd))
truelight@0: 		NetworkAcceptClients();
truelight@0: 
truelight@0: 	// read stuff from clients
truelight@0: 	for(cs=_clients;cs->socket != INVALID_SOCKET; cs++) {
truelight@0: 		cs->writable = !!FD_ISSET(cs->socket, &write_fd);
truelight@0: 		if (FD_ISSET(cs->socket, &read_fd)) {
truelight@0: 			if (!ReadPackets(cs))
truelight@0: 				cs--;
truelight@0: 		}
truelight@0: 	}
truelight@0: 
truelight@0: 	// if we're a server, and any client needs a snapshot, create a snapshot and send all commands from the server queue to the client.
truelight@0: 	if (_networking_server && _transmit_file == NULL) {
truelight@0: 		bool didsave = false;
truelight@0: 
truelight@0: 		for(cs=_clients;cs->socket != INVALID_SOCKET; cs++) {
truelight@0: 			if (cs->inactive) {
truelight@0: 				cs->inactive = false;
truelight@0: 				// found a client waiting for a snapshot. make a snapshot.
truelight@0: 				if (!didsave) {
truelight@0: 					char filename[256];
truelight@0: 					sprintf(filename, "%snetwork.tmp",  _path.autosave_dir);
truelight@0: 					didsave = true;
truelight@0: 					if (SaveOrLoad(filename, SL_SAVE) != SL_OK) error("network savedump failed");
truelight@0: 					_transmit_file = ReadFileToMem(filename, &_transmit_file_size, 500000);
truelight@0: 					if (_transmit_file == NULL) error("network savedump failed to load");
truelight@0: 				}
truelight@0: 				// and start sending the file..
truelight@0: 				cs->xmitpos = 1;
truelight@0: 
truelight@0: 				// send queue of commands to client.
truelight@0: 				SendQueuedCommandsToNewClient(cs);
signde@206: 
signde@206: 				NetworkSendWelcome(cs, true);
truelight@0: 			}
truelight@0: 		}
truelight@0: 	}
truelight@0: }
truelight@0: 
truelight@0: void NetworkSend()
truelight@0: {
truelight@0: 	ClientState *cs;
truelight@0: 	void *free_xmit;
truelight@0: 
truelight@0: 	free_xmit = _transmit_file;
truelight@0: 
truelight@0: 	// send stuff to all clients
truelight@0: 	for(cs=_clients;cs->socket != INVALID_SOCKET; cs++) {
truelight@0: 		if (cs->xmitpos) {
truelight@0: 			if (cs->writable)
truelight@0: 				SendXmit(cs);
truelight@0: 			free_xmit = NULL;
truelight@0: 		}
truelight@0: 		if (cs->writable)	{
truelight@0: 			if (!SendPackets(cs)) cs--;
truelight@0: 		}
truelight@0: 	}
truelight@0: 
truelight@0: 	// no clients left that xmit the file, free it.
truelight@0: 	if (free_xmit) {
truelight@0: 		_transmit_file = NULL;
truelight@0: 		free(free_xmit);
truelight@0: 	}
truelight@0: }
truelight@0: 
truelight@0: 
dominik@105: void NetworkInitialize()
truelight@0: {
truelight@0: 	ClientState *cs;
darkvater@1: 
signde@206: 	QueueClear(&_command_queue);
signde@206: 	QueueClear(&_ack_queue);
truelight@0: 	_command_queue.last = &_command_queue.head;
darkvater@211: 	_network_game_list = NULL;
truelight@0: 
truelight@0: 	// invalidate all clients
truelight@0: 	for(cs=_clients; cs != &_clients[MAX_CLIENTS]; cs++)
truelight@0: 		cs->socket = INVALID_SOCKET;
dominik@105: 
dominik@105: }
dominik@105: 
darkvater@211: void NetworkClose(bool client)
darkvater@211: {
dominik@105: 
dominik@105: 	ClientState *cs;
dominik@105: 	// invalidate all clients
dominik@105: 
dominik@105: 	for(cs=_clients; cs != &_clients[MAX_CLIENTS]; cs++) if (cs->socket != INVALID_SOCKET) {
dominik@105: 		CloseClient(cs);
dominik@105: 		}
dominik@105: 
dominik@105: 	if (!client) {
dominik@105: 		// if in servermode --> close listener
dominik@105: 		closesocket(_listensocket);
dominik@105: 		_listensocket= INVALID_SOCKET;
truelight@185: 		DEBUG(net, 1) ("[NET][TCP] closed listener on port %i", _network_server_port);
darkvater@211: 	}
truelight@0: }
truelight@0: 
truelight@0: void NetworkShutdown()
truelight@0: {
truelight@193: 	_networking_server = false;
darkvater@169: 	_networking = false;
darkvater@169: 	_networking_sync = false;
darkvater@169: 	_frame_counter = 0;
darkvater@169: 	_frame_counter_max = 0;
darkvater@169: 	_frame_counter_srv = 0;
truelight@0: }
truelight@0: 
truelight@0: // switch to synced mode.
dominik@105: void NetworkStartSync(bool fcreset)
truelight@0: {
truelight@185: 	DEBUG(net, 3) ("[NET][SYNC] switching to synced game mode");
truelight@0: 	_networking_sync = true;
truelight@0: 	_frame_counter = 0;
darkvater@211: 
dominik@105: 	if (fcreset) {
dominik@105: 		_frame_counter_max = 0;
dominik@105: 		_frame_counter_srv = 0;
signde@208: 		_frame_fsync_last = 0;
dominik@105: 		}
truelight@0: 	_num_future_seed = 0;
truelight@0: 	_sync_seed_1 = _sync_seed_2 = 0;
truelight@0: 	memset(_my_seed_list, 0, sizeof(_my_seed_list));
truelight@0: }
truelight@0: 
truelight@0: // ************************** //
truelight@0: // * UDP Network Extensions * //
truelight@0: // ************************** //
truelight@0: 
dominik@105: void NetworkUDPListen(bool client)
truelight@0: {
truelight@0: 	SOCKET udp;
truelight@0: 	struct sockaddr_in sin;
dominik@105: 	int port;
truelight@0: 
dominik@105: 	if (client) { port = _network_client_port; } else { port = _network_server_port; };
dominik@105: 
truelight@185: 	DEBUG(net, 1) ("[NET][UDP] listening on port %i", port);
truelight@0: 
truelight@0: 	udp = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
truelight@193: 
dominik@105: 	// this disables network
dominik@105: 	_network_available = !(udp == INVALID_SOCKET);
truelight@193: 
truelight@0: 	// set nonblocking mode for socket
truelight@0: 	{ unsigned long blocking = 1; ioctlsocket(udp, FIONBIO, &blocking); }
truelight@0: 
truelight@0: 	sin.sin_family = AF_INET;
truelight@0: 	sin.sin_addr.s_addr = 0;
truelight@0: 	sin.sin_port = htons(port);
truelight@0: 
truelight@0: 	if (bind(udp, (struct sockaddr*)&sin, sizeof(sin)) != 0)
truelight@185: 		DEBUG(net, 1) ("[NET][UDP] error: bind failed on port %i", port);
truelight@193: 
truelight@0: 
truelight@0: 	// enable broadcasting
truelight@0: 	{ unsigned long val=1; setsockopt(udp, SOL_SOCKET, SO_BROADCAST, (char *) &val , sizeof(val)); }
dominik@105: 	// allow reusing
dominik@105: 	{ unsigned long val=1; setsockopt(udp, SOL_SOCKET, SO_REUSEADDR, (char *) &val , sizeof(val)); }
dominik@105: 
dominik@105: 	if (client) { _udp_client_socket = udp; } else { _udp_server_socket = udp; } ;
truelight@0: 
truelight@0: }
truelight@0: 
darkvater@211: void NetworkUDPClose(bool client)
darkvater@211: {
truelight@193: 	if (client) {
truelight@185: 		DEBUG(net, 1) ("[NET][UDP] closed listener on port %i", _network_client_port);
dominik@105: 		closesocket(_udp_client_socket);
dominik@105: 		_udp_client_socket = INVALID_SOCKET;
dominik@105: 		} else {
truelight@185: 		DEBUG(net, 1) ("[NET][UDP] closed listener on port %i", _network_server_port);
dominik@105: 		closesocket(_udp_server_socket);
dominik@105: 		_udp_server_socket = INVALID_SOCKET;
dominik@105: 		};
dominik@105: 	}
dominik@105: 
darkvater@211: void NetworkUDPReceive(bool client)
darkvater@211: {
truelight@0: 	struct sockaddr_in client_addr;
darkvater@173: #ifndef __MORPHOS__
truelight@0: 	int client_len;
darkvater@173: #else
darkvater@173: 	LONG client_len; // for some reason we need a 'LONG' under MorphOS
darkvater@173: #endif
truelight@0: 	int nbytes;
truelight@0: 	struct UDPPacket packet;
truelight@0: 	int packet_len;
truelight@193: 
dominik@105: 	SOCKET udp;
dominik@105: 	if (client) udp=_udp_client_socket; else udp=_udp_server_socket;
dominik@105: 
truelight@0: 	packet_len = sizeof(packet);
truelight@193: 	client_len = sizeof(client_addr);
truelight@193: 
dominik@105: 	nbytes = recvfrom(udp, (char *) &packet, packet_len , 0, (struct sockaddr *) &client_addr, &client_len);
truelight@0: 	if (nbytes>0) {
truelight@0: 		if (packet.command_code==packet.command_check) switch (packet.command_code) {
truelight@193: 
dominik@105:  		case NET_UDPCMD_SERVERSEARCH:
dominik@105:  			if (!client) {
dominik@105: 				packet.command_check=packet.command_code=NET_UDPCMD_SERVERINFO;
dominik@105: 				memcpy(&packet.data,&_network_game,sizeof(_network_game));
dominik@105: 				packet.data_len=sizeof(_network_game);
dominik@105:  				NetworkUDPSend(client,client_addr, packet);
dominik@105:  			}
dominik@105:  			break;
dominik@105: 		case NET_UDPCMD_GETSERVERINFO:
dominik@105: 			if (!client) {
dominik@105: 				packet.command_check=packet.command_code=NET_UDPCMD_SERVERINFO;
dominik@105: 				memcpy(&packet.data,&_network_game,sizeof(_network_game));
dominik@105: 				packet.data_len=sizeof(_network_game);
dominik@105: 				NetworkUDPSend(client,client_addr, packet);
truelight@0: 			}
truelight@0: 			break;
dominik@105: 		case NET_UDPCMD_SERVERINFO:
dominik@105:  			if (client) {
dominik@105: 				NetworkGameList * item;
dominik@105: 
dominik@105: 				item = (NetworkGameList *) NetworkGameListAdd();
dominik@105: 				item -> ip = inet_addr(inet_ntoa(client_addr.sin_addr));
dominik@105: 				item -> port = ntohs(client_addr.sin_port);
truelight@193: 
dominik@105: 				memcpy(item,&packet.data,packet.data_len);
dominik@105:  			}
dominik@105:  			break;
truelight@0: 		}
truelight@0: 	}
truelight@0: }
truelight@0: 
darkvater@211: void NetworkUDPBroadCast(bool client, struct UDPPacket packet)
darkvater@211: {
truelight@0: 	int i=0, res;
truelight@0: 	struct sockaddr_in out_addr;
truelight@0: 	uint32 bcaddr;
truelight@0: 	byte * bcptr;
dominik@105: 
dominik@105: 	SOCKET udp;
dominik@105: 	if (client) udp=_udp_client_socket; else udp=_udp_server_socket;
dominik@105: 
truelight@0: 	while (_network_ip_list[i]!=0) {
truelight@0: 		bcaddr=_network_ip_list[i];
truelight@0: 		out_addr.sin_family = AF_INET;
dominik@105: 		if (client) { out_addr.sin_port = htons(_network_server_port); } else { out_addr.sin_port = htons(_network_client_port); };
truelight@0: 		bcptr = (byte *) &bcaddr;
truelight@0: 		bcptr[3]=255;
truelight@0: 		out_addr.sin_addr.s_addr = bcaddr;
dominik@105: 		res=sendto(udp,(char *) &packet,sizeof(packet),0,(struct sockaddr *) &out_addr,sizeof(out_addr));
truelight@185: 		if (res==-1) DEBUG(net, 1)("udp: broadcast error: %i",GET_LAST_ERROR());
truelight@0: 		i++;
truelight@0: 	}
truelight@193: 
truelight@0: }
truelight@0: 
darkvater@211: void NetworkUDPSend(bool client, struct sockaddr_in recv,struct UDPPacket packet)
darkvater@211: {
dominik@105: 	SOCKET udp;
dominik@105: 	if (client) udp=_udp_client_socket; else udp=_udp_server_socket;
truelight@193: 
dominik@105: 	sendto(udp,(char *) &packet,sizeof(packet),0,(struct sockaddr *) &recv,sizeof(recv));
truelight@0: }
truelight@0: 
dominik@105: 
darkvater@211: bool NetworkUDPSearchGame(const byte ** _network_detected_serverip, unsigned short * _network_detected_serverport)
darkvater@211: {
truelight@0: 	struct UDPPacket packet;
truelight@0: 	int timeout=3000;
truelight@193: 
dominik@105: 	NetworkGameListClear();
dominik@105: 
truelight@185: 	DEBUG(net, 0) ("[NET][UDP] searching server");
dominik@105: 	*_network_detected_serverip = "255.255.255.255";
dominik@105: 	*_network_detected_serverport = 0;
truelight@193: 
truelight@0: 	packet.command_check=packet.command_code=NET_UDPCMD_SERVERSEARCH;
truelight@0: 	packet.data_len=0;
dominik@105: 	NetworkUDPBroadCast(true, packet);
truelight@0: 	while (timeout>=0) {
truelight@0: 		CSleep(100);
truelight@0: 		timeout-=100;
dominik@105: 	    NetworkUDPReceive(true);
dominik@105: 
dominik@105: 		if (_network_game_count>0) {
dominik@105: 			NetworkGameList * item;
dominik@105: 			item = (NetworkGameList *) NetworkGameListItem(0);
dominik@105: 			*_network_detected_serverip=inet_ntoa(*(struct in_addr *) &item->ip);
dominik@105: 			*_network_detected_serverport=item->port;
dominik@105:  			timeout=-1;
truelight@185:  			DEBUG(net, 0) ("[NET][UDP] server found on %s", *_network_detected_serverip);
dominik@105:  			}
truelight@193: 
truelight@0: 		}
dominik@105: 
darkvater@175: 	return (*_network_detected_serverport>0);
truelight@193: 
truelight@0: }
truelight@0: 
truelight@0: 
dominik@105: // *************************** //
dominik@105: // * New Network Core System * //
dominik@105: // *************************** //
dominik@105: 
darkvater@211: void NetworkIPListInit()
darkvater@211: {
dominik@105: 	struct hostent* he = NULL;
dominik@105: 	char hostname[250];
dominik@105: 	uint32 bcaddr;
dominik@105: 	int i=0;
truelight@193: 
dominik@105: 	gethostname(hostname,250);
truelight@185: 	DEBUG(net, 2) ("[NET][IP] init for host %s", hostname);
dominik@105: 	he=gethostbyname((char *) hostname);
truelight@110: 
truelight@110: 	if (he == NULL) {
truelight@110: 		he = gethostbyname("localhost");
truelight@110: 		}
truelight@193: 
truelight@110: 	if (he == NULL) {
truelight@110: 		bcaddr = inet_addr("127.0.0.1");
truelight@110: 		he = gethostbyaddr(inet_ntoa(*(struct in_addr *) &bcaddr), sizeof(bcaddr), AF_INET);
dominik@105: 		}
dominik@105: 
dominik@105: 	if (he == NULL) {
truelight@185: 		DEBUG(net, 2) ("[NET][IP] cannot resolve %s", hostname);
dominik@105: 	} else {
truelight@193: 		while(he->h_addr_list[i]) {
dominik@105: 			bcaddr = inet_addr(inet_ntoa(*(struct in_addr *) he->h_addr_list[i]));
dominik@105: 			_network_ip_list[i]=bcaddr;
truelight@185: 			DEBUG(net, 2) ("[NET][IP] add %s",inet_ntoa(*(struct in_addr *) he->h_addr_list[i]));
dominik@105: 			i++;
dominik@105: 		}
dominik@105: 
dominik@105: 	}
dominik@105: 	_network_ip_list[i]=0;
truelight@193: 
dominik@105: }
dominik@105: 
dominik@105: /* *************************************************** */
dominik@105: 
darkvater@211: void NetworkCoreInit()
dominik@105: {
darkvater@211: 	DEBUG(net, 3) ("[NET][Core] init()");
signde@220: 	_network_available = true;
signde@220: 	_network_client_timeout = 300;
signde@220: 	_network_ready_ahead = 1;
dominik@105: 
darkvater@211: 	// [win32] winsock startup
dominik@105: 
darkvater@211: 	#if defined(WIN32)
darkvater@211: 	{
darkvater@211: 		WSADATA wsa;
darkvater@211: 		DEBUG(net, 3) ("[NET][Core] using windows socket library");
darkvater@211: 		if (WSAStartup(MAKEWORD(2,0), &wsa) != 0) {
darkvater@211: 			DEBUG(net, 3) ("[NET][Core] error: WSAStartup failed");
darkvater@211: 			_network_available=false;
darkvater@211: 			}
darkvater@211: 	}
darkvater@211: 	#else
darkvater@144: 
darkvater@211: 	// [morphos/amigaos] bsd-socket startup
darkvater@211: 
darkvater@211: 	#if defined(__MORPHOS__) || defined(__AMIGA__)
darkvater@211: 	{
darkvater@211: 		DEBUG(misc,3) ("[NET][Core] using bsd socket library");
darkvater@211: 		if (!(SocketBase = OpenLibrary("bsdsocket.library", 4))) {
darkvater@211: 			DEBUG(net, 3) ("[NET][Core] Couldn't open bsdsocket.library version 4.");
darkvater@211: 			_network_available=false;
darkvater@211: 			}
darkvater@211: 
darkvater@211: 		#if !defined(__MORPHOS__)
darkvater@211: 		// for usleep() implementation (only required for legacy AmigaOS builds)
darkvater@211: 		if ( (TimerPort = CreateMsgPort()) ) {
darkvater@211: 			if ( (TimerRequest = (struct timerequest *) CreateIORequest(TimerPort, sizeof(struct timerequest))) ) {
darkvater@211: 				if ( OpenDevice("timer.device", UNIT_MICROHZ, (struct IORequest *) TimerRequest, 0) == 0 ) {
darkvater@211: 					if ( !(TimerBase = TimerRequest->tr_node.io_Device) ) {
darkvater@211: 						// free ressources...
darkvater@211: 						DEBUG(net, 3) ("[NET][Core] Couldn't initialize timer.");
darkvater@211: 						_network_available=false;
darkvater@211: 					}
darkvater@144: 				}
darkvater@144: 			}
darkvater@144: 		}
darkvater@211: 		#endif
darkvater@211: 
darkvater@211: 	}
darkvater@211: 	#else
darkvater@211: 
darkvater@211: 	// [linux/macos] unix-socket startup
darkvater@211: 
darkvater@211: 		DEBUG(net, 3) ("[NET][Core] using unix socket library");
darkvater@211: 
darkvater@211: 	#endif
darkvater@211: 
darkvater@211: 	#endif
darkvater@211: 
darkvater@211: 
darkvater@211: 	if (_network_available) {
darkvater@211: 		DEBUG(net, 3) ("[NET][Core] OK: multiplayer available");
darkvater@211: 		// initiate network ip list
darkvater@211: 		NetworkIPListInit();
darkvater@211: 	} else
darkvater@211: 		DEBUG(net, 3) ("[NET][Core] FAILED: multiplayer not available");
darkvater@211: }
darkvater@211: 
darkvater@211: /* *************************************************** */
darkvater@211: 
darkvater@211: void NetworkCoreShutdown()
darkvater@211: {
darkvater@211: 	DEBUG(net, 3) ("[NET][Core] shutdown()");
darkvater@211: 
darkvater@211: 	#if defined(__MORPHOS__) || defined(__AMIGA__)
darkvater@211: 	{
darkvater@211: 		// free allocated ressources
darkvater@211: 		#if !defined(__MORPHOS__)
darkvater@211: 		if (TimerBase)    { CloseDevice((struct IORequest *) TimerRequest); }
darkvater@211: 		if (TimerRequest) { DeleteIORequest(TimerRequest); }
darkvater@211: 		if (TimerPort)    { DeleteMsgPort(TimerPort); }
darkvater@211: 		#endif
darkvater@211: 
darkvater@211: 		if (SocketBase) {
darkvater@211: 			CloseLibrary(SocketBase);
darkvater@211: 		}
darkvater@144: 	}
truelight@193: 	#endif
darkvater@173: 
darkvater@211: 	#if defined(WIN32)
darkvater@211: 	{ WSACleanup();}
darkvater@173: 	#endif
dominik@105: }
dominik@105: 
dominik@105: /* *************************************************** */
dominik@105: 
darkvater@228: void ParseConnectionString(const byte **player, const byte **port, byte *connection_string)
darkvater@228: {
darkvater@228: 	byte c = 0;
darkvater@228: 	while (connection_string[c] != '\0') {
darkvater@228: 		if (connection_string[c] == '#') {
darkvater@228: 			*player = &connection_string[c+1];
darkvater@228: 			connection_string[c] = '\0';
darkvater@228: 		}
darkvater@228: 		if (connection_string[c] == ':') {
darkvater@228: 			*port = &connection_string[c+1];
darkvater@228: 			connection_string[c] = '\0';
darkvater@228: 		}
darkvater@228: 		c++;
darkvater@228: 	}
darkvater@228: }
darkvater@228: 
darkvater@175: bool NetworkCoreConnectGame(const byte* b, unsigned short port)
dominik@105: {
dominik@105: 	if (!_network_available) return false;
dominik@105: 
darkvater@175: 	if (strcmp(b,"auto")==0) {
dominik@105: 		// do autodetect
dominik@105: 		NetworkUDPSearchGame(&b, &port);
darkvater@172: 	}
dominik@105: 
dominik@105: 	if (port==0) {
dominik@105: 		// autodetection failed
dominik@105: 		if (_networking_override) NetworkLobbyShutdown();
dominik@105: 		ShowErrorMessage(-1, STR_NETWORK_ERR_NOSERVER, 0, 0);
darkvater@172: 		_switch_mode_errorstr = STR_NETWORK_ERR_NOSERVER;
dominik@105: 		return false;
darkvater@172: 	}
darkvater@172: 
dominik@105: 	NetworkInitialize();
dominik@105: 	_networking = NetworkConnect(b, port);
dominik@105: 	if (_networking) {
dominik@105: 		NetworkLobbyShutdown();
darkvater@247: 		IConsoleCmdExec("exec scripts/on_client.scr 0");
darkvater@172: 	} else {
truelight@193: 		if (_networking_override)
darkvater@172: 			NetworkLobbyShutdown();
truelight@193: 
dominik@105: 		ShowErrorMessage(-1, STR_NETWORK_ERR_NOCONNECTION,0,0);
darkvater@172: 		_switch_mode_errorstr = STR_NETWORK_ERR_NOCONNECTION;
darkvater@172: 	}
dominik@105: 	return _networking;
dominik@105: }
dominik@105: 
dominik@105: /* *************************************************** */
dominik@105: 
darkvater@211: bool NetworkCoreConnectGameStruct(NetworkGameList * item)
darkvater@211: {
darkvater@211: 	return NetworkCoreConnectGame(inet_ntoa(*(struct in_addr *) &item->ip),item->port);
darkvater@211: }
darkvater@211: 
darkvater@211: /* *************************************************** */
darkvater@211: 
dominik@105: bool NetworkCoreStartGame()
dominik@105: {
dominik@105: 	if (!_network_available) return false;
dominik@105: 	NetworkLobbyShutdown();
dominik@105: 	NetworkInitialize();
dominik@105: 	NetworkListen();
dominik@105: 	NetworkUDPListen(false);
dominik@105: 	_networking_server = true;
dominik@105: 	_networking = true;
dominik@105: 	NetworkGameFillDefaults(); // clears the network game info
dominik@105: 	_network_game.players_on++; // the serverplayer is online
darkvater@247: 	// execute server initialization script
darkvater@247: 	IConsoleCmdExec("exec scripts/on_server.scr 0");
dominik@105: 	return true;
dominik@105: }
dominik@105: 
dominik@105: /* *************************************************** */
dominik@105: 
dominik@105: void NetworkCoreDisconnect()
dominik@105: {
dominik@105: 	/* terminate server */
dominik@105: 	if (_networking_server) {
dominik@105: 		NetworkUDPClose(false);
dominik@105: 		NetworkClose(false);
truelight@193: 		}
dominik@105: 
dominik@105: 	/* terminate client connection */
dominik@105: 	else if (_networking) {
dominik@105: 		NetworkClose(true);
dominik@105: 		}
truelight@193: 
dominik@105: 	NetworkShutdown();
dominik@105: }
dominik@105: 
dominik@105: /* *************************************************** */
dominik@105: 
darkvater@211: void NetworkCoreLoop(bool incomming)
darkvater@211: {
darkvater@211: 	if (incomming) {
darkvater@211: 		// incomming
darkvater@211: 		if ( _udp_client_socket != INVALID_SOCKET ) NetworkUDPReceive(true);
darkvater@211: 		if ( _udp_server_socket != INVALID_SOCKET ) NetworkUDPReceive(false);
dominik@105: 
darkvater@211: 		if (_networking)
darkvater@211: 			NetworkReceive();
dominik@105: 
dominik@105: 	} else {
darkvater@211: 		if ( _udp_client_socket != INVALID_SOCKET ) NetworkUDPReceive(true);
darkvater@211: 		if ( _udp_server_socket != INVALID_SOCKET ) NetworkUDPReceive(false);
truelight@185: 
darkvater@211: 		if (_networking)
darkvater@211: 			NetworkSend();
dominik@105: 	}
dominik@105: }
dominik@105: 
darkvater@211: void NetworkLobbyInit()
darkvater@211: {
truelight@185: 	DEBUG(net, 3) ("[NET][Lobby] init()");
dominik@105: 	NetworkUDPListen(true);
dominik@105: }
dominik@105: 
darkvater@211: void NetworkLobbyShutdown()
darkvater@211: {
truelight@185: 	DEBUG(net, 3) ("[NET][Lobby] shutdown()");
dominik@105: 	NetworkUDPClose(true);
dominik@105: }
dominik@105: 
dominik@105: 
dominik@105: // ******************************** //
dominik@105: // * Network Game List Extensions * //
dominik@105: // ******************************** //
dominik@105: 
darkvater@211: void NetworkGameListClear()
darkvater@211: {
darkvater@211: 	NetworkGameList * item;
darkvater@211: 	NetworkGameList * next;
dominik@105: 
darkvater@211: 	DEBUG(net, 4) ("[NET][G-List] cleared server list");
darkvater@211: 
darkvater@211: 	item = _network_game_list;
darkvater@211: 
darkvater@211: 	while (item != NULL) {
darkvater@211: 		next = (NetworkGameList *) item -> _next;
darkvater@211: 		free (item);
darkvater@211: 		item = next;
dominik@105: 	}
darkvater@211: 	_network_game_list=NULL;
darkvater@211: 	_network_game_count=0;
dominik@105: }
dominik@105: 
darkvater@211: NetworkGameList * NetworkGameListAdd()
darkvater@211: {
darkvater@211: 	NetworkGameList * item;
darkvater@211: 	NetworkGameList * before;
dominik@105: 
darkvater@211: 	DEBUG(net, 4) ("[NET][G-List] added server to list");
dominik@105: 
darkvater@211: 	item = _network_game_list;
dominik@105: 	before = item;
darkvater@211: 	while (item != NULL) {
darkvater@211: 		before = item;
darkvater@211: 		item = (NetworkGameList *) item -> _next;
dominik@105: 	}
darkvater@211: 
darkvater@211: 	item = malloc(sizeof(NetworkGameList));
darkvater@211: 	item -> _next = NULL;
darkvater@211: 
darkvater@211: 	if (before == NULL) {
darkvater@211: 		_network_game_list = item;
darkvater@211: 	} else
darkvater@211: 		before -> _next = item;
darkvater@211: 
darkvater@211: 	_network_game_count++;
darkvater@211: 	return item;
dominik@105: }
dominik@105: 
darkvater@211: void NetworkGameListFromLAN()
darkvater@211: {
dominik@105: 	struct UDPPacket packet;
truelight@185: 	DEBUG(net, 2) ("[NET][G-List] searching server over lan");
dominik@105: 	NetworkGameListClear();
dominik@105: 	packet.command_check=packet.command_code=NET_UDPCMD_SERVERSEARCH;
dominik@105: 	packet.data_len=0;
dominik@105: 	NetworkUDPBroadCast(true,packet);
dominik@105: }
dominik@105: 
darkvater@211: void NetworkGameListFromInternet()
darkvater@211: {
truelight@185: 	DEBUG(net, 2) ("[NET][G-List] searching servers over internet");
dominik@105: 	NetworkGameListClear();
dominik@105: 
dominik@105: 	// **TODO** masterserver communication [internet protocol list]
dominik@105: }
dominik@105: 
darkvater@211: NetworkGameList * NetworkGameListItem(uint16 index)
darkvater@211: {
darkvater@211: 	NetworkGameList * item;
darkvater@211: 	NetworkGameList * next;
darkvater@211: 	uint16 cnt = 0;
dominik@105: 
darkvater@211: 	item = _network_game_list;
dominik@105: 
darkvater@211: 	while ((item != NULL) && (cnt != index)) {
darkvater@211: 		next = (NetworkGameList *) item -> _next;
darkvater@211: 		item = next;
darkvater@211: 		cnt++;
dominik@105: 	}
dominik@105: 
darkvater@211: 	return item;
dominik@105: }
dominik@105: 
dominik@105: // *************************** //
dominik@105: // * Network Game Extensions * //
dominik@105: // *************************** //
dominik@105: 
darkvater@211: void NetworkGameFillDefaults()
darkvater@211: {
dominik@105: 	NetworkGameInfo * game = &_network_game;
darkvater@288: 	#if defined(WITH_REV)
darkvater@288: 		extern char _openttd_revision[];
darkvater@288: 	#else
darkvater@288: 		const char _openttd_revision[] = "norev000";
darkvater@288: 	#endif
truelight@193: 
truelight@185: 	DEBUG(net, 4) ("[NET][G-Info] setting defaults");
dominik@105: 
darkvater@288: 	ttd_strlcpy(game->server_name, "OpenTTD Game", sizeof(game->server_name));
dominik@105: 	game->game_password[0]='\0';
dominik@105: 	game->map_name[0]='\0';
darkvater@288: 	ttd_strlcpy(game->server_revision, _openttd_revision, sizeof(game->server_revision));
dominik@105: 	game->game_date=0;
dominik@105: 
dominik@105: 	game->map_height=0;
dominik@105: 	game->map_width=0;
dominik@105: 	game->map_set=0;
dominik@105: 
dominik@105: 	game->players_max=8;
dominik@105: 	game->players_on=0;
truelight@193: 
dominik@105: 	game->server_lang=_dynlang.curr;
dominik@105: }
dominik@105: 
darkvater@211: void NetworkGameChangeDate(uint16 newdate)
darkvater@211: {
darkvater@211: 	if (_networking_server)
dominik@105: 		_network_game.game_date = newdate;
dominik@105: }
dominik@105: 
dominik@8: #else // not ENABLE_NETWORK
truelight@0: 
truelight@0: // stubs
dominik@105: void NetworkInitialize() {}
truelight@0: void NetworkShutdown() {}
dominik@105: void NetworkListen() {}
truelight@0: void NetworkConnect(const char *hostname, int port) {}
truelight@0: void NetworkReceive() {}
truelight@0: void NetworkSend() {}
truelight@0: void NetworkSendCommand(TileIndex tile, uint32 p1, uint32 p2, uint32 cmd, CommandCallback *callback) {}
signde@239: void NetworkSendEvent(uint16 type, uint16 data_len, void * data) {};
truelight@0: void NetworkProcessCommands() {}
dominik@106: void NetworkStartSync(bool fcreset) {}
signde@208: void NetworkSendReadyPacket() {}
signde@208: void NetworkSendSyncPackets() {}
signde@208: void NetworkSendFrameSyncPackets() {}
signde@208: bool NetworkCheckClientReady() { return true; }
dominik@105: void NetworkCoreInit() { _network_available=false; };
dominik@105: void NetworkCoreShutdown() {};
dominik@105: void NetworkCoreDisconnect() {};
dominik@105: void NetworkCoreLoop(bool incomming) {};
darkvater@228: void ParseConnectionString(const byte **player, const byte **port, byte *connection_string) {};
darkvater@177: bool NetworkCoreConnectGame(const byte* b, unsigned short port) {return false;};
dominik@106: bool NetworkCoreStartGame() {return false;};
dominik@105: void NetworkLobbyShutdown() {};
dominik@105: void NetworkLobbyInit() {};
dominik@105: void NetworkGameListClear() {};
darkvater@218: NetworkGameList * NetworkGameListAdd() {return NULL;};
dominik@105: void NetworkGameListFromLAN() {};
dominik@105: void NetworkGameListFromInternet() {};
dominik@105: void NetworkGameFillDefaults() {};
darkvater@218: NetworkGameList * NetworkGameListItem(uint16 index) {return NULL;};
signde@220: bool NetworkCoreConnectGameStruct(NetworkGameList * item) {return false;};
dominik@105: void NetworkGameChangeDate(uint16 newdate) {};
dominik@105: 
dominik@105: #endif