source: sample/pingpong/PingPong.h@ 2410

#ifndef __PINGPONG_H_
#define __PINGPONG_H_

#include "ariba/ariba.h"
#include "PingPongMessage.h"

using namespace ariba;

#include "ariba/utility/system/StartupInterface.h"
#include "ariba/utility/system/Timer.h"
using ariba::utility::StartupInterface;
using ariba::utility::Timer;

namespace ariba {
namespace application {
namespace pingpong {

/**
/* The PingPong main class
/* This class implements an example service for demonstration purposes
/* The pingpong class sends and receives messages between two SpoVNet
/* instances
**/
class PingPong :
        public NodeListener,
        public CommunicationListener,
        public StartupInterface,
        public Timer {

        use_logging_h(PingPong);

public:
        PingPong();
        virtual ~PingPong();

protected:
        // communication listener interface
        virtual bool onLinkRequest(const NodeID& remote, Message* msg);
        virtual void onMessage(Message* msg, const NodeID& remote, const LinkID& lnk);

        // node listener interface
        virtual void onJoinCompleted( const SpoVNetID& vid );
        virtual void onJoinFailed( const SpoVNetID& vid );

        // startup wrapper interface
        virtual void startup();
        virtual void shutdown();

        // timer events
        virtual void eventFunction();

private:
        // the ariba module and a node
        AribaModule* ariba;
        Node* node;

        // flag, wheter this node is the initiator of this spovnet
        bool isInitiator;

        // the ping pong service id
        static ServiceID PINGPONG_ID;

        // the current ping id
        unsigned long pingId;

//      // the known remote nodes
//      typedef map<NodeID, LinkID> RemoteNodes;
//      RemoteNodes remoteNodes;
};

//ARIBA_SIMULATION_SERVICE(PingPong);

}}} // namespace ariba, application, pingpong

#endif // __PINGPONG_H_