Changeset 2473 for sample/pingpong/PingPong.cpp

Timestamp:

Feb 23, 2009, 2:21:49 PM (16 years ago)

Author:

Christoph Mayer

Message:

-einige fixes im ablauf des neuen interface
-einige fehlende funktionalität implementiert

File:

• sample/pingpong/PingPong.cpp (modified) (6 diffs)

sample/pingpong/PingPong.cpp

@@ -1 @@
-
 #include "PingPong.h"
 #include "ariba/utility/configuration/Configuration.h"
@@ -11 +10 @@
 
 // logging
-use_logging_cpp( PingPong);
+use_logging_cpp( PingPong );
 
 // the service id of the ping pong service
-ServiceID PingPong::PINGPONG_ID = ServiceID(111);
+ServiceID PingPong::PINGPONG_ID = ServiceID( 111 );
 
 // construction
@@ -27 +26 @@
 void PingPong::startup() {
 
+        logging_info( "starting up PingPong service ... " );
+
         // create ariba module
-        logging_info("Creating ariba underlay module ... ");
+        logging_debug( "creating ariba underlay module ... " );
         ariba = new AribaModule();
 
-        logging_info("Starting up PingPong service ... ");
-
-        // --- get config ---
+        // get the configuration object
         Configuration& config = Configuration::instance();
 
@@ -66 +65 @@
         node->start();
 
-        if (!isInitiator) {
-                node->join(spovnetName);
-        } else {
-                node->initiate(spovnetName);
-        }
+        // initiate or join the spovnet
+        if (!isInitiator) node->join(spovnetName);
+        else node->initiate(spovnetName);
 
         // bind communication and node listener
         node->bind(this);
         node->bind(this, PingPong::PINGPONG_ID);
-
+        
         // ping pong started up...
-        logging_info("PingPong started up");
+        logging_info( "pingpong started up ");
 }
 
 // implementation of the startup interface
 void PingPong::shutdown() {
-        logging_info("PingPong service starting shutdown sequence ...");
+
+        logging_info( "pingpong service starting shutdown sequence ..." );
 
         // stop timer
         Timer::stop();
-
-        // leave spovnet
-        node->leave();
 
         // unbind listeners
@@ -94 +89 @@
         node->unbind( this, PingPong::PINGPONG_ID );
 
+        // leave spovnet
+        node->leave();
+
+        // stop the ariba module
         ariba->stop();
+
+        // delete node and ariba module
         delete node;
         delete ariba;
 
-        logging_info("PingPong service shut down!");
+        // now we are completely shut down
+        logging_info( "pingpong service shut down" );
 }
 
 // node listener interface
 void PingPong::onJoinCompleted( const SpoVNetID& vid ) {
-        logging_info("PingPong node join completed, spovnetid=" << vid.toString() );
+        logging_info( "pingpong node join completed, spovnetid=" << vid.toString() );
+
+        // start the timer to ping every second
+        Timer::setInterval( 1000 );
+        Timer::start();
 }
 
 void PingPong::onJoinFailed( const SpoVNetID& vid ) {
-        logging_info("PingPong node join failed, spovnetid=" << vid.toString() );
+        logging_error(" pingpong node join failed, spovnetid=" << vid.toString() );
 }
 
@@ -115 +121 @@
 }
 
-void PingPong::onMessage(Message* msg, const NodeID& remote, const LinkID& lnk =
-                LinkID::UNSPECIFIED) {
-        PingPongMessage* incoming = msg->decapsulate<PingPongMessage> ();
+void PingPong::onMessage(Message* msg, const NodeID& remote, 
+                const LinkID& lnk = LinkID::UNSPECIFIED) {
 
-        logging_info("received ping message on link " << lnk.toString()
-                        << " from node with id " << (int) incoming->getid());
+        PingPongMessage* pingmsg = msg->decapsulate<PingPongMessage> ();
+
+        logging_info( "received ping message on link " << lnk.toString()
+                        << " from node " << remote.toString()
+                        << ": " << pingmsg->toString() );
 }
 
 // timer event
 void PingPong::eventFunction() {
+        
+        // we ping all nodes that are known in the overlay structure
+        // this can be all nodes (OneHop) overlay or just some neighbors
+        // in case of a Chord or Kademlia structure
+        
+        logging_info( "pinging overlay neighbors with ping id " << ++pingId );
+
+        PingPongMessage pingmsg( pingId );
+        node->sendBroadcastMessage( pingmsg, PingPong::PINGPONG_ID );
+
 }