Changeset 7774

Timestamp:

Dec 17, 2010, 11:49:08 AM (13 years ago)

Author:

scheusso

Message:

some comments
enable enet packet compression

Location:

code/branches/network5/src/libraries/network

Files:

• ClientConnection.cc (modified) (2 diffs)
• Connection.cc (modified) (1 diff)
• Connection.h (modified) (1 diff)
• ServerConnection.cc (modified) (3 diffs)

code/branches/network5/src/libraries/network/ClientConnection.cc

@@ -70 +70 @@
     ENetEvent event;
 
+    // create host
     this->host_ = enet_host_create(NULL, NETWORK_CLIENT_MAX_CONNECTIONS, NETWORK_CHANNEL_COUNT, 0, 0);
+    
     if ( this->host_ == NULL )
     {
@@ -77 +79 @@
       return false;
     }
+    
+    // enable compression
+    this->enableCompression();
+    
     assert( this->host_->socket4 != ENET_SOCKET_NULL || this->host_->socket6 != ENET_SOCKET_NULL );
     if (this->host_->socket4 == ENET_SOCKET_NULL)

code/branches/network5/src/libraries/network/Connection.cc

@@ -210 +210 @@
     return p->process();
   }
+  
+  void Connection::enableCompression()
+  {
+    enet_host_compress_with_range_coder( this->host_ );
+  }
+
 
 }

code/branches/network5/src/libraries/network/Connection.h

@@ -95 +95 @@
     void communicationThread();
     virtual void disconnectPeer(ENetPeer *peer);
+    
+    void enableCompression();
 
     void processQueue();

code/branches/network5/src/libraries/network/ServerConnection.cc

@@ -68 +68 @@
   bool ServerConnection::openListener()
   {
+    // create host
     this->host_ = enet_host_create(this->bindAddress_, NETWORK_MAX_CONNECTIONS, NETWORK_CHANNEL_COUNT, 0, 0);
+    
     if ( this->host_ == NULL )
     {
@@ -74 +76 @@
         return false;
     }
+    
+    // enable compression
+    this->enableCompression();
     assert( this->host_->socket4 != ENET_SOCKET_NULL || this->host_->socket6 != ENET_SOCKET_NULL );
     if (this->host_->socket4 == ENET_SOCKET_NULL)
@@ -82 +87 @@
         COUT(3) << "Info: Using IPv4 and IPv6 Sockets." << std::endl;
     
+    // start communication thread
     Connection::startCommunicationThread();