Changeset 6115 in orxonox.OLD for branches/network

Timestamp:

Dec 14, 2005, 10:50:33 PM (19 years ago)

Author:

rennerc

Message:

handshake now sends NetworkGameManagerId

Location:

branches/network/src/lib/network

Files:

• handshake.cc (modified) (5 diffs)
• handshake.h (modified) (2 diffs)
• network_socket.cc (modified) (5 diffs)
• network_socket.h (modified) (1 diff)

branches/network/src/lib/network/handshake.cc

@@ -22 +22 @@
 #include "handshake.h"
 
-Handshake::Handshake( bool server, int clientId )
+Handshake::Handshake( bool server, int clientId, int entityManagerId )
 {
   /* set the class id for the base object */
   this->setClassID(CL_HANDSHAKE, "Handshake");
 
+  if ( clientId > 255 )
+  {
+    PRINTF(1)("clientId is too big for type byte (%d)! connection to client %d will not work!", clientId, clientId);
+  }
+
+  if ( entityManagerId > 255 )
+  {
+    PRINTF(1)("entityManagerId is too big for type byte (%d)! connection to client %d will not work!", entityManagerId, clientId);
+  }
+
   this->setIsServer(server);
   this->clientId = clientId;
+  this->entityManagerId = entityManagerId;
   this->state = 0;
   this->isOk = false;
@@ -88 +99 @@
   if ( !isServer() && hasState( HS_RECVD_VER ) && !hasState( HS_RECVD_HID ) )
   {
-    if ( length != 1 )
+    if ( length != 2 )
     {
       PRINTF(0)("hostID packet has wrong size %d instead of %d\n", length, 1);
@@ -99 +110 @@
     this->isOk = true;
     this->newHostId = data[0];
+    this->newEntityManagerId = data[1];
 
     if ( newHostId == 0 )
@@ -156 +168 @@
   if ( isServer() && hasState( HS_RECVD_VER) && hasState( HS_SENT_VER ) && !hasState( HS_SENT_HID ) )
   {
-    if ( maxLength < 4 )
+    if ( maxLength < 2 )
     {
       PRINTF(0)("buffer too small for ID");
@@ -177 +189 @@
       //memcpy(data, &clientId, 4);
       data[0] = (byte)clientId;
+      data[1] = (byte)entityManagerId;
     }
     *reciever = clientId;
-    return 1;
+    return 2;
   }
 

branches/network/src/lib/network/handshake.h

@@ -34 +34 @@
 {
   public:
-    Handshake(bool server, int clientId = 0);
+    Handshake(bool server, int clientId = 0, int entityManagerId = 0);
     inline bool       completed(){ return hasState( HS_COMPLETED ); }
     inline bool       ok(){ return isOk; }
@@ -49 +49 @@
     int               state;
     int               clientId;
+    int               entityManagerId;
     int               newHostId;
+    int               newEntityManagerId;
     bool              isOk;
 

branches/network/src/lib/network/network_socket.cc

@@ -51 +51 @@
   this->tcpSocket = sock;
 
-  SDL_CreateThread(thread_read, (void*)this);
-  SDL_CreateThread(thread_write, (void*)this);
+  readThread = SDL_CreateThread(thread_read, (void*)this);
+  writeThread = SDL_CreateThread(thread_write, (void*)this);
 }
 
@@ -63 +63 @@
   incomingBufferLength = 0;
   outgoingBufferLength = 0;
+
+  readThread = NULL;
+  writeThread = NULL;
 
 
@@ -129 +132 @@
   }
 
-  SDL_CreateThread(thread_read, (void*)this);
-  SDL_CreateThread(thread_write, (void*)this);
+  readThread = SDL_CreateThread(thread_read, (void*)this);
+  writeThread = SDL_CreateThread(thread_write, (void*)this);
 }
 
@@ -310 +313 @@
   if ( !self->thread_write_running )
   {
+    //delete self;
     SDL_mutexV(self->threadTerminationMutex);
   }
@@ -378 +382 @@
   if ( !self->thread_read_running )
   {
+    //delete self;
     SDL_mutexV(self->threadTerminationMutex);
   }

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

@@ -67 +67 @@
   bool thread_read_running;
   bool thread_write_running;
+
+  SDL_Thread*            readThread;
+  SDL_Thread*            writeThread;
+
 #ifdef _USE_OUTGOING_BUFFER
   static int thread_write(void * data);