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

Timestamp:

May 10, 2006, 4:48:27 PM (18 years ago)

Author:

rennerc

Message:

fixed some bugs

File:

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

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

@@ -64 +64 @@
   this->networkProtocol = new NetworkProtocol();
   this->connectionMonitor = new ConnectionMonitor();
-  this->maxConnections = MAX_CONNECTIONS;
 }
 
@@ -131 +130 @@
   // 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->networkGameManager->setUniqueID( MAX_CONNECTIONS + 2 );
 
 }
@@ -142 +141 @@
   assert( peers[0].handshake == NULL );
   peers[0].handshake = hs;
+//   peers[0].handshake->setSynchronized( true );
+  this->connectSynchronizeable(*hs);
   //this->connectSynchronizeable(*hs);
-  PRINTF(0)("NetworkStream: %s\n", hs->getName());
+  PRINTF(0)("NetworkStream: Handshake created: %s\n", hs->getName());
 }
 
@@ -194 +195 @@
   }
 
+  handleHandshakes();
+  handleUpstream();
+  handleDownstream();
 
 
@@ -354 +358 @@
     } else
     {
-      clientId = 0;
+      clientId = 1;
       
       for ( PeerList::iterator it = peers.begin(); it != peers.end(); it++ )
@@ -366 +370 @@
     }
 
-    if ( clientId > this->maxConnections )
+    if ( clientId > MAX_CONNECTIONS )
     {
       peers[clientId].handshake->doReject( "too many connections" );
@@ -419 +423 @@
                (*it)->getUniqueID(), (*it)->beSynchronized());
   }
-  PRINT(0)(" Maximal Connections: %i\n", this->maxConnections);
+  PRINT(0)(" Maximal Connections: %i\n", MAX_CONNECTIONS );
 
 }
@@ -486 +490 @@
     offset = INTSIZE; //make already space for length 
     
-    if ( peer->second.socket )
+    if ( !peer->second.socket )
       continue;
     
@@ -504 +508 @@
     {
       Synchronizeable & sync = **it;
+
+      if ( !sync.beSynchronized() || sync.getUniqueID() < 0 )
+        continue;
+
+      //if handshake not finished only sync handshake
+      if ( peer->second.handshake && sync.getLeafClassID() != CL_HANDSHAKE )
+        continue;
+
+      PRINTF(0)("syncing: id:%d name:%s\n", sync.getUniqueID(), sync.getClassName());
       
       assert( offset + INTSIZE <= UDP_PACKET_SIZE );
       
-      n = Converter::intToByteArray( sync.getUniqueID(), buf + offset, UDP_PACKET_SIZE - offset );
+      //server fakes uniqueid=0 for handshake
+      if ( this->isServer() && sync.getUniqueID() < MAX_CONNECTIONS - 1 )
+        n = Converter::intToByteArray( 0, buf + offset, UDP_PACKET_SIZE - offset );
+      else
+        n = Converter::intToByteArray( sync.getUniqueID(), buf + offset, UDP_PACKET_SIZE - offset );
       assert( n == INTSIZE );
       offset += n;
@@ -517 +534 @@
     
     assert( peer->second.socket->writePacket( buf, offset ) );
+    PRINTF(0)("send packet: %d\n", offset);
   }
 }
@@ -537 +555 @@
   for ( PeerList::iterator peer = peers.begin(); peer != peers.end(); peer++ )
   {
+    if ( !peer->second.socket )
+      continue;
+
     packetLength = peer->second.socket->readPacket( buf, UDP_PACKET_SIZE );
+
+    if ( packetLength < 4*INTSIZE )
+    {
+      if ( packetLength != 0 )
+        PRINTF(1)("got too small packet: %d\n", packetLength);
+      continue;
+    }
     
     assert( Converter::byteArrayToInt( buf, &length ) == INTSIZE );
@@ -543 +571 @@
     assert( Converter::byteArrayToInt( buf + 2*INTSIZE, &fromState ) == INTSIZE );
     assert( Converter::byteArrayToInt( buf + 3*INTSIZE, &ackedState ) == INTSIZE );
+
+    PRINTF(0)("got packet: %d, %d\n", length, packetLength);
     
     //if this is an old state drop it
@@ -565 +595 @@
       
       for ( SynchronizeableList::iterator it = synchronizeables.begin(); it != synchronizeables.end(); it++ )
-      {
-        if ( (*it)->getUniqueID() == uniqueId )
+      { 
+        //                                        client thinks his handshake has id 0!!!!!
+        if ( (*it)->getUniqueID() == uniqueId || ( uniqueId == 0 && (*it)->getUniqueID() == peer->second.userId ) )
         {
           sync = *it;