diff options
Diffstat (limited to 'src/parsec/net_rmev_peer.cpp')
| -rw-r--r-- | src/parsec/net_rmev_peer.cpp | 280 |
1 files changed, 280 insertions, 0 deletions
diff --git a/src/parsec/net_rmev_peer.cpp b/src/parsec/net_rmev_peer.cpp new file mode 100644 index 0000000..8e7c2d7 --- /dev/null +++ b/src/parsec/net_rmev_peer.cpp @@ -0,0 +1,280 @@ +/* + * PARSEC - Remote Events + * + * $Author: uberlinuxguy $ - $Date: 2004/09/26 03:43:40 $ + * + * Orginally written by: + * Copyright (c) Clemens Beer <cbx@parsec.org> 2002 + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + +// C library +#include <stddef.h> +#include <stdio.h> +#include <stdlib.h> +#include <string.h> + +// compilation flags/debug support +#include "config.h" +#include "debug.h" + +// general definitions +#include "general.h" +#include "objstruc.h" +#include "od_class.h" + +// global externals +#include "globals.h" + +// subsystem headers +#include "aud_defs.h" +#include "net_defs.h" +#include "sys_defs.h" + +// network code config +#include "net_conf.h" + +// local module header +#include "net_rmev.h" + +// proprietary module headers +#include "con_aux.h" +#include "net_game.h" +#include "net_rmev.h" + +// external flag +extern int name_change_notification; + + +// process entire remote event list (execute all contained events) ------------ +// +PRIVATE +void ProcessRmEvList_PEER( NetPacket_PEER* pIntPkt ) +{ + ASSERT( NetConnected ); + ASSERT( pIntPkt != NULL ); + + NetPacket_PEER* gamepacket = (NetPacket_PEER*)pIntPkt; + + //NOTE: + // if new remote events are added this function + // should be updated. + + // identify sender + int senderid = gamepacket->SendPlayerId; + ASSERT( ( senderid >= 0 ) && ( senderid < MAX_NET_PROTO_PLAYERS ) ); + + RE_Header *relist = (RE_Header *) &gamepacket->RE_List; + + // process remote event list + while ( relist->RE_Type != RE_EMPTY ) { + switch ( relist->RE_Type ) { + + case RE_OWNERSECTION: + // change senderid on RE_OWNERSECTION + senderid = ( (RE_OwnerSection*)relist )->owner; + break; + case RE_DELETED: + // ignore + break; + + case RE_CREATEOBJECT: + NET_ExecRmEvCreateObject( relist, senderid ); + break; + + case RE_CREATELASER: + NET_ExecRmEvCreateLaser( relist, senderid ); + break; + + case RE_CREATEMISSILE: + NET_ExecRmEvCreateMissile( relist, senderid ); + break; + + case RE_PARTICLEOBJECT: + NET_ExecRmEvParticleObject( relist, senderid ); + break; + + case RE_CREATEEXTRA: + NET_ExecRmEvCreateExtra( relist, senderid ); + break; + + case RE_KILLOBJECT: + NET_ExecRmEvKillObject( relist ); + break; + + case RE_SENDTEXT: + NET_ExecRmEvSendText( relist, senderid ); + break; + + case RE_PLAYERNAME: + NET_ExecRmEvPlayerName( relist, senderid ); + break; + + case RE_WEAPONSTATE: + NET_ExecRmEvWeaponState( relist, senderid ); + break; + + case RE_STATESYNC: + NET_ExecRmEvStateSync( relist, senderid ); + break; + + case RE_CREATESWARM: + NET_ExecRmEvCreateSwarm( relist, senderid ); + break; + + case RE_CREATEEMP: + NET_ExecRmEvCreateEmp( relist, senderid ); + break; + + case RE_PLAYERSTATUS: + case RE_PLAYERANDSHIPSTATUS: + case RE_KILLSTATS: + case RE_GAMESTATE: + case RE_COMMANDINFO: + case RE_CLIENTINFO: + case RE_CREATEEXTRA2: + case RE_IPV4SERVERINFO: + case RE_SERVERLINKINFO: + case RE_MAPOBJECT: + case RE_STARGATE: + // remote event invalid in peer-to-peer mode + ASSERT( FALSE ); + break; + + default: + MSGOUT( "ProcessRmEvList_PEER(): unknown remote event (%d).", relist->RE_Type ); + } + + // advance to next event in list + ASSERT( ( relist->RE_BlockSize == RE_BLOCKSIZE_INVALID ) || + ( relist->RE_BlockSize == NET_RmEvGetSize( relist ) ) ); + relist = (RE_Header *) ( (char *) relist + NET_RmEvGetSize( relist ) ); + } +} + + +// process NODE_ALIVE packet -------------------------------------------------- +// +void NET_ProcessNodeAlive_PEER( NetPacket_PEER* gamepacket ) +{ + ASSERT( NetConnected ); + ASSERT( gamepacket != NULL ); + ASSERT( gamepacket->Command == PKTP_NODE_ALIVE ); + + // identify sender + int senderid = gamepacket->SendPlayerId; + ASSERT( ( senderid >= 0 ) && ( senderid < MAX_NET_PROTO_PLAYERS ) ); + + // player must be connected in order to send NODE_ALIVE + if ( Player_Status[ senderid ] == PLAYER_INACTIVE ) { + DBGTXT( MSGOUT( "filtering NODE_ALIVE for player who is not connected: %d.", senderid ); ); + return; + } + + // player should not be joined, only connected when sending NODE_ALIVE + if ( Player_Status[ senderid ] == PLAYER_JOINED ) { + DBGTXT( MSGOUT( "warning: received NODE_ALIVE from joined player: %d.", senderid ); ); + } + + UPDTXT( MSGOUT( "received node_alive from id %d (pid=%d).", senderid, gamepacket->MessageId ); ); + + // keep player from being kicked out + Player_AliveCounter[ senderid ] = MAX_ALIVE_COUNTER; + + // update player kill stats + //NETs_UpdateKillStats( gamepacket ); + + // process remote event list + name_change_notification = FALSE; + ProcessRmEvList_PEER( gamepacket ); + name_change_notification = TRUE; +} + + +// dump the ship remote info to the console ----------------------------------- +// +static +void DumpShipRemInfo( ShipRemInfo* pShipRemInfo ) +{ + MSGOUT( "CurYaw %d CurPitch %d CurRoll %d CurSlideHorz %d CurSlideVert %d", pShipRemInfo->CurYaw, + pShipRemInfo->CurPitch, + pShipRemInfo->CurRoll, + pShipRemInfo->CurSlideHorz, + pShipRemInfo->CurSlideVert ); +} + + +// update game state with data of remote player ------------------------------- +// +void NET_UpdateGameState_PEER( NetPacket_PEER* gamepacket ) +{ + ASSERT( NetConnected ); + ASSERT( gamepacket != NULL ); + ASSERT( gamepacket->Command == PKTP_GAME_STATE ); + + // identify sender + int senderid = gamepacket->SendPlayerId; + ASSERT( ( senderid >= 0 ) && ( senderid < MAX_NET_PROTO_PLAYERS ) ); + + // player must be joined in order to send GAME_STATE + if ( Player_Status[ senderid ] != PLAYER_JOINED ) { + DBGTXT( MSGOUT( "filtering GAME_STATE for player who is not joined: %d.", senderid ); ); + return; + } + + UPDTXT( MSGOUT( "updating game state from id %d (pid=%d).", senderid, gamepacket->MessageId ); ); + //DumpShipRemInfo( &gamepacket->ShipInfo ); + + // keep player from being kicked out + Player_AliveCounter[ senderid ] = MAX_ALIVE_COUNTER; + + // set up-to-date flag (i.e., no interpolation + // need be performed since real data is available). + Player_UpToDate[ senderid ] = TRUE; + + // fetch pointer to remote player's local ship-object + ShipObject *playerobj = (ShipObject *) Player_Ship[ senderid ]; + ASSERT( playerobj != NULL ); + + // ship status will only be updated on newer messages + if ( gamepacket->MessageId > (dword)Player_LastUpdateGameStateMsgId[ senderid ] ) { + + // set ship remote info + NET_ExecShipRemInfo( &gamepacket->ShipInfo, playerobj, senderid ); + + //FIXME: + //MSGOUT( "shipstate update from packet %d/%d ( diff = %d )", gamepacket->MessageId, + // Player_LastUpdateGameStateMsgId[ senderid ], + // gamepacket->MessageId - Player_LastUpdateGameStateMsgId[ senderid ] ); + } else { + //FIXME: + MSGOUT( "NET_UpdateGameState_PEER(): supressed update from packet %d ( already had %d )", + gamepacket->MessageId, + Player_LastUpdateGameStateMsgId[ senderid ] ); + } + + // ensure message ids are monotonically increasing + Player_LastUpdateGameStateMsgId[ senderid ] = max( (dword)Player_LastUpdateGameStateMsgId[ senderid ], gamepacket->MessageId ); + + // update player kill stats + //NETs_UpdateKillStats( gamepacket ); + + // process remote event list + ProcessRmEvList_PEER( gamepacket ); +} + + + |