source: sample/pingpong/PingPong.h@ 12772

#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"



#include <vector>



using namespace ariba;

using ariba::utility::StartupInterface;

using ariba::utility::Timer;



namespace ariba {

namespace application {

namespace pingpong {



using namespace std;



/**

 * 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( string config );

        virtual ~PingPong();



protected:

        // communication listener interface

        virtual bool onLinkRequest(const NodeID& remote);

        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);



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

        Node node;

        string name;

        int counter;

        vector<string> names;



        // the ping pong service id

        static ServiceID PINGPONG_SERVICEID;



        // the current ping id

        unsigned long pingId;



        string config_file;

};



}}} // namespace ariba, application, pingpong



#endif // __PINGPONG_H_