Changeset 7763

Timestamp:

Dec 15, 2010, 2:51:39 PM (13 years ago)

Author:

smerkli

Message:

disconnect implemented, switching to only use the MSC object of wandiscovery.

Location:

code/branches/presentation/src/libraries/network

Files:

• MasterServer.cc (modified) (1 diff)
• MasterServerComm.cc (modified) (6 diffs)
• MasterServerComm.h (modified) (1 diff)
• MasterServerProtocol.h (modified) (1 diff)
• Server.cc (modified) (3 diffs)
• Server.h (modified) (1 diff)
• WANDiscovery.cc (modified) (1 diff)
• WANDiscovery.h (modified) (1 diff)

code/branches/presentation/src/libraries/network/MasterServer.cc

@@ -186 +186 @@
       }
 
+      else if( !strncmp( (char *)event->packet->data
+        + MSPROTO_GAME_SERVER_LEN+1,
+        MSPROTO_SERVERDC, MSPROTO_SERVERDC_LEN ) )
+      {
+        /* create string from peer data */
+        std::string name = std::string( addrconv );
+
+        /* remove the server from the list it belongs to */
+        this->mainlist.delServerByName( name );
+
+        /* tell the user */
+        COUT(2) << "Removed server " << name << " from list.\n";
+      }
+
       /* TODO add hook for disconnect here */
     }

code/branches/presentation/src/libraries/network/MasterServerComm.cc

@@ -41 +41 @@
   {
     /* initialize Enet */
-    if (enet_initialize () != 0)
+    if( enet_initialize () != 0 )
     { COUT(1) << "An error occurred while initializing ENet.\n";
       return 1;
@@ -59 +59 @@
     /* see if it worked */
     if (this->client == NULL)
-    { COUT(1) << "An error occurred while trying to create an ENet client host.\n";
+    { COUT(1) << "An error occurred while trying to create an " 
+        << "ENet client host.\n";
       return 1;
     }
@@ -70 +71 @@
     /* destroy the enet facilities */
     enet_host_destroy(this->client);
-
-    /* install atexit handler for enet */
-    enet_deinitialize();
   }
 
@@ -84 +82 @@
     this->peer = enet_host_connect(this->client, &this->address, 2, 0);    
 
-    if (this->peer == NULL )
-    { COUT(2) << "ERROR: No available peers for initiating an ENet connection.\n";
+    if( this->peer == NULL )
+    { COUT(2) << "ERROR: No available peers for initiating an ENet"
+        << " connection.\n";
       return -1;
     }
@@ -96 +95 @@
     {
       enet_peer_reset (this->peer);
-      fprintf( stdout, "Connection to %s failed.", address );
       COUT(2) << "ERROR: connection to " << address << " failed.\n";
       return -1;
@@ -240 +238 @@
     /* One could just use enet_host_service() instead. */
     enet_host_flush( this->client );
-    if( packet ) free( packet );
+    enet_packet_destroy( packet );
 
     /* all done. */

code/branches/presentation/src/libraries/network/MasterServerComm.h

@@ -66 +66 @@
        * Disconnect from master server.
        */
-      int disconnect();
+      int disconnect( void );
 
       /** \param data The data to be sent. 

code/branches/presentation/src/libraries/network/MasterServerProtocol.h

@@ -69 +69 @@
 #define MSPROTO_PING_GAMESERVER_LEN 4 
 
+/* server disconnect */
+#define MSPROTO_SERVERDC "DC"
+#define MSPROTO_SERVERDC_LEN 2
+
 /* ping reply */
 #define MSPROTO_ACK "ACK"

code/branches/presentation/src/libraries/network/Server.cc

@@ -104 +104 @@
   void Server::helper_ConnectToMasterserver()
   {
-    /* initialize it and see if it worked */
-    if( msc.initialize() )
-    { COUT(1) << "Error: could not initialize master server communications!\n";
-      return;
-    }
-
-    /* connect and see if it worked */
-    if( msc.connect( WANDiscovery::getInstance().getMSAddress().c_str(), 
-      ORX_MSERVER_PORT ) )
-    { COUT(1) << "Error: could not connect to master server!\n";
-      return;
-    }
+    //[> initialize it and see if it worked <]
+    //if( msc.initialize() )
+    //{ COUT(1) << "Error: could not initialize master server communications!\n";
+      //return;
+    //}
+
+    //[> connect and see if it worked <]
+    //if( msc.connect( WANDiscovery::getInstance().getMSAddress().c_str(), 
+      //ORX_MSERVER_PORT ) )
+    //{ COUT(1) << "Error: could not connect to master server!\n";
+      //return;
+    //}
 
     /* now send the master server some note we're here */
-    msc.sendRequest( MSPROTO_GAME_SERVER " " MSPROTO_REGISTER_SERVER );
+    //msc.sendRequest( MSPROTO_GAME_SERVER " " MSPROTO_REGISTER_SERVER );
+    WANDiscovery::getInstance().msc.sendRequest( MSPROTO_GAME_SERVER " " 
+      MSPROTO_REGISTER_SERVER );
   }
 
@@ -152 +154 @@
     this->disconnectClients();
     this->closeListener();
+
+    /* tell master server we're closing */
     COUT(2) << "disconnecting." << endl;
-    this->msc.disconnect();
+    WANDiscovery::getInstance().msc.sendRequest( MSPROTO_GAME_SERVER " " 
+      MSPROTO_SERVERDC );
     COUT(2) << "disconnecting done" << endl;
+
     LANDiscoverable::setActivity(false);
     return;
@@ -196 +202 @@
      * has to be done or changed.
      */
-    this->msc.pollForReply( rephandler, 10 ); 
+    //WANDiscovery::getInstance().msc.pollForReply( rhandler, 10 );
   }
 

code/branches/presentation/src/libraries/network/Server.h

@@ -90 +90 @@
 
     float timeSinceLastUpdate_;
-    MasterServerComm msc;
+    //MasterServerComm msc;
   };
 

code/branches/presentation/src/libraries/network/WANDiscovery.cc

@@ -133 +133 @@
     {
       /* poll for reply and act according to what was received */
-      switch( this->msc.pollForReply( rhandler, 1000 ) )
+      switch( this->msc.pollForReply( rhandler, 500 ) )
       { case 0: /* no event occured, decrease timeout */
           --i; break;

code/branches/presentation/src/libraries/network/WANDiscovery.h

@@ -95 +95 @@
       /** Function used for the configuration file parameter update */
       void setConfigValues();
+
+      /** Master server communications object */
+      MasterServerComm msc;
       
     private:
       /** Singleton pointer */
       static WANDiscovery* singletonPtr_s;
-
-      /** Master server communications object */
-      MasterServerComm msc;
 
       /** master server address */