Changeset 8068 in orxonox.OLD for trunk/src/lib/network

Timestamp:

Jun 1, 2006, 2:28:16 PM (19 years ago)

Author:

patrick

Message:

trunk: merged the network branche back to trunk

Location:

trunk/src/lib/network

Files:

• Makefile.am (modified) (2 diffs)
• connection_monitor.cc (modified) (8 diffs)
• connection_monitor.h (modified) (1 diff)
• message_manager.cc (modified) (2 diffs)
• message_manager.h (modified) (2 diffs)
• network_game_manager.cc (modified) (3 diffs)
• network_game_manager.h (modified) (1 diff)
• network_stream.cc (modified) (9 diffs)
• network_stream.h (modified) (1 diff)
• player_stats.cc (copied) (copied from branches/network/src/lib/network/player_stats.cc)
• player_stats.h (copied) (copied from branches/network/src/lib/network/player_stats.h)
• synchronizeable.cc (modified) (7 diffs)
• synchronizeable.h (modified) (1 diff)

trunk/src/lib/network/Makefile.am

@@ -23 +23 @@
                       network_log.cc \
                       zip.cc \
+                      player_stats.cc \
                       \
                       synchronizeable_var/synchronizeable_var.cc \
@@ -56 +57 @@
                  network_log.h \
                  zip.h \
+                 player_stats.h \
                  \
                  synchronizeable_var/synchronizeable_var.h \

trunk/src/lib/network/connection_monitor.cc

@@ -61 +61 @@
  * @param stateId packet's state id
  */
-void ConnectionMonitor::processUnzippedOutgoingPacket( byte * data, int length, int stateId )
-{
-  int tick = SDL_GetTicks();
-  
+void ConnectionMonitor::processUnzippedOutgoingPacket( int tick, byte * data, int length, int stateId )
+{
   nOutgoingPackets++;
   
@@ -77 +75 @@
   
   // count zero bytes
-  int nZeroBytes = 0;
-  
-  for ( int i = 0; i < length; i++ )
-    if ( data[i] == '\0' )
-      nZeroBytes++;
+  //int nZeroBytes = 0;
+  
+  //for ( int i = 0; i < length; i++ )
+  //  if ( data[i] == '\0' )
+  //    nZeroBytes++;
   
   //NETPRINTF(n)( "ZEROBYTES: %d (%f%%)\n", nZeroBytes, ((float)100)*nZeroBytes/length );
@@ -93 +91 @@
  * @param ackedState state which was acked by this packet
  */
-void ConnectionMonitor::processUnzippedIncomingPacket( byte * data, int length, int stateId, int ackedState )
-{
-  int tick = SDL_GetTicks();
-  
+void ConnectionMonitor::processUnzippedIncomingPacket( int tick, byte * data, int length, int stateId, int ackedState )
+{
   nIncomingPackets++;
   
@@ -149 +145 @@
   for ( std::map<int,int>::iterator it = packetHistory.begin(); it != packetHistory.end(); it++ )
   {
-    res += it->second;
+    if ( it != packetHistory.begin() )
+      res += it->second;
   }
   
@@ -155 +152 @@
     res = 0.0f;
   else
-    res /= (float)((tick - packetHistory.begin()->first)*( 1 + 1/((float)(packetHistory.size()-1)) ));
+    res /= (float)(tick - packetHistory.begin()->first);
   
   res *= 1000.0f;
@@ -169 +166 @@
  * @param stateId packet's state id
  */
-void ConnectionMonitor::processZippedOutgoingPacket( byte * data, int length, int stateId )
-{
-  int tick = SDL_GetTicks();
-  
+void ConnectionMonitor::processZippedOutgoingPacket( int tick, byte * data, int length, int stateId )
+{
   nZOutgoingPackets++;
   
@@ -196 +191 @@
  * @param ackedState state which was acked by this packet
  */
-void ConnectionMonitor::processZippedIncomingPacket( byte * data, int length, int stateId, int ackedState )
-{
-  int tick = SDL_GetTicks();
-  
+void ConnectionMonitor::processZippedIncomingPacket( int tick, byte * data, int length )
+{
   nZIncomingPackets++;
   
@@ -233 +226 @@
 void ConnectionMonitor::printStatis( )
 {
-  NETPRINT(n)("=========NETWORKSTATS FOR USER %d=========\n", userId);
-  NETPRINT(n)("PING = %d\n", ping);
+  NETPRINT(n)("============NETWORKSTATS FOR USER %d============\n", userId);
+  NETPRINT(n)("PING = %d\n", ping );
   NETPRINT(n)("BANDWIDTH: UP: %f (%f) DOWN %f (%f)\n", outgoingZippedBandWidth, outgoingUnzippedBandWidth, incomingZippedBandWidth, incomingUnzippedBandWidth);
-  NETPRINT(n)("==========================================");
-}
-
-
+  NETPRINT(n)("PACKETS: RECIEVED %d; SENT %d\n", nIncomingPackets, nOutgoingPackets );
+  NETPRINT(n)("================================================\n");
+}
+
+

trunk/src/lib/network/connection_monitor.h

@@ -22 +22 @@
     virtual ~ConnectionMonitor();
 
-    void processUnzippedOutgoingPacket( byte * data, int length, int stateId );
-    void processUnzippedIncomingPacket( byte * data, int length, int stateId, int ackedState );
+    void processUnzippedOutgoingPacket( int tick, byte * data, int length, int stateId );
+    void processUnzippedIncomingPacket( int tick, byte * data, int length, int stateId, int ackedState );
     
-    void processZippedOutgoingPacket( byte * data, int length, int stateId );
-    void processZippedIncomingPacket( byte * data, int length, int stateId, int ackedState );
+    void processZippedOutgoingPacket( int tick, byte * data, int length, int stateId );
+    void processZippedIncomingPacket( int tick, byte * data, int length );
     
     void calculatePing();

trunk/src/lib/network/message_manager.cc

@@ -309 +309 @@
   {
     if ( 
-         recieverType == RT_ALL ||
+         recieverType == RT_ALL_ME ||
+         recieverType == RT_ALL_NOT_ME ||
          recieverType == RT_USER && it->first == reciever ||
          recieverType == RT_NOT_USER && it->first != reciever
@@ -324 +325 @@
       
       it->second.messages.push_back( msg );
-    }
-  }
-}
-
-
+      
+      if ( recieverType == RT_ALL_ME )
+        incomingMessabeBuffer.push_back( msg );
+    }
+  }
+}
+
+

trunk/src/lib/network/message_manager.h

@@ -29 +29 @@
 {
   TESTMESSAGEID = 1,
-  MSGID_YOU_ARE
+  MSGID_DELETESYNCHRONIZEABLE
 };
 
@@ -36 +36 @@
 enum RecieverType
 {
-  RT_ALL = 1,   //!< message is sent to all users
-  RT_USER,      //!< message is only sent to reciever
-  RT_NOT_USER   //!< message is sent to all but reciever
+  RT_ALL_NOT_ME = 1,   //!< message is sent to all users
+  RT_ALL_ME,           //!< message is sent to all users
+  RT_USER,             //!< message is only sent to reciever
+  RT_NOT_USER          //!< message is sent to all but reciever
 };
 

trunk/src/lib/network/network_game_manager.cc

@@ -34 +34 @@
 #include "game_world.h"
 
+#include "game_rules.h"
+#include "network_game_rules.h"
+
 #include "network_game_manager.h"
 
@@ -55 +58 @@
   this->setSynchronized(true);
   
-  MessageManager::getInstance()->registerMessageHandler( MSGID_YOU_ARE, youAreHandler, NULL );
+  MessageManager::getInstance()->registerMessageHandler( MSGID_DELETESYNCHRONIZEABLE, delSynchronizeableHandler, NULL );
+  
+  this->gameState = 0;
+  registerVar( new SynchronizeableInt( &gameState, &gameState, "gameState" ) );
 }
 
@@ -63 +69 @@
 NetworkGameManager::~NetworkGameManager()
 {
-#if 0
-  for ( int i = 0; i<outBuffer.size(); i++)
-  {
-    if ( outBuffer[i].buffer )
-      delete outBuffer[i].buffer;
-  }
-#endif
-
-}
-
-#if 0
-int NetworkGameManager::writeBytes(const byte* data, int length, int sender)
-{
-  int i = 0;
-  byte b;
-
-  while ( i<length )
-  {
-    b = data[i++];
-
-    /**************** Commands only processed by servers ****************/
-    if ( isServer() )
-    {
-      if ( b == NET_REQUEST_CREATE )
-      {
-        if ( !handleRequestCreate( i, data, length, sender ) )
-          return i;
-        continue;
-      }
-      else if ( b == NET_REQUEST_REMOVE )
-      {
-        if ( !handleRequestRemove( i, data, length, sender ) )
-          return i;
-        continue;
-      }
-      else if ( b == NET_REQUEST_PNODE_PATH )
-      {
-        if ( !handleRequestPNodePath( i, data, length, sender ) )
-          return i;
-        continue;
-      }
-    }
-    else
-    {
-      /**************** Commands only processed by clients ****************/
-      if ( b == NET_CREATE_ENTITY )
-      {
-        PRINTF(0)("CREATE_ENTITY\n");
-        if ( !handleCreateEntity( i, data, length, sender ) )
-          return i;
-        continue;
-      }
-      else if ( b == NET_REMOVE_ENTITY )
-      {
-        if ( !handleRemoveEntity( i, data, length, sender ) )
-          return i;
-        continue;
-      }
-      else if ( b == NET_CREATE_ENTITY_LIST )
-      {
-        if ( !handleCreateEntityList( i, data, length, sender ) )
-          return i;
-        continue;
-      }
-      else if ( b == NET_REMOVE_ENTITY_LIST )
-      {
-        if ( !handleRemoveEntityList( i, data, length, sender ) )
-          return i;
-        continue;
-      }
-      else if ( b == NET_YOU_ARE_ENTITY )
-      {
-        if ( !handleYouAreEntity( i, data, length, sender ) )
-          return i;
-        continue;
-      }
-    }
-
-    /**************** Commands processed by servers and clients ****************/
-    if ( b == NET_REQUEST_ENTITY_LIST )
-    {
-      sendEntityList( sender );
-      continue;
-    }
-
-
-    PRINTF(1)("Network is asynchronous: couldn't decode the command sent by %i\n", sender);
-    PRINTF(1)("Probably this is because the network protocol has different \n");
-    PRINTF(1)("versions or there occured an error in the sending algorithm\n");
-    PRINTF(1)("Data is not in the right format! i=%d\n", i);
-    return i;
-  }
-
-  return i;
-}
-#endif
-
-#if 0
-int NetworkGameManager::readBytes(byte* data, int maxLength, int * reciever)
-{
-  if ( !isServer() && !hasRequestedWorld )
-  {
-    assert( maxLength >= 1 );
-    data[0] = NET_REQUEST_ENTITY_LIST;
-    hasRequestedWorld = true;
-    return 1;
-  }
-
-  for ( int i = 0; i<outBuffer.size(); i++ )
-  {
-    *reciever = i;
-    if ( outBuffer[i].length>0 )
-    {
-      int nbytes = outBuffer[i].length;
-      outBuffer[i].length = 0;
-
-      if ( nbytes > maxLength )
-      {
-        PRINTF(1)("OutBuffer.length (%d) > (%d) networkStreamBuffer.maxLength\n", nbytes, maxLength);
-        return 0;
-      }
-
-      memcpy(data, outBuffer[i].buffer, nbytes);
-      return nbytes;
-    }
-  }
-
-  return 0;
-}
-#endif
-
-#if 0
-void NetworkGameManager::writeDebug() const
-{
-}
-
-void NetworkGameManager::readDebug() const
-{
-}
-#endif
-
-
-/*!
- * Checks whether this is connected to a server or a client
- * and afterwards creates the needed entity
- * @param classID: The ID of the class of which an entity should be created
- */
-int NetworkGameManager::createEntity( ClassID classID, int owner )
-{
-  if ( this->isServer())
-  {
-    int res = this->executeCreateEntity( classID, SharedNetworkData::getInstance()->getNewUniqueID(), owner );
-    
-    if ( res < 0 )
-    {
-      PRINTF(1)("Cannot create entity! There are no more uniqueIDs left!\n");
-      return -1;
-    }
-    
-    return res;
-  }
-  else
-  {
-#if 0
-    this->requestCreateEntity( classID );
-#endif
-    return -1;
-  }
 }
 
 
-/*!
- * Checks whether this is connected to a server or a client
- * and afterwards creates the needed entity
- * @param classID: The ID of the class of which an entity should be created
+/**
+ * insert new player into game
+ * @param userId 
+ * @return 
  */
-BaseObject* NetworkGameManager::createEntity(const TiXmlElement* element)
+bool NetworkGameManager::signalNewPlayer( int userId )
 {
-  if ( this->isServer() )
-  {
-    if ( SharedNetworkData::getInstance()->getNewUniqueID() < 0 )
-    {
-      PRINTF(1)("Cannot create entity! There are no more uniqueIDs left!\n");
-      return NULL;
-    }
-
-    BaseObject * b = Factory::fabricate( element );
-
-    if ( !b )
-    {
-      PRINTF(1)("Could not fabricate Object with className %s\n", element->Value() );
-      return NULL;
-    }
-
-
-    if ( b->isA(CL_SYNCHRONIZEABLE) )
-    {
-      Synchronizeable * s = dynamic_cast<Synchronizeable*>(b);
-      s->setUniqueID( SharedNetworkData::getInstance()->getNewUniqueID() );
-      s->setOwner( 0 );
-      // all entities created via this function are added automaticaly to the synchronizeable list
-      s->setSynchronized(true);
-      return b;
-    }
-    else
-    {
-      PRINTF(1)("Class %s is not a synchronizeable!\n", b->getClassName() );
-      delete b;
-    }
-
-  }
-  else
-
-  {
-    PRINTF(1)("This node is not a server and cannot create id %x\n", element->Value());
-  }
-  return NULL;
+  assert( SharedNetworkData::getInstance()->isGameServer() );
+  assert( State::getGameRules() );
+  assert( State::getGameRules()->isA( CL_NETWORK_GAME_RULES ) );
+  
+  NetworkGameRules & rules = *(dynamic_cast<NetworkGameRules*>(State::getGameRules()));
+  
+  int team = rules.getTeamForNewUser();
+  ClassID playableClassId = rules.getPlayableClassId( team );
+  std::string playableModel = rules.getPlayableModelFileName( team, playableClassId );
+  
+  BaseObject * bo = Factory::fabricate( playableClassId );
+  
+  assert( bo != NULL );
+  assert( bo->isA( CL_PLAYABLE ) );
+  
+  Playable & playable = *(dynamic_cast<Playable*>(bo));
+  
+  playable.loadModel( playableModel );
+  playable.setOwner( userId );
+  playable.setUniqueID( SharedNetworkData::getInstance()->getNewUniqueID() );
+  playable.setSynchronized( true );
+  
+  PlayerStats * stats = rules.getNewPlayerStats( userId );
+  
+  stats->setUniqueID( SharedNetworkData::getInstance()->getNewUniqueID() );
+  stats->setSynchronized( true );
+  stats->setOwner( getHostID() );
+  
+  stats->setTeamId( team );
+  stats->setPlayableClassId( playableClassId );
+  stats->setPlayableUniqueId( playable.getUniqueID() );
+  stats->setModelFileName( playableModel );
 }
 
 
-/*!
- * Checks whether this is connected to a server or a client
- * and afterwards removes the specified entity
- * @param uniqueID: The ID of the entity object which should be removed
+/**
+ * remove player from game
+ * @param userID 
+ * @return 
  */
-void NetworkGameManager::removeEntity(int uniqueID)
+bool NetworkGameManager::signalLeftPlayer(int userID)
 {
-  if ( this->isServer() )
-  {
-    this->executeRemoveEntity( uniqueID );
-  }
-  else
-  {
-#if 0
-    this->requestRemoveEntity( uniqueID );
-#endif
-  }
-}
-
-
-#if 0
-/*!
- * Creates the needed entity on the server if possible
- * @param classID: The ID of the class of which an entity should be created
- */
-void NetworkGameManager::requestCreateEntity(ClassID classID)
-{
-  for ( int i = 0; i<outBuffer.size(); i++)
-  {
-    if ( !this->networkStream->isUserIdActive( i ) )
-      continue;
-
-    if ( !writeToClientBuffer( outBuffer[i], (byte)NET_REQUEST_CREATE ) )
-      return;
-    if ( !writeToClientBuffer( outBuffer[i], (int)classID ) )
-      return;
-  }
-}
-#endif
-
-#if 0
-/*!
- * Removes the specified entity on the server
- * @param uniqueID: The ID of the entity object which should be removed
- */
-void NetworkGameManager::requestRemoveEntity(int uniqueID)
-{
-  for ( int i = 0; i<outBuffer.size(); i++)
-  {
-    if ( !this->networkStream->isUserIdActive( i ) )
-      continue;
-
-    if ( !writeToClientBuffer( outBuffer[i], (byte)NET_REQUEST_REMOVE ) )
-      return;
-    if ( !writeToClientBuffer( outBuffer[i], uniqueID ) )
-      return;
-  }
-}
-#endif
-
-/*!
- * Creates the needed entity if possible
- * This function is called if this is a server
- * @param classID: The ID of the class of which an entity should be created
- */
-int NetworkGameManager::executeCreateEntity(ClassID classID, int uniqueID, int owner)
-{
-#if 0
-  for ( int i = 0; i<outBuffer.size(); i++)
-  {
-    if ( !this->networkStream->isUserIdActive( i ) )
-      continue;
-
-    if ( !writeToClientBuffer( outBuffer[i], (byte)NET_CREATE_ENTITY ) )
-      return -1;
-    if ( !writeToClientBuffer( outBuffer[i], (int)classID ) )
-      return -1;
-    if ( !writeToClientBuffer( outBuffer[i], uniqueID ) )
-      return -1;
-    if ( !writeToClientBuffer( outBuffer[i], owner ) )
-      return -1;
-  }
-#endif
-  PRINTF(0)("ExecuteCreateEntity: server side: classID: %x, uniqueID: %i, owner: %i\n", classID, uniqueID, owner);
-  doCreateEntity( classID, uniqueID, owner );
-
-  return uniqueID;
-}
-
-/*!
- * Removes the specified entity
- * This function is called if this is a server
- * @param uniqueID: The ID of the entity object which should be removed
- */
-void NetworkGameManager::executeRemoveEntity(int uniqueID)
-{
-#if 0
-  for ( int i = 0; i<outBuffer.size(); i++)
-  {
-    if ( !this->networkStream->isUserIdActive( i ) )
-      continue;
-
-    if ( !writeToClientBuffer( outBuffer[i], (byte)NET_REMOVE_ENTITY ) )
-      return;
-    if ( !writeToClientBuffer( outBuffer[i], uniqueID ) )
-      return;
-  }
-#endif
-
-  doRemoveEntity(uniqueID);
-}
-
-/*!
- * Checks whether it is possible to create an entity of a given class
- * @return: true if the entity can be created, false otherwise
- */
-bool NetworkGameManager::canCreateEntity(ClassID classID)
-{
-  return true;
-}
-
-#if 0
-/*!
- * Sends the Entities to the new connected client
- * @param userID: The ID of the user
- */
-void NetworkGameManager::sendEntityList( int userID )
-{
-  if ( !isServer() )
-    return;
-
-  if ( userID >= outBuffer.size() )
-    resizeBufferVector( userID );
-
-  SynchronizeableList::const_iterator it, e;
-
-  it = this->networkStream->getSyncBegin();
-  e = this->networkStream->getSyncEnd();
-
-  // send the packet header
-  if ( !writeToClientBuffer( outBuffer[userID], (byte)NET_CREATE_ENTITY_LIST ) )
-    return;
-
-  // send the number of entities: -2 because you must not send network_game_manager and handshake
-  if ( !writeToClientBuffer( outBuffer[userID], networkStream->getSyncCount() ) )
-    return;
-
-  //PRINTF(0)("SendEntityList: n = %d\n", networkStream->getSyncCount()-2 );
-
-  // first send the NullParent
-  if ( !writeToClientBuffer( outBuffer[userID], (int)PNode::getNullParent()->getLeafClassID()) )
-    return;
-  if ( !writeToClientBuffer( outBuffer[userID], (int)PNode::getNullParent()->getUniqueID()) )
-    return;
-  if ( !writeToClientBuffer( outBuffer[userID], (int)PNode::getNullParent()->getOwner()) )
-    return;
-
-  // now send the rest of the entities
-  while ( it != e )
-  {
-    if( (*it)->beSynchronized() && (*it) != PNode::getNullParent())
-    {
-      PRINTF(0)("SENDING ENTITY %s classid: %x, uniqueid %d\n", (*it)->getClassName(), (*it)->getLeafClassID(), (*it)->getUniqueID() );
-      if ( !writeToClientBuffer( outBuffer[userID], (int)((*it)->getLeafClassID()) ) )
-        return;
-
-      if ( !writeToClientBuffer( outBuffer[userID], (int)((*it)->getUniqueID()) ) )
-        return;
-
-      if ( !writeToClientBuffer( outBuffer[userID], (int)((*it)->getOwner()) ) )
-        return;
-    }
-    it++;
-  }
-
-  signalNewPlayer( userID );
-}
-#endif
-
-
-
-bool NetworkGameManager::signalNewPlayer(int userId)
-{
-  /* create new playable for Player*/
-  PRINTF(0)("Request for creation: %i\n", userId);
-  int uniqueId = this->createEntity(CL_SPACE_SHIP, userId);
-  PRINTF(0)("Request for creation: userid: %i, uniqueid: %i\n", userId, uniqueId);
-  this->sendYouAre(uniqueId, userId);
+  delete PlayerStats::getStats( userID )->getPlayable();
+  delete PlayerStats::getStats( userID );
 }
 
 
 
-bool NetworkGameManager::signalLeftPlayer(int userID)
+/**
+ * handler for remove synchronizeable messages
+ * @param messageId 
+ * @param data 
+ * @param dataLength 
+ * @param someData 
+ * @param userId 
+ * @return true on successfull handling else handler will be called again
+ */
+bool NetworkGameManager::delSynchronizeableHandler( MessageId messageId, byte * data, int dataLength, void * someData, int userId )
 {
-  const std::list<BaseObject*>* playableList = ClassList::getList(CL_PLAYABLE);
+  if ( getInstance()->isServer() )
+  {
+    PRINTF(2)("Recieved DeleteSynchronizeable message from client %d!\n", userId);
+    return true;
+  }
   
-  if ( !playableList )
-    return false;
+  int uniqueId = 0;
+  int len = Converter::byteArrayToInt( data, &uniqueId );
   
-  std::list<BaseObject*>::const_iterator it = playableList->begin();
-
-  for(; it != playableList->end(); it++)
+  if ( len != dataLength )
   {
-    if( dynamic_cast<Synchronizeable*>(*it)->getOwner() == userID )
+    PRINTF(2)("Recieved DeleteSynchronizeable message with incorrect size (%d) from client %d!\n", dataLength, userId);
+    return true;
+  }
+  
+  const std::list<BaseObject*> * list = ClassList::getList( CL_SYNCHRONIZEABLE );
+  
+  for ( std::list<BaseObject*>::const_iterator it = list->begin(); it != list->end(); it++ )
+  {
+    if ( dynamic_cast<Synchronizeable*>(*it)->getUniqueID() == uniqueId )
     {
-      PRINTF(0)("remove playable from %i\n", userID);
-      this->removeEntity(dynamic_cast<Synchronizeable*>(*it)->getUniqueID());
+      delete dynamic_cast<Synchronizeable*>(*it);
       return true;
     }
   }
-  return false;
-}
-
-#if 0
-/**
- * Creates a buffer for user n
- * @param n The ID of the user
- */
-void NetworkGameManager::resizeBufferVector( int n )
-{
-  for ( int i = outBuffer.size(); i<=n; i++)
-  {
-    clientBuffer outBuf;
-
-    outBuf.length = 0;
-
-    outBuf.maxLength = 5*1024;
-
-    outBuf.buffer = new byte[5*1014];
-
-    outBuffer.push_back(outBuf);
-  }
-}
-#endif
-
-/**
- * Creates the entity on this host
- * @param classID: ClassID of the entity to create
- * @param uniqueID: Unique ID to assign to the synchronizeable
- * @param owner: owner of this synchronizealbe
- */
-BaseObject* NetworkGameManager::doCreateEntity( ClassID classID, int uniqueID, int owner )
-{
-  PRINTF(0)("Creating Entity via Factory: classid: %x, uniqueID: %i, owner: %i\n", classID, uniqueID, owner);
-
-  BaseObject * b;
-  /* These are some small exeptions in creation: Not all objects can/should be created via Factory */
-  /* Exception 1: NullParent */
-  if( classID == CL_NULL_PARENT)
-  {
-    b = (BaseObject*)PNode::getNullParent();
-  }
-  else
-    b = Factory::fabricate( classID );
-
-  if ( !b )
-  {
-    PRINTF(1)("Could not fabricate Object with classID %x\n", classID);
-    return NULL;
-  }
-
-  if ( b->isA(CL_SYNCHRONIZEABLE) )
-  {
-    Synchronizeable * s = dynamic_cast<Synchronizeable*>(b);
-    s->setUniqueID( uniqueID );
-    s->setOwner( owner );
-    s->setSynchronized(true);
-    //this->networkStream->connectSynchronizeable( *s );
-
-    PRINTF(0)("Fabricated %s with id %d\n", s->getClassName(), s->getUniqueID());
-
-    //TODO HACK: hack to prevent collision
-    if ( b->isA(CL_WORLD_ENTITY) && !b->isA(CL_PLAYABLE) )
-    {
-      if ( SharedNetworkData::getInstance()->getHostID()!=0 )
-      {
-        static Vector pos = Vector(1000.0, 1000.0, 1000.0);
-        PNode *p = dynamic_cast<PNode*>(b);
-        p->setAbsCoor(pos);
-        p->updateNode(0);
-        pos += Vector(1000.0, 1000.0, 1000.0);
-      }
-    }
-    ///TODO HACK this is only for network multiplayer games.
-    if( b->isA(CL_PLAYABLE))
-    {
-      Playable* ss = dynamic_cast<Playable*>(b);
-      if( owner%2 == 0)
-      {
-
-        ss->loadModel("models/ships/reap_0.obj");
-        ss->toList(OM_GROUP_00);
-        ss->setAbsCoor(213.37, 57.71, -47.98);
-        ss->setAbsDir(Quaternion(0.16, 0.98, -0.10));
-      }
-      else
-      {
-        ss->loadModel( "models/ships/fighter.obj" );
-        ss->toList(OM_GROUP_01);
-        ss->setAbsCoor(-314.450, 40.701, 83.554);
-      }
-    }
-
-    return b;
-  }
-  else
-  {
-    PRINTF(1)("Class with ID %x is not a synchronizeable!", (int)classID);
-    delete b;
-  }
-  return NULL;
 }
 
 /**
- * Removes a entity on this host
- * @param uniqueID: unique ID assigned with the entity to remove
+ * removes synchronizeable (also on clients)
+ * @param uniqueId uniqueid to delete
  */
-void NetworkGameManager::doRemoveEntity( int uniqueID )
+void NetworkGameManager::removeSynchronizeable( int uniqueId )
 {
-  SynchronizeableList::const_iterator it,e;
-  it = this->networkStream->getSyncBegin();
-  e = this->networkStream->getSyncEnd();
-
-  while ( it != e )
-  {
-    if ( (*it)->getUniqueID() == uniqueID )
-    {
-      assert((*it)->isA(CL_WORLD_ENTITY));
-      dynamic_cast<WorldEntity*>(*it)->leaveWorld();
-      dynamic_cast<WorldEntity*>(*it)->toList(OM_DEAD);
-      break;
-    }
-    it++;
-  }
-}
-
-#if 0
-/**
- * Copies length bytes to the clientBuffer with error checking
- * @param clientBuffer: the clientBuffer to write to
- * @param data: buffer to the data
- * @param length: length of data
- * @return false on error true else
- */
-bool NetworkGameManager::writeToClientBuffer( clientBuffer &cb, byte * data, int length )
-{
-  if ( length > cb.maxLength-cb.length )
-  {
-    PRINTF(1)("No space left in clientBuffer\n");
-    return false;
-  }
-
-  memcpy( cb.buffer+cb.length, data, length );
-  return true;
-}
-#endif
-
-#if 0
-/**
- * Reads data from clientBuffer with error checking
- * @param clientBuffer: the clientBuffer to read from
- * @param data: pointer to the buffer
- * @param length:
- * @return
- */
-bool NetworkGameManager::readFromClientBuffer( clientBuffer &cb, byte * data, int length )
-{
-  if ( cb.length < length )
-  {
-    PRINTF(0)("There is not enough data in clientBuffer\n");
-    return 0;
-  }
-
-  memcpy( data, cb.buffer+cb.length-length, length );
-  return true;
-}
-#endif
-
-/**
- * Tells this client that he has to control this entity
- * @param uniqueID: the entity's uniqeID
- */
-void NetworkGameManager::doYouAre( int uniqueID )
-{
-
-  SynchronizeableList::const_iterator it = this->networkStream->getSyncBegin();
-
-  Playable *p = NULL;
-  Synchronizeable *s = NULL;
-
-  for ( ; it !=networkStream->getSyncEnd(); it++ )
-  {
-    if ( (*it)->getUniqueID()==uniqueID )
-    {
-      if ( (*it)->isA( CL_SYNCHRONIZEABLE ) )
-      {
-        s = dynamic_cast<Synchronizeable*>(*it);
-      }
-      if ( (*it)->isA( CL_PLAYABLE ) )
-      {
-        p = dynamic_cast<Playable*>(*it);
-        break;
-      } else
-      {
-        PRINTF(1)("UniqueID %d is not a Playable\n", uniqueID);
-      }
-    }
-  }
-
-  Player* player = State::getPlayer();
-  assert(p != NULL);
-  assert(s != NULL);
-  assert(player != NULL);
-
-  PRINTF(0)("uniqueID = %d\n", s->getUniqueID());
-
-  player->setPlayable(p);
-
-
-}
-
-/**
- * Tells a remote client that he has to control this entity
- * @param uniqueID: the entity's uniqeID
- * @param userID: the users ID
- */
-void NetworkGameManager::sendYouAre( int uniqueID, int userID )
-{
-  if ( !isServer() )
-    return;
-  
   byte buf[INTSIZE];
   
-  Converter::intToByteArray( uniqueID, buf, INTSIZE );
+  assert( Converter::intToByteArray( uniqueId, buf, INTSIZE ) == INTSIZE );
   
-  MessageManager::getInstance()->sendMessage( MSGID_YOU_ARE, buf, INTSIZE, RT_USER, userID, MP_HIGHBANDWIDTH);
-}
-
-bool NetworkGameManager::handleRequestCreate( int & i, const byte * data, int length, int sender )
-{
-  if ( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read classID from buffer! Not enough data left!\n");
-    return false;
-  }
-  int classID;
-  i += Converter::byteArrayToInt( &data[i], &classID );
-
-  createEntity( (ClassID)classID );
-
-  return true;
-}
-
-bool NetworkGameManager::handleRequestRemove( int & i, const byte * data, int length, int sender )
-{
-  if ( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read uniqueID from buffer! Not enough data left!\n");
-    return false;
-  }
-  int uniqueID;
-  i += Converter::byteArrayToInt( &data[i], &uniqueID );
-
-  removeEntity( uniqueID );
-
-  return true;
-}
-
-bool NetworkGameManager::handleCreateEntity( int & i, const byte * data, int length, int sender )
-{
-  if ( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read classID from buffer! Not enough data left!\n");
-    return false;
-  }
-  int classID;
-  i += Converter::byteArrayToInt( &data[i], &classID );
-
-  if ( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read uniqueID from buffer! Not enough data left!\n");
-    return false;
-  }
-  int uniqueID;
-  i += Converter::byteArrayToInt( &data[i], &uniqueID );
-
-  if ( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read owner from buffer! Not enough data left!\n");
-    return false;
-  }
-  int owner;
-  i += Converter::byteArrayToInt( &data[i], &owner );
-
-  PRINTF(0)("handleCreateEntity: client side: classID: %x, uniqueID: %i, owner: %i\n", classID, uniqueID, owner);
-  doCreateEntity( (ClassID)classID, uniqueID, owner );
-
-  return true;
-}
-
-bool NetworkGameManager::handleRemoveEntity( int & i, const byte * data, int length, int sender )
-{
-  if ( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read uniqueID from buffer! Not enough data left!\n");
-    return false;
-  }
-  int uniqueID;
-  i += Converter::byteArrayToInt( &data[i], &uniqueID );
-
-  doRemoveEntity( uniqueID );
-
-  return true;
-}
-
-bool NetworkGameManager::handleCreateEntityList( int & i, const byte * data, int length, int sender )
-{
-  if ( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read n from buffer! Not enough data left!\n");
-    return false;
-  }
-
-  PRINTF(0)("HandleCreateEntityList:  data[i..i+3] = %d %d %d %d\n", data[i], data[i+1], data[i+2], data[i+3]);
-
-  int n;
-  i += Converter::byteArrayToInt( &data[i], &n );
-
-
-  PRINTF(0)("HandleCreateEntityList: n = %d\n", n);
-
-  int classID, uniqueID, owner;
-
-  for ( int j = 0; j<n; j++ )
-  {
-
-    if ( INTSIZE > length-i )
-    {
-      PRINTF(1)("Cannot read classID from buffer! Not enough data left!\n");
-      return false;
-    }
-    i += Converter::byteArrayToInt( &data[i], &classID );
-
-    if ( INTSIZE > length-i )
-    {
-      PRINTF(1)("Cannot read uniqueID from buffer! Not enough data left!\n");
-      return false;
-    }
-    i += Converter::byteArrayToInt( &data[i], &uniqueID );
-
-    if ( INTSIZE > length-i )
-    {
-      PRINTF(1)("Cannot read owner from buffer! Not enough data left!\n");
-      return false;
-    }
-    i += Converter::byteArrayToInt( &data[i], &owner );
-
-    if ( classID != CL_NETWORK_GAME_MANAGER && classID != CL_HANDSHAKE )
-    {
-      BaseObject* b = doCreateEntity( (ClassID)classID, uniqueID, owner );
-    }
-
-  }
-
-  return true;
-}
-
-bool NetworkGameManager::handleRemoveEntityList( int & i, const byte * data, int length, int sender )
-{
-  if ( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read n from buffer! Not enough data left!\n");
-    return false;
-  }
-  int n;
-  i += Converter::byteArrayToInt( &data[i], &n );
-
-  int uniqueID;
-
-  for ( int j = 0; j<n; j++ )
-  {
-
-    if ( INTSIZE > length-i )
-    {
-      PRINTF(1)("Cannot read uniqueID from buffer! Not enough data left!\n");
-      return false;
-    }
-    i += Converter::byteArrayToInt( &data[i], &uniqueID );
-
-    doRemoveEntity( uniqueID );
-  }
-
-  return true;
-}
-
-bool NetworkGameManager::handleYouAreEntity( int & i, const byte * data, int length, int sender )
-{
-  if ( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read uniqueID from buffer! Not enough data left!\n");
-    return false;
-  }
-
-  int uniqueID;
-  i += Converter::byteArrayToInt( &data[i], &uniqueID );
-
-  doYouAre( uniqueID );
-
-  return true;
-}
-
-/**
- *  handles the network signal NET_REQUEST_PNODE_PATH
- * @param i byte offset in the buffer
- * @param data data array
- * @param length length of the data arary
- * @param sender the sender id
- * @return true if process terminated sucessfully
- */
-bool NetworkGameManager::handleRequestPNodePath(int& i, const byte* data, int length, int sender)
-{
-  if( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read n from buffer! Not enough data left!\n");
-    return false;
-  }
-  PRINTF(0)("HandleRequestPNodePath:  data[i..i+3] = %d %d %d %d\n", data[i], data[i+1], data[i+2], data[i+3]);
-
-  int uniqueID1, uniqueID2;
-  if( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read uniqueID from buffer! Not enough data left!\n");
-    return false;
-  }
-  i += Converter::byteArrayToInt( &data[i], &uniqueID1 );
-
-  if( INTSIZE > length-i )
-  {
-    PRINTF(1)("Cannot read uniqueID from buffer! Not enough data left!\n");
-    return false;
-  }
-  i += Converter::byteArrayToInt( &data[i], &uniqueID2 );
-
-
-  PRINTF(0)("HandleRequestPNodePath: got a request for path from uid %i to uid %i\n", uniqueID1, uniqueID2);
-
-  return true;
-}
-
-bool NetworkGameManager::youAreHandler( MessageId messageId, byte * data, int dataLength, void * someData, int userId )
-{
-  assert( dataLength == INTSIZE );
-  int uniqueId;
-  
-  Converter::byteArrayToInt( data, &uniqueId );
-  
-  SynchronizeableList::const_iterator it = NetworkGameManager::getInstance()->networkStream->getSyncBegin();
-
-  Playable *p = NULL;
-  Synchronizeable *s = NULL;
-
-  for ( ; it !=NetworkGameManager::getInstance()->networkStream->getSyncEnd(); it++ )
-  {
-    if ( (*it)->getUniqueID()==uniqueId )
-    {
-      break;
-    }
-  }
-  
-  if ( it == NetworkGameManager::getInstance()->networkStream->getSyncEnd() )
-    return false;
-  
-  NetworkGameManager::getInstance()->doYouAre( uniqueId );
-  
-  return true;
-}
-
-#if 0
-bool NetworkGameManager::writeToClientBuffer( clientBuffer & cb, byte b )
-{
-  if ( cb.maxLength-cb.length < 1 )
-  {
-    PRINTF(1)("Cannot write to clientBuffer! Not enough space for 1 byte\n");
-    return false;
-  }
-
-  cb.buffer[cb.length++] = b;
-
-  return true;
+  MessageManager::getInstance()->sendMessage( MSGID_DELETESYNCHRONIZEABLE, buf, INTSIZE, RT_ALL_NOT_ME, 0, MP_HIGHBANDWIDTH );
 }
 
 
-bool NetworkGameManager::writeToClientBuffer( clientBuffer & cb, int i )
-{
-  int n = Converter::intToByteArray( i, cb.buffer+cb.length, cb.maxLength-cb.length );
-  cb.length += n;
-
-  if ( n <= 0 )
-  {
-    PRINTF(1)("Cannot write to clientBuffer! Not enough space for 1 int\n");
-    return false;
-  }
-
-  return true;
-}
-#endif
 
 
+
+

trunk/src/lib/network/network_game_manager.h

@@ -47 +47 @@
   public:
     virtual ~NetworkGameManager();
-
+    
     static NetworkGameManager* NetworkGameManager::getInstance()
     { if (!NetworkGameManager::singletonRef) NetworkGameManager::singletonRef = new NetworkGameManager(); return NetworkGameManager::singletonRef; }
 
-#if 0
-    virtual int writeBytes(const byte* data, int length, int sender);
-    virtual int readBytes(byte* data, int maxLength, int * reciever);
-    virtual void writeDebug() const;
-    virtual void readDebug() const;
-#endif
 
-    int createEntity( ClassID classID, int owner = 0 );
-    BaseObject* createEntity(const TiXmlElement* element);
-    void removeEntity( int uniqueID );
-    void sendYouAre( int uniqueID, int userID );
+    bool signalNewPlayer( int userId );
+    bool signalLeftPlayer( int userID );
+    
+    void removeSynchronizeable( int uniqueId );
 
-#if 0
-    void sendEntityList(int userID);
-#endif
-
-    bool signalNewPlayer(int userId);
-    bool signalLeftPlayer(int userID);
-
+    inline void setGameState( int gameState ){ this->gameState = gameState; }
+    inline int getGameState(){ return this->gameState; }
 
   private:
     NetworkGameManager();
     
-    static bool youAreHandler(MessageId messageId, byte * data, int dataLength, void * someData, int userId );
+    static bool delSynchronizeableHandler( MessageId messageId, byte * data, int dataLength, void * someData, int userId );
 
-
-    /* some network signal handlers */
-    bool handleRequestCreate( int& i, const byte* data, int length, int sender );
-    bool handleRequestRemove( int& i, const byte* data, int length, int sender );
-    bool handleCreateEntity( int& i, const byte* data, int length, int sender );
-    bool handleRemoveEntity( int& i, const byte* data, int length, int sender );
-    bool handleCreateEntityList( int& i, const byte* data, int length, int sender );
-    bool handleRemoveEntityList( int& i, const byte* data, int length, int sender );
-    bool handleYouAreEntity( int& i, const byte* data, int length, int sender );
-    bool handleRequestPNodePath(int& i, const byte* data, int length, int sender);
-    bool handleSendPNodePath(int& i, const byte* data, int length, int sender);
-
-
-    /* some network handlers helper functions */
-//    void requestCreateEntity(ClassID classID);
-    int executeCreateEntity(ClassID classID, int uniqueID = 0, int owner = 0);
-    BaseObject* doCreateEntity(ClassID classID, int uniqueID, int owner);
-
-//    void requestRemoveEntity(int uniqueID);
-    void executeRemoveEntity(int uniqueID);
-    void doRemoveEntity(int uniqueID);
-
-    void doYouAre( int uniqueID );
-
-//    void requestPNodePath(const PNode* node1, const PNode* node2);
-    void executeRequestPNodePath(const PNode* node2, const PNode* node2);
-    void doRequestPNodePath(const PNode* node1, const PNode* node2);
-
-    bool canCreateEntity(ClassID classID);
-#if 0
-    void resizeBufferVector(int n);
-
-
-    bool writeToClientBuffer( clientBuffer &cb, byte*data, int length );
-    bool writeToClientBuffer( clientBuffer &cb, byte b );
-    bool writeToClientBuffer( clientBuffer &cb, int i );
-    bool readFromClientBuffer( clientBuffer &cb, byte*data, int length );
-#endif
-
-  private:
-#if 0
-    std::vector<clientBuffer>     outBuffer;
-    //clientBuffer                  allOutBuffer;
-#endif
     static NetworkGameManager*    singletonRef;
+    
+    int                           gameState;
 };
 

trunk/src/lib/network/network_stream.cc

@@ -177 +177 @@
 void NetworkStream::processData()
 {
+  int tick = SDL_GetTicks();
+  
   currentState++;
   
@@ -207 +209 @@
   // order of up/downstream is important!!!!
   // don't change it
-  handleDownstream();
-  handleUpstream();
+  handleDownstream( tick );
+  handleUpstream( tick );
 
 }
@@ -277 +279 @@
       PRINTF(0)("Client is gone: %d (%s)\n", it->second.userId, reason.c_str());
       
-      assert(false);
+      //assert(false);
 
       it->second.socket->disconnectServer();
@@ -391 +393 @@
  * handle upstream network traffic
  */
-void NetworkStream::handleUpstream( )
+void NetworkStream::handleUpstream( int tick )
 {
   int offset;
   int n;
   
-  for ( PeerList::iterator peer = peers.begin(); peer != peers.end(); peer++ )
+  for ( PeerList::reverse_iterator peer = peers.rbegin(); peer != peers.rend(); peer++ )
   {
     offset = INTSIZE; //make already space for length 
@@ -496 +498 @@
       writeToNewDict( buf, offset );
     
-    peer->second.connectionMonitor->processUnzippedOutgoingPacket( buf, offset, currentState );
-    peer->second.connectionMonitor->processZippedOutgoingPacket( compBuf, compLength, currentState );
+    peer->second.connectionMonitor->processUnzippedOutgoingPacket( tick, buf, offset, currentState );
+    peer->second.connectionMonitor->processZippedOutgoingPacket( tick, compBuf, compLength, currentState );
     
     //NETPRINTF(n)("send packet: %d userId = %d\n", offset, peer->second.userId);
@@ -506 +508 @@
  * handle downstream network traffic
  */
-void NetworkStream::handleDownstream( )
+void NetworkStream::handleDownstream( int tick )
 {
   int offset = 0;
@@ -527 +529 @@
     while ( 0 < (compLength = peer->second.socket->readPacket( compBuf, UDP_PACKET_SIZE )) )
     {
-      //TODO tell monitor about zipped packet. because dropped packets dont count to bandwidth
+      peer->second.connectionMonitor->processZippedIncomingPacket( tick, compBuf, compLength );
+      
       //PRINTF(0)("GGGGGOOOOOOOOOOTTTTTTTT: %d\n", compLength);
       packetLength = Zip::getInstance()->unZip( compBuf, compLength, buf, UDP_PACKET_SIZE );
@@ -547 +550 @@
       //NETPRINTF(n)("ackedstate: %d\n", ackedState);
       offset = 4*INTSIZE;
+      
+      peer->second.connectionMonitor->processUnzippedIncomingPacket( tick, buf, offset, state, ackedState );
 
       //NETPRINTF(n)("got packet: %d, %d\n", length, packetLength);
@@ -672 +677 @@
       }
       
-      peer->second.connectionMonitor->processZippedIncomingPacket( compBuf, compLength, state, ackedState );
-      peer->second.connectionMonitor->processUnzippedIncomingPacket( buf, offset, state, ackedState );
-    
       assert( peer->second.lastAckedState <= ackedState );
       peer->second.lastAckedState = ackedState;

trunk/src/lib/network/network_stream.h

@@ -79 +79 @@
     void updateConnectionList();
     void handleHandshakes();
-    void handleUpstream();
-    void handleDownstream(); 
+    void handleUpstream( int tick );
+    void handleDownstream(int tick ); 
     void handleNewClient( int userId );
     void cleanUpOldSyncList();

trunk/src/lib/network/synchronizeable.cc

@@ -21 +21 @@
 #include "netdefs.h"
 #include "network_log.h"
+#include "network_game_manager.h"
 
 #include "state.h"
@@ -36 +37 @@
 {
   this->setClassID(CL_SYNCHRONIZEABLE, "Synchronizeable");
-  this->owner = -1;
+  this->owner = 0;
   this->hostID = SharedNetworkData::getInstance()->getHostID();
   this->setIsServer(this->hostID == 0);
@@ -68 +69 @@
   if ( this->networkStream )
     this->networkStream->disconnectSynchronizeable(*this);
+  
+  if ( this->isServer() && this->beSynchronized() && this->getUniqueID() > 0 )
+    NetworkGameManager::getInstance()->removeSynchronizeable( this->getUniqueID() );
 }
 
@@ -175 +179 @@
             this->isServer() && (*it)->checkPermission( PERMISSION_SERVER ) ||
             this->owner == this->hostID && (*it)->checkPermission( PERMISSION_OWNER ) ||
+            this->isServer() && this->owner != userId && (*it)->checkPermission( PERMISSION_OWNER ) ||
             (*it)->checkPermission( PERMISSION_ALL ) 
                     );
@@ -289 +294 @@
         (*it)->checkPermission( PERMISSION_SERVER ) && networkStream->isUserServer( userId ) ||
         (*it)->checkPermission( PERMISSION_OWNER ) && this->owner == userId ||
+        networkStream->isUserServer( userId ) && this->owner != getHostID() && (*it)->checkPermission( PERMISSION_OWNER ) ||
         (*it)->checkPermission( PERMISSION_ALL ) 
        )
@@ -331 +337 @@
 void Synchronizeable::registerVar( SynchronizeableVar * var )
 {
-  PRINTF(0)("ADDING VAR: %s\n", var->getName().c_str());
+  //PRINTF(0)("ADDING VAR: %s\n", var->getName().c_str());
   syncVarList.push_back( var );
 }
@@ -343 +349 @@
 int Synchronizeable::registerVarId( SynchronizeableVar * var )
 {
-  PRINTF(0)("ADDING VAR: %s\n", var->getName().c_str());
+  //PRINTF(0)("ADDING VAR: %s\n", var->getName().c_str());
   syncVarList.push_back( var );
   var->setWatched( true );

trunk/src/lib/network/synchronizeable.h

@@ -61 +61 @@
     virtual void handleSentState( int userId, int stateId, int fromStateId );
     virtual void handleRecvState( int userId, int stateId, int fromStateId );
-
+    
     void registerVar( SynchronizeableVar * var );
     int registerVarId( SynchronizeableVar * var );