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

Timestamp:

Jul 25, 2006, 10:34:28 AM (18 years ago)

Author:

patrick

Message:

using the new id scheme

File:

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

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

@@ -182 +182 @@
  * @param port: the port number
  */
-int NetworkStream::connectToMasterServer(std::string host, int port)
-{
-  int node = this->peers.size();
+void NetworkStream::connectToMasterServer(std::string host, int port)
+{
+  int node = NET_ID_MASTER_SERVER;
   // this create the new node in the peers map
   this->peers[node].socket = new UdpSocket( host, port );
-  this->peers[node].userId = 0;
+  this->peers[node].userId = NET_ID_MASTER_SERVER;
 
   this->peers[node].nodeType = NET_MASTER_SERVER;
-  this->peers[node].connectionMonitor = new ConnectionMonitor( 0 );
+  this->peers[node].connectionMonitor = new ConnectionMonitor( NET_ID_MASTER_SERVER );
   this->peers[node].ip = this->peers[node].socket->getRemoteAddress();
-
-  return node;
 }
 
@@ -202 +200 @@
  * @param port: the port number
  */
-int NetworkStream::connectToProxyServer(std::string host, int port)
-{
-  int node = this->peers.size();
-  PRINTF(0)("connect to proxy %s, this is node %i\n", host.c_str(), node);
-
-  // this creates the new node in the peers map
-  this->peers[node].socket = new UdpSocket( host, port );
-  this->peers[node].userId = 0;
-
-  this->peers[node].nodeType = NET_PROXY_SERVER_ACTIVE;
-  this->peers[node].connectionMonitor = new ConnectionMonitor( 0 );
-  this->peers[node].ip = this->peers[node].socket->getRemoteAddress();
-
-  return node;
+void NetworkStream::connectToProxyServer(int proxyId,std::string host, int port)
+{
+  PRINTF(0)("connect to proxy %s, this is proxyId %i\n", host.c_str(), proxyId);
+
+  // this creates the new proxyId in the peers map
+  this->peers[proxyId].socket = new UdpSocket( host, port );
+  this->peers[proxyId].userId = proxyId;
+
+  this->peers[proxyId].nodeType = NET_PROXY_SERVER_ACTIVE;
+  this->peers[proxyId].connectionMonitor = new ConnectionMonitor( proxyId );
+  this->peers[proxyId].ip = this->peers[proxyId].socket->getRemoteAddress();
 }
 
@@ -250 +245 @@
 {
   Handshake* hs = new Handshake(this->pInfo->nodeType);
-  hs->setUniqueID( 0 );
+  // fake the unique id
+  hs->setUniqueID( NET_UID_HANDSHAKE );
   assert( peers[userId].handshake == NULL );
   peers[userId].handshake = hs;
@@ -327 +323 @@
   {
     // check if the connection is ok else terminate and remove
-    if ( !peers.empty() && peers[0].socket && ( !peers[0].socket->isOk() || peers[0].connectionMonitor->hasTimedOut() ) )
-    {
-      this->handleDisconnect( 0);
+#warning make this more modular: every proxy/master server connection should be watched for termination
+    if ( !peers.empty() && peers[NET_ID_MASTER_SERVER].socket &&
+          ( !peers[NET_ID_MASTER_SERVER].socket->isOk() ||
+          peers[NET_ID_MASTER_SERVER].connectionMonitor->hasTimedOut() ) )
+    {
+      this->handleDisconnect( NET_ID_MASTER_SERVER);
       PRINTF(1)("lost connection to server\n");
     }
@@ -335 +334 @@
     if( this->bRedirect)
     {
-      this->handleReconnect( 0);
+      this->handleReconnect( NET_ID_MASTER_SERVER);
     }
   }
@@ -625 +624 @@
   // disconnect from the current server and reconnect to proxy server
   this->handleDisconnect( userId);
-  this->connectToProxyServer(proxyIP.ipString(), 9999);
+  this->connectToProxyServer(NET_ID_PROXY_SERVER_01, proxyIP.ipString(), 9999);
   #warning the ports are not yet integrated correctly in the ip class
 
@@ -707 +706 @@
 
       // do not include synchronizeables with uninit id and syncs that don't want to be synchronized
-      if ( !sync.beSynchronized() || sync.getUniqueID() < 0 )
+      if ( !sync.beSynchronized() || sync.getUniqueID() <= NET_UID_UNASSIGNED )
         continue;
 
@@ -769 +768 @@
       Synchronizeable & sync = **it;
 
-      if ( !sync.beSynchronized() || sync.getUniqueID() < 0 )
+      // again exclude all unwanted syncs
+      if ( !sync.beSynchronized() || sync.getUniqueID() <= NET_UID_UNASSIGNED)
         continue;
 
@@ -969 +969 @@
         Synchronizeable & sync = **it;
 
-        if ( !sync.beSynchronized() || sync.getUniqueID() < 0 )
+        if ( !sync.beSynchronized() || sync.getUniqueID() <= NET_UID_UNASSIGNED )
           continue;