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

Timestamp:

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

Author:

rennerc

Message:

NetworkStream should now accept net connections

Location:

branches/network/src/lib/network

Files:

• network_manager.h (modified) (1 diff)
• network_socket.h (modified) (1 diff)
• network_stream.cc (modified) (3 diffs)
• network_stream.h (modified) (1 diff)
• server_socket.cc (modified) (2 diffs)
• server_socket.h (modified) (1 diff)

branches/network/src/lib/network/network_manager.h

@@ -47 +47 @@
     inline int getHostID() { return this->hostID; };
 
-  private:
+
     void connectSynchronizeable(Synchronizeable& sync);
     void synchronize();
 
+  private:
     NetworkManager();
 

branches/network/src/lib/network/network_socket.h

@@ -87 +87 @@
   int readPacket(byte * data, int maxLength);
 
+  inline bool isOk() { return tcpSocket!=NULL; }
+
 };
 

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);
+      }
+    }
+  }
+
+}

branches/network/src/lib/network/network_stream.h

@@ -51 +51 @@
     Header                 packetHeader;
     bool                   bActive;
+    std::list<int>         freeSocketSlots;
+
+    void updateConnectionList();
 };
 #endif /* _NETWORK_STREAM */

branches/network/src/lib/network/server_socket.cc

@@ -110 +110 @@
 
 
-NetworkSocket ServerSocket::getNewSocket( )
+NetworkSocket* ServerSocket::getNewSocket( )
 {
   if ( !listenSocket )
@@ -127 +127 @@
   else
   {
-    return NetworkSocket(sock);
+    return new NetworkSocket(sock);
   }
 }

branches/network/src/lib/network/server_socket.h

@@ -39 +39 @@
     ~ServerSocket();
     bool listen( unsigned int port );
-    NetworkSocket getNewSocket( void );
+    NetworkSocket* getNewSocket( void );
     void close();
+    inline bool isOk(){ return listenSocket!=NULL; }
 };