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

Timestamp:

Dec 10, 2005, 6:48:01 PM (18 years ago)

Author:

rennerc

Message:

NetworkStream should now accept net connections

File:

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

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

@@ -66 +66 @@
   this->networkProtocol = new NetworkProtocol();
   this->connectionMonitor = new ConnectionMonitor();
+  this->networkSockets.push_back( NULL );
+  this->bActive = true;
 }
 
@@ -111 +113 @@
 void NetworkStream::processData()
 {
+  printf("processData()");
+  if ( this->type == NET_SERVER )
+    this->updateConnectionList();
+
 #if 0
   int dataLength = 0;
@@ -178 +184 @@
 #endif
 }
+
+void NetworkStream::updateConnectionList( )
+{
+  //check for new connections
+  NetworkSocket* tempNetworkSocket = serverSocket->getNewSocket();
+
+  if ( tempNetworkSocket )
+  {
+    int clientId;
+    if ( freeSocketSlots.size() >0 )
+    {
+      clientId = freeSocketSlots.back();
+      freeSocketSlots.pop_back();
+      networkSockets[clientId] = tempNetworkSocket;
+    } else
+    {
+      networkSockets.push_back(tempNetworkSocket);
+      clientId = networkSockets.size();
+    }
+
+    PRINTF(0)("New Client: %s", clientId);
+    //TODO: start handshake
+    //new Handshake(true, clientId);
+  }
+
+
+  //check if connections are ok else remove them
+  for ( int i = 1; i<networkSockets.size(); i++)
+  {
+    if ( networkSockets[i] && !networkSockets[i]->isOk() )
+    {
+      //TODO: tell EntityManager that this player left the game
+
+      delete networkSockets[i];
+      networkSockets[i] = NULL;
+
+      if ( i == networkSockets.size()-1 )
+      {
+        networkSockets.pop_back();
+      }
+      else
+      {
+        freeSocketSlots.push_back(i);
+      }
+    }
+  }
+
+}