Changes between Version 26 and Version 27 of Documentation/Tutorial/PingPong

Timestamp:

Apr 28, 2009, 3:53:04 PM (15 years ago)

Author:

huebsch

Comment:

--

Documentation/Tutorial/PingPong

@@ -46 +46 @@
 }}}
 The ''main.cpp'' serves us as an entry point to the application. In the first lines we include class definitions we need here (e.g. strings because we want to handle some). Also, we include the !StartupWrapper class that comes with ''Ariba''. It provides some handy helpers for initialization. Finally, we need to include the ''!PingPong.h'', because this is the actual thing we want to execute.
-Then, we declare the used namespaces (lines 05-07) to be able to use the functionalities. Now we get to the main method, being our starting point. After determining the location of our config file, we initialize the system by passing the config file's location to the !StartupWrapper and telling the same to start the architecture up (lines 11-15). Now we are ready to start the ping-pong service, which we first create (line 18). Then we declare the role of the node (initiator or joiner), which is written down in the config file as a bool value. Finally, we start the service up by calling the specific method in the !StartupWrapper. Now the service will run until we press the enter button.
+Then, we declare the used namespaces (lines 05-07) to be able to use the functionalities. Now we get to the main method, being our starting point. After determining the location of our config file, we initialize the system by passing the config file's location to the !StartupWrapper and telling the same to start the architecture up (lines 15-16). Now we are ready to start the ping-pong service, which we first have to create (line 19). Finally, we start the service up by calling the specific method in the !StartupWrapper. Now the service will run until we press the enter button.
 
 
@@ -53 +53 @@
 {{{
 01 #include "PingPong.h"
-02
-03 namespace ariba {
-04 namespace application {
-05 namespace pingpong {
+02 #include "ariba/utility/configuration/Configuration.h"
+03
+04 using ariba::utility::Configuration;
+05 using namespace ariba;
 06
-07 use_logging_cpp(PingPong);
-08 ServiceID PingPong::PINGPONG_ID = ServiceID(111);
-09
-10 PingPong::PingPong() : pingid( 0 ) {
-11 }
-12 
-13 PingPong::~PingPong(){
-14 }
-15
-16 void PingPong::setMode(bool startingNode){
-17      startping = startingNode;
-18 }
-19
-20 void PingPong::startup(UnderlayAbstraction* _abstraction){
-21      abstraction = _abstraction;
-22
-23      logging_info( "starting up PingPong service ... " );
-24
-25      SpoVNetID spovnetid (Identifier(5000));
-26
-27      NodeID nodeid = (Configuration::instance().exists("BASE_nodeid") ?
-28                      NodeID(Identifier(Configuration::instance().read<unsigned long>("BASE_nodeid"))) :
-29                      NodeID::UNSPECIFIED);
+07 namespace ariba {
+08 namespace application {
+09 namespace pingpong {
+10
+11 // logging
+12 use_logging_cpp( PingPong );
+13
+14 // the service that the pingpong wants to use
+15 ServiceID PingPong::PINGPONG_SERVICEID = ServiceID( 111 );
+16
+17 // construction
+18 PingPong::PingPong() : pingId( 0 ) {
+19      Timer::setInterval( 5000 );
+20 }
+21
+22 // destruction
+23 PingPong::~PingPong() {
+24 }
+25
+26 // implementation of the startup interface
+27 void PingPong::startup() {
+28
+29      logging_info( "starting up PingPong service ... " );
 30
-31      IPv4Locator* locallocator = (Configuration::instance().exists("BASE_localLocator") ?
-32                                      &(IPv4Locator::fromString(Configuration::instance().read<string>("BASE_localLocator"))) :
-33                                      NULL);
+31      // create ariba module
+32      logging_debug( "creating ariba underlay module ... " );
+33      ariba = new AribaModule();
 34
-35      uint16_t localport = Configuration::instance().exists("BASE_port") ?
-36                              Configuration::instance().read<uint16_t>("BASE_port") :
-37                              ARIBA_DEFAULT_PORT;
-38
-39      if( !startping )
-40              context = abstraction->createSpoVNet( spovnetid, nodeid, locallocator, localport );
-41      else
-42              context = abstraction->joinSpoVNet  ( spovnetid, nodeid, locallocator, localport );
+35      // get the configuration object
+36      Configuration& config = Configuration::instance();
+37
+38      // generate spovnet name
+39      Name spovnetName("pingpong");
+40
+41      // get initiator flag
+42      this->isInitiator = Configuration::instance().read<bool>("node.initiator");
 43
-44      overlay = &context->getOverlay();
-45      overlay->bind( this, PingPong::PINGPONG_ID );
-46
-47      logging_info( "PingPong started up" );
-48
-49      
-50
-51 }
+44      // get node name
+45      Name nodeName = Name::UNSPECIFIED;
+46      if (config.exists("node.name")) nodeName = config.read<string> ("node.name");
+47
+48      // configure ariba module
+49      if (config.exists("ariba.ip.addr")) ariba->setProperty("ip.addr",
+50                      config.read<string>("ariba.ip.addr"));
+51      if (config.exists("ariba.tcp.port")) ariba->setProperty("tcp.port",
+52                      config.read<string>("ariba.tcp.port"));
+53      if (config.exists("ariba.udp.port")) ariba->setProperty("udp.port",
+54                      config.read<string>("ariba.udp.port"));
+55      if (config.exists("ariba.bootstrap.hints")) ariba->setProperty("bootstrap.hints",
+56                      config.read<string>("ariba.bootstrap.hints"));
+57
+58      // start ariba module
+59      ariba->start();
+60
+61      // create node and join
+62      node = new Node( *ariba, nodeName );
+63
+64      // bind communication and node listener
+65      node->bind( this );                              /*NodeListener*/
+66      node->bind( this, PingPong::PINGPONG_SERVICEID); /*CommunicationListener*/
+67
+68      // start node module
+69      node->start();
+70
+71      // initiate or join the spovnet
+72      if (!isInitiator) node->join(spovnetName);
+73      else node->initiate(spovnetName);
+74
+75      // ping pong started up...
+76      logging_info( "pingpong starting up with"
+77                      << " [spovnetid " << node->getSpoVNetId().toString() << "]"
+78                      << " and [nodeid " << node->getNodeId().toString() << "]" );
+79 }
 }}}