Changeset 6190 in orxonox.OLD for branches/network/src/lib/network/network_stream.cc

Timestamp:

Dec 20, 2005, 2:51:37 PM (18 years ago)

Author:

rennerc

Message:

synchronizeable: added sender parameter to writeBytes
network_stream: creates now a network_game_manager
network_game_manager: implemented some functions

File:

• branches/network/src/lib/network/network_stream.cc (modified) (10 diffs)

branches/network/src/lib/network/network_stream.cc

@@ -27 +27 @@
 #include "synchronizeable.h"
 #include "network_manager.h"
+#include "network_game_manager.h"
 #include "list.h"
 #include "debug.h"
@@ -77 +78 @@
   this->handshakes.push_back( NULL );
   this->bActive = true;
+  this->networkGameManager = new NetworkGameManager();
+  // setUniqueID( maxCon+2 ) because we need one id for every handshake
+  // and one for handshake to reject client maxCon+1
+  this->networkGameManager->setUniqueID( this->maxConnections+2 );
+  this->connectSynchronizeable( *(this->networkGameManager) );
 
   this->setMaxConnections( 10 );
@@ -88 +94 @@
   this->bActive = false;
   this->serverSocket = NULL;
+  this->networkGameManager = NULL;
   myHostId = 0;
 }
@@ -175 +182 @@
           }
           PRINT(0)("handshake finished\n");
+
+          this->networkGameManager = new NetworkGameManager();
+          this->networkGameManager->setUniqueID( handshakes[i]->getNetworkGameManagerId() );
+          this->connectSynchronizeable( *(this->networkGameManager) );
+
           delete handshakes[i];
           handshakes[i] = NULL;
-          //TODO: replace handshake by entitymanager
         }
         else
@@ -199 +210 @@
   for (SynchronizeableList::iterator it = synchronizeables.begin(); it!=synchronizeables.end(); it++)
   {
-    //TODO: remove items from synchronizeables if they dont exist
     if ( (*it)!=NULL && (*it)->getOwner() == myHostId )
     {
@@ -214 +224 @@
         dataLength = networkProtocol->createHeader((byte*)downBuffer, dataLength, DATA_STREAM_BUFFER_SIZE, static_cast<const Synchronizeable&>(*(*it)));
 
-        //FIXME: this is a hack, find a better way
         Header* header = (Header*)downBuffer;
-        if ( header->synchronizeableID<100 )
+        if ( header->synchronizeableID < this->maxConnections )
           header->synchronizeableID = 0;
 
@@ -284 +293 @@
         {
           if ( *it && (*it)->getUniqueID()==header.synchronizeableID )
-            (*it)->writeBytes(upBuffer+sizeof(header), dataLength);
+            (*it)->writeBytes(upBuffer+sizeof(header), dataLength, i);
         }
 
@@ -306 +315 @@
       freeSocketSlots.pop_back();
       networkSockets[clientId] = tempNetworkSocket;
-      handshakes[clientId] = new Handshake(true, clientId);
+      handshakes[clientId] = new Handshake(true, clientId, this->networkGameManager->getUniqueID());
       handshakes[clientId]->setUniqueID(clientId);
     } else
@@ -312 +321 @@
       clientId = networkSockets.size();
       networkSockets.push_back(tempNetworkSocket);
-      Handshake* tHs = new Handshake(true, clientId);
+      Handshake* tHs = new Handshake(true, clientId, this->networkGameManager->getUniqueID());
       tHs->setUniqueID(clientId);
       handshakes.push_back(tHs);
@@ -374 +383 @@
   }
   this->maxConnections = n;
-}
-
-
+  this->networkGameManager->setUniqueID( n+2 );
+}
+
+