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