source: source/ariba/overlay/modules/OverlayInterface.h@ 5665

Last change on this file since 5665 was 5624, checked in by Christoph Mayer, 15 years ago

maemo segfault wegen static object ctors workaround

File size: 6.2 KB
Line 
1// [License]
2// The Ariba-Underlay Copyright
3//
4// Copyright (c) 2008-2009, Institute of Telematics, UniversitÀt Karlsruhe (TH)
5//
6// Institute of Telematics
7// UniversitÀt Karlsruhe (TH)
8// Zirkel 2, 76128 Karlsruhe
9// Germany
10//
11// Redistribution and use in source and binary forms, with or without
12// modification, are permitted provided that the following conditions are
13// met:
14//
15// 1. Redistributions of source code must retain the above copyright
16// notice, this list of conditions and the following disclaimer.
17// 2. Redistributions in binary form must reproduce the above copyright
18// notice, this list of conditions and the following disclaimer in the
19// documentation and/or other materials provided with the distribution.
20//
21// THIS SOFTWARE IS PROVIDED BY THE INSTITUTE OF TELEMATICS ``AS IS'' AND
22// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
23// IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
24// PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE ARIBA PROJECT OR
25// CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
26// EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
27// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
28// PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
29// LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
30// NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
31// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
32//
33// The views and conclusions contained in the software and documentation
34// are those of the authors and should not be interpreted as representing
35// official policies, either expressed or implied, of the Institute of
36// Telematics.
37// [License]
38
39#ifndef __OVERLAY_INTERFACE_H
40#define __OVERLAY_INTERFACE_H
41
42#include "ariba/CommunicationListener.h"
43#include "ariba/communication/EndpointDescriptor.h"
44#include "ariba/overlay/modules/OverlayStructureEvents.h"
45#include "ariba/utility/types/NodeID.h"
46#include "ariba/utility/types/ServiceID.h"
47#include "ariba/utility/types/OverlayParameterSet.h"
48
49using ariba::CommunicationListener;
50using ariba::communication::EndpointDescriptor;
51using ariba::overlay::OverlayStructureEvents;
52using ariba::utility::NodeID;
53using ariba::utility::ServiceID;
54using ariba::utility::OverlayParameterSet;
55
56namespace ariba {
57namespace overlay {
58
59class BaseOverlay;
60
61/**
62 * This class declares an interface for an structured overlay.
63 */
64class OverlayInterface: public CommunicationListener {
65 friend class BaseOverlay;
66
67public:
68 /**
69 * A node list
70 */
71 typedef vector<NodeID> NodeList;
72
73 /**
74 * Constructs a new overlay.
75 */
76 OverlayInterface(
77 BaseOverlay& _baseoverlay,
78 const NodeID& _nodeid,
79 OverlayStructureEvents* _eventsReceiver,
80 OverlayParameterSet _parameters
81 );
82
83 /**
84 * Destrcuts the overlay.
85 */
86 virtual ~OverlayInterface();
87
88 /**
89 * Creates the overlay.
90 */
91 virtual void createOverlay() = 0;
92
93 /**
94 * Destroys the overlay.
95 */
96 virtual void deleteOverlay() = 0;
97
98 /**
99 * Joins the overlay. Starts integration and stabilization of the overlay
100 * Node.
101 *
102 * @param bootstrap The bootstrap end-point descriptor or the default
103 * end-point, if this node is the initiator
104 */
105 virtual void joinOverlay(const EndpointDescriptor& bootstrap = EndpointDescriptor::UNSPECIFIED()) = 0;
106
107 /**
108 * Leaves the overlay gracefully.
109 */
110 virtual void leaveOverlay() = 0;
111
112 /**
113 * Resolves a overlay neighbor.
114 *
115 * @param node The node to resolve
116 * @return Endpoint descriptor of local neighbor or UNSPECIFIED
117 */
118 virtual const EndpointDescriptor& resolveNode(const NodeID& node) = 0;
119
120 /**
121 * Routes a message to a given node by using overlay routing.
122 *
123 * @param destnode The destination node.
124 * @param msg The message to be routed.
125 */
126 virtual void routeMessage(const NodeID& destnode, Message* msg) = 0;
127
128 /**
129 * Routes a message to a given node by using an existing link.
130 *
131 * TODO: This is a hack. This method allows the BaseOverlay class to
132 * use overlay signaling links to transfer data for relaying
133 *
134 * @param node The destination node.
135 * @param link An established link
136 * @param msg The message to be sent.
137 */
138 virtual void routeMessage(const NodeID& node, const LinkID& link, Message* msg) = 0;
139
140 /**
141 * Returns the nodes known to this overlay.
142 *
143 * Usually this are the direct neighbors in the overlay structure.
144 * For instance, Chord would return his predecessor, successor and finger
145 * nodes. On the other hand OneHop would likely return all participating
146 * nodes in the overlay.
147 *
148 * @return The list of all known nodes
149 */
150 virtual NodeList getKnownNodes(bool deep = true) const = 0;
151
152 /**
153 * Returns the link id of the next hop a route message would take.
154 *
155 * @param id The destination node id
156 * @return The link id of the next hop
157 */
158 virtual const LinkID& getNextLinkId( const NodeID& id ) const = 0;
159
160 //--- functions from CommunicationListener that we _can_ use as overlay ---
161
162 /// @see CommunicationListener
163 virtual void onLinkUp(const LinkID& lnk, const NodeID& remote);
164
165 /// @see CommunicationListener
166 virtual void onLinkDown(const LinkID& lnk, const NodeID& remote);
167
168 /// @see CommunicationListener
169 virtual void onLinkChanged(const LinkID& lnk, const NodeID& remote);
170
171 /// @see CommunicationListener
172 virtual void onLinkFail(const LinkID& lnk, const NodeID& remote);
173
174 /// @see CommunicationListener
175 virtual void onLinkQoSChanged(const LinkID& lnk, const NodeID& remote,
176 const LinkProperties& prop);
177
178 /// @see CommunicationListener
179 virtual bool onLinkRequest(const NodeID& remote, const DataMessage& msg);
180
181 /// @see CommunicationListener
182 virtual void onMessage(const DataMessage& msg, const NodeID& remote,
183 const LinkID& lnk = LinkID::UNSPECIFIED);
184
185
186 const OverlayParameterSet& getParameters() const;
187
188protected:
189 /// Reference to an active base overlay
190 BaseOverlay& baseoverlay;
191
192 /// The parameters of the overlay structure
193 OverlayParameterSet parameters;
194
195 /// The node identifier to use with this overlay
196 const NodeID& nodeid;
197
198 /// The listener used to inform about overlay structure changes
199 OverlayStructureEvents* eventsReceiver;
200
201 /// The service identifer of this overlay
202 static ServiceID OVERLAY_SERVICE_ID;
203};
204
205}} // namespace ariba, overlay
206
207#endif // __OVERLAY_INTERFACE_H
Note: See TracBrowser for help on using the repository browser.