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