| 1 | #ifndef __PINGPONG_H_ |
|---|
| 2 | #define __PINGPONG_H_ |
|---|
| 3 | |
|---|
| 4 | #include "ariba/ariba.h" |
|---|
| 5 | #include "PingPongMessage.h" |
|---|
| 6 | #include "ariba/utility/system/StartupInterface.h" |
|---|
| 7 | #include "ariba/utility/system/Timer.h" |
|---|
| 8 | |
|---|
| 9 | using namespace ariba; |
|---|
| 10 | using ariba::utility::StartupInterface; |
|---|
| 11 | using ariba::utility::Timer; |
|---|
| 12 | |
|---|
| 13 | namespace ariba { |
|---|
| 14 | namespace application { |
|---|
| 15 | namespace pingpong { |
|---|
| 16 | |
|---|
| 17 | /** |
|---|
| 18 | /* The PingPong main class |
|---|
| 19 | /* This class implements an example service for demonstration purposes |
|---|
| 20 | /* The pingpong class sends and receives messages between two SpoVNet |
|---|
| 21 | /* instances |
|---|
| 22 | **/ |
|---|
| 23 | class PingPong : |
|---|
| 24 | public NodeListener, |
|---|
| 25 | public CommunicationListener, |
|---|
| 26 | public StartupInterface, |
|---|
| 27 | public Timer { |
|---|
| 28 | |
|---|
| 29 | use_logging_h(PingPong); |
|---|
| 30 | |
|---|
| 31 | public: |
|---|
| 32 | PingPong(); |
|---|
| 33 | virtual ~PingPong(); |
|---|
| 34 | |
|---|
| 35 | protected: |
|---|
| 36 | // communication listener interface |
|---|
| 37 | virtual bool onLinkRequest(const NodeID& remote, const DataMessage& msg); |
|---|
| 38 | virtual void onMessage(const DataMessage& msg, const NodeID& remote, const LinkID& lnk= LinkID::UNSPECIFIED); |
|---|
| 39 | virtual void onLinkUp(const LinkID& lnk, const NodeID& remote); |
|---|
| 40 | virtual void onLinkDown(const LinkID& lnk, const NodeID& remote); |
|---|
| 41 | virtual void onLinkChanged(const LinkID& lnk, const NodeID& remote); |
|---|
| 42 | virtual void onLinkFail(const LinkID& lnk, const NodeID& remote); |
|---|
| 43 | virtual void onLinkQoSChanged(const LinkID& lnk, const NodeID& remote, const LinkProperties& prop); |
|---|
| 44 | virtual void onMessageSent(seqnum_t seq_num, bool failed, const DataMessage& msg = DataMessage::UNSPECIFIED); |
|---|
| 45 | |
|---|
| 46 | // node listener interface |
|---|
| 47 | virtual void onJoinCompleted( const SpoVNetID& vid ); |
|---|
| 48 | virtual void onJoinFailed( const SpoVNetID& vid ); |
|---|
| 49 | virtual void onLeaveCompleted( const SpoVNetID& vid ); |
|---|
| 50 | virtual void onLeaveFailed( const SpoVNetID& vid ); |
|---|
| 51 | |
|---|
| 52 | // startup wrapper interface |
|---|
| 53 | virtual void startup(); |
|---|
| 54 | virtual void shutdown(); |
|---|
| 55 | |
|---|
| 56 | // timer events |
|---|
| 57 | virtual void eventFunction(); |
|---|
| 58 | |
|---|
| 59 | private: |
|---|
| 60 | // the ariba module and a node |
|---|
| 61 | AribaModule* ariba; |
|---|
| 62 | Node* node; |
|---|
| 63 | |
|---|
| 64 | // flag, whether this node initiates or just joins the spovnet |
|---|
| 65 | bool isInitiator; |
|---|
| 66 | |
|---|
| 67 | // the ping pong service id |
|---|
| 68 | static ServiceID PINGPONG_ID; |
|---|
| 69 | |
|---|
| 70 | // the current ping id |
|---|
| 71 | unsigned long pingId; |
|---|
| 72 | |
|---|
| 73 | }; |
|---|
| 74 | |
|---|
| 75 | // needed for simulation support |
|---|
| 76 | ARIBA_SIMULATION_SERVICE(PingPong); |
|---|
| 77 | |
|---|
| 78 | }}} // namespace ariba, application, pingpong |
|---|
| 79 | |
|---|
| 80 | #endif // __PINGPONG_H_ |
|---|
