source: sample/pingpong/PingPong.cpp@ 5289

#include "PingPong.h"
#include "ariba/utility/configuration/Configuration.h"

using ariba::utility::Configuration;
using namespace ariba;

namespace ariba {
namespace application {
namespace pingpong {

// logging
use_logging_cpp( PingPong );

// the service that the pingpong wants to use
ServiceID PingPong::PINGPONG_SERVICEID = ServiceID( 111 );

// construction
PingPong::PingPong() : pingId( 0 ) {
        Timer::setInterval( 1000 );
}

// destruction
PingPong::~PingPong() {
}

// implementation of the startup interface
void PingPong::startup() {

        logging_info( "starting up PingPong service ... " );

        // create ariba module
        logging_debug( "creating ariba underlay module ... " );
        ariba = new AribaModule();

        // get the configuration object
        Configuration& config = Configuration::instance();

        // generate spovnet name
        Name spovnetName("pingpong");

        // get initiator flag
        this->isInitiator = Configuration::instance().read<bool>("node.initiator");

        this->name = string("<ping>");

        // get node name
        Name nodeName = Name::UNSPECIFIED;
        if (config.exists("node.name")) nodeName = config.read<string> ("node.name");

        // configure ariba module
        if (config.exists("ariba.endpoints"))
                ariba->setProperty("endpoints", config.read<string>("ariba.endpoints"));
        if (config.exists("ariba.bootstrap.hints"))
                ariba->setProperty("bootstrap.hints", config.read<string>("ariba.bootstrap.hints"));
        if (config.exists("pingpong.name"))
                name = config.read<string>("pingpong.name");

        // start ariba module
        ariba->start();

        // create node and join
        node = new Node( *ariba, nodeName );

        // bind communication and node listener
        node->bind( this );                              /*NodeListener*/
        node->bind( this, PingPong::PINGPONG_SERVICEID); /*CommunicationListener*/

        // start node module
        node->start();

        // when initiating, you can define the overlay type, default is Chord [CHORD_OVERLAY]
        SpoVNetProperties params;
        //params.setBaseOverlayType( SpoVNetProperties::ONE_HOP_OVERLAY ); // alternative: OneHop

        // initiate or join the spovnet
        if (!isInitiator) node->join(spovnetName);
        else node->initiate(spovnetName, params);

        // ping pong started up...
        logging_info( "pingpong starting up with"
                        << " [spovnetid " << node->getSpoVNetId().toString() << "]"
                        << " and [nodeid " << node->getNodeId().toString() << "]" );
}

// implementation of the startup interface
void PingPong::shutdown() {

        logging_info( "pingpong service starting shutdown sequence ..." );

        // stop timer
        Timer::stop();

        // leave spovnet
        node->leave();

        // unbind communication and node listener
        node->unbind( this );                               /*NodeListener*/
        node->unbind( this, PingPong::PINGPONG_SERVICEID ); /*CommunicationListener*/

        // stop the ariba module
        ariba->stop();

        // delete node and ariba module
        delete node;
        delete ariba;

        // now we are completely shut down
        logging_info( "pingpong service shut down" );
}

// 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

        // in this sample we use auto-links: we just send out our message
        // to the node and the link is established automatically. for more
        // control we would use the node->establishLink function to create
        // a link and start using the link in the CommunicationListener::onLinkUp
        // function that is implemented further down in PingPong::onLinkUp

//      logging_info( "pinging overlay neighbors with ping id " << ++pingId );

        PingPongMessage pingmsg( pingId, name );

        //-----------------------------------------------------------------------
        // Option 1: get all neighboring nodes and send the message to each
        //-----------------------------------------------------------------------
        counter++;
        if (counter<0 || counter>4) {
                counter = 0;
                string s;
                for (int i=0; i<names.size();i++) {
                        if (i!=0) s+= ", ";
                        s = s+names[i];
                }
                logging_info("----> I am " << name << " and I know " << s);
                names.clear();
        }
        vector<NodeID> nodes = node->getNeighborNodes();
        BOOST_FOREACH( NodeID nid, nodes ){
                node->sendMessage( pingmsg, nid, PingPong::PINGPONG_SERVICEID );
        }

        //-----------------------------------------------------------------------
        // Option 2: send a "broadcast message" that actually does the same thing
        //           internally, gets all neighboring nodes and sends the message
        //-----------------------------------------------------------------------
        // node->sendBroadcastMessage( pingmsg, PingPong::PINGPONG_SERVICEID );
}

void PingPong::onJoinCompleted( const SpoVNetID& vid ) {
        logging_info( "pingpong node join completed, spovnetid=" << vid.toString() );

        // start the timer to ping every second
        Timer::start();
}

void PingPong::onJoinFailed( const SpoVNetID& vid ) {
        logging_error("pingpong node join failed, spovnetid=" << vid.toString() );
}

void PingPong::onLeaveCompleted( const SpoVNetID& vid ){
        logging_info("pingpong node leave completed, spovnetid=" << vid.toString() );
}

void PingPong::onLeaveFailed( const SpoVNetID& vid ){
        logging_error("pingpong node leave failed, spovnetid=" << vid.toString() );
}

void PingPong::onMessage(const DataMessage& msg, const NodeID& remote, const LinkID& lnk) {
        PingPongMessage* pingmsg = msg.getMessage()->convert<PingPongMessage> ();
        bool found=false;
        for (int i=0;i<names.size(); i++) if (names[i]==pingmsg->getName()) found=true;
        if (!found) names.push_back(pingmsg->getName());
//      logging_info( "received ping message on link " << lnk.toString()
//                      << " from node " << remote.toString()
//                      << ": " << pingmsg->info() );
}

void PingPong::onLinkUp(const LinkID& lnk, const NodeID& remote){
        logging_info( "received link-up event for link " << lnk.toString()
                        << " and node " << remote.toString() );
}

void PingPong::onLinkDown(const LinkID& lnk, const NodeID& remote){
        logging_info( "received link-down event for link " << lnk.toString()
                        << " and node " << remote.toString() );
}

void PingPong::onLinkChanged(const LinkID& lnk, const NodeID& remote){
        logging_info( "link-changed event for link " << lnk.toString()
                        << " and node " << remote.toString() );
}

bool PingPong::onLinkRequest(const NodeID& remote, const DataMessage& msg) {
        logging_info( "node " << remote.toString() << " wants to build up a link with us ... allowing" );
        return true;
}

void PingPong::onLinkFail(const LinkID& lnk, const NodeID& remote){
        logging_info( "received link-failed event for link " << lnk.toString()
                        << " and node " << remote.toString() );
}

}}} // namespace ariba, application, pingpong