#include "quakedef.h" static bool localconnectpending;static qsocket_t *loop_client;static qsocket_t *loop_server; intLoop_Init(void){	if(cls.state == ca_dedicated)		return -1;	return 0;} voidLoop_Shutdown(void){} qsocket_t *Loop_Connect(char *host){	if(strcmp(host, "local") != 0)		return nil; 	localconnectpending = true; 	if(!loop_client) {		if((loop_client = NET_NewQSocket()) == nil) {			Con_Printf("Loop_Connect: no qsocket available\n");			return nil;		}		strcpy(loop_client->address, "localhost");	}	loop_client->receiveMessageLength = 0;	loop_client->sendMessageLength = 0;	loop_client->canSend = true;	loop_client->local = true; 	if(!loop_server) {		if((loop_server = NET_NewQSocket()) == nil) {			Con_Printf("Loop_Connect: no qsocket available\n");			return nil;		}		strcpy(loop_server->address, "LOCAL");	}	loop_server->receiveMessageLength = 0;	loop_server->sendMessageLength = 0;	loop_server->canSend = true;	loop_server->local = true; 	loop_client->driverdata = (void *)loop_server;	loop_server->driverdata = (void *)loop_client; 	return loop_client;} qsocket_t *Loop_CheckNewConnections(void){	if(!localconnectpending)		return nil; 	localconnectpending = false;	loop_server->sendMessageLength = 0;	loop_server->receiveMessageLength = 0;	loop_server->canSend = true;	loop_client->sendMessageLength = 0;	loop_client->receiveMessageLength = 0;	loop_client->canSend = true;	return loop_server;} static intIntAlign(int value){	return (value + (sizeof(int) - 1)) & (~(sizeof(int) - 1));} intLoop_GetMessage(qsocket_t *sock){	int ret;	int length; 	if(sock->receiveMessageLength == 0)		return 0; 	ret = sock->receiveMessage[0];	length = sock->receiveMessage[1] + (sock->receiveMessage[2] << 8);	// alignment byte skipped here	SZ_Clear(&net_message);	SZ_Write(&net_message, &sock->receiveMessage[4], length); 	length = IntAlign(length + 4);	sock->receiveMessageLength -= length; 	if(sock->receiveMessageLength)		memmove(sock->receiveMessage, &sock->receiveMessage[length], sock->receiveMessageLength); 	if(sock->driverdata && ret == 1)		((qsocket_t *)sock->driverdata)->canSend = true; 	return ret;} intLoop_SendMessage(qsocket_t *sock, sizebuf_t *data){	byte *buffer;	int *bufferLength; 	if(!sock->driverdata)		return -1; 	bufferLength = &((qsocket_t *)sock->driverdata)->receiveMessageLength; 	if((*bufferLength + data->cursize + 4) > NET_MAXMESSAGE)		fatal("Loop_SendMessage: overflow\n"); 	buffer = ((qsocket_t *)sock->driverdata)->receiveMessage + *bufferLength; 	// message type	*buffer++ = 1; 	// length	*buffer++ = data->cursize & 0xff;	*buffer++ = data->cursize >> 8; 	// align	buffer++; 	// message	memmove(buffer, data->data, data->cursize);	*bufferLength = IntAlign(*bufferLength + data->cursize + 4); 	sock->canSend = false;	return 1;} intLoop_SendUnreliableMessage(qsocket_t *sock, sizebuf_t *data){	byte *buffer;	int *bufferLength; 	if(!sock->driverdata)		return -1; 	bufferLength = &((qsocket_t *)sock->driverdata)->receiveMessageLength; 	if((*bufferLength + data->cursize + sizeof(byte) + sizeof(short)) > NET_MAXMESSAGE)		return 0; 	buffer = ((qsocket_t *)sock->driverdata)->receiveMessage + *bufferLength; 	// message type	*buffer++ = 2; 	// length	*buffer++ = data->cursize & 0xff;	*buffer++ = data->cursize >> 8; 	// align	buffer++; 	// message	memmove(buffer, data->data, data->cursize);	*bufferLength = IntAlign(*bufferLength + data->cursize + 4);	return 1;} boolLoop_CanSendMessage(qsocket_t *sock){	if(!sock->driverdata)		return false;	return sock->canSend;} boolLoop_CanSendUnreliableMessage(qsocket_t *sock){	USED(sock);	return true;} voidLoop_Close(qsocket_t *sock){	if(sock->driverdata)		((qsocket_t *)sock->driverdata)->driverdata = nil;	sock->receiveMessageLength = 0;	sock->sendMessageLength = 0;	sock->canSend = true;	if(sock == loop_client)		loop_client = nil;	else		loop_server = nil;}