source: sample/pingpong/PingPong.h@ 3038

#ifndef __PINGPONG_H_

#define __PINGPONG_H_



#include "ariba/ariba.h"

#include "PingPongMessage.h"

#include "ariba/utility/system/StartupInterface.h"

#include "ariba/utility/system/Timer.h"



using namespace ariba;

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, const DataMessage& msg);

        virtual void onMessage(const DataMessage& msg, const NodeID& remote, const LinkID& lnk= LinkID::UNSPECIFIED);

        virtual void onLinkUp(const LinkID& lnk, const NodeID& remote);

        virtual void onLinkDown(const LinkID& lnk, const NodeID& remote);

        virtual void onLinkChanged(const LinkID& lnk, const NodeID& remote);

        virtual void onLinkFail(const LinkID& lnk, const NodeID& remote);

        virtual void onLinkQoSChanged(const LinkID& lnk, const NodeID& remote, const LinkProperties& prop);

        virtual void onMessageSent(seqnum_t seq_num, bool failed, const DataMessage& msg = DataMessage::UNSPECIFIED);



        // node listener interface

        virtual void onJoinCompleted( const SpoVNetID& vid );

        virtual void onJoinFailed( const SpoVNetID& vid );

        virtual void onLeaveCompleted( const SpoVNetID& vid );

        virtual void onLeaveFailed( 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, whether this node initiates or just joins the spovnet

        bool isInitiator;



        // the ping pong service id

        static ServiceID PINGPONG_ID;



        // the current ping id

        unsigned long pingId;



};



// needed for simulation support

ARIBA_SIMULATION_SERVICE(PingPong);



}}} // namespace ariba, application, pingpong



#endif // __PINGPONG_H_