// [License] // The Ariba-Underlay Copyright // // Copyright (c) 2008-2009, Institute of Telematics, Universität Karlsruhe (TH) // // Institute of Telematics // Universität Karlsruhe (TH) // Zirkel 2, 76128 Karlsruhe // Germany // // Redistribution and use in source and binary forms, with or without // modification, are permitted provided that the following conditions are // met: // // 1. Redistributions of source code must retain the above copyright // notice, this list of conditions and the following disclaimer. // 2. Redistributions in binary form must reproduce the above copyright // notice, this list of conditions and the following disclaimer in the // documentation and/or other materials provided with the distribution. // // THIS SOFTWARE IS PROVIDED BY THE INSTITUTE OF TELEMATICS ``AS IS'' AND // ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE // IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR // PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE ARIBA PROJECT OR // CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, // EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, // PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR // PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF // LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING // NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS // SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. // // The views and conclusions contained in the software and documentation // are those of the authors and should not be interpreted as representing // official policies, either expressed or implied, of the Institute of // Telematics. // [License] #ifndef __OVERLAY_INTERFACE_H #define __OVERLAY_INTERFACE_H #include "ariba/CommunicationListener.h" #include "ariba/communication/EndpointDescriptor.h" #include "ariba/overlay/modules/OverlayStructureEvents.h" #include "ariba/utility/types/NodeID.h" #include "ariba/utility/types/ServiceID.h" using ariba::CommunicationListener; using ariba::communication::EndpointDescriptor; using ariba::overlay::OverlayStructureEvents; using ariba::utility::NodeID; using ariba::utility::ServiceID; namespace ariba { namespace overlay { class BaseOverlay; /** * This class declares an interface for an structured overlay. */ class OverlayInterface: public CommunicationListener { friend class BaseOverlay; public: /** * A node list */ typedef vector NodeList; /** * Constructs a new overlay. */ OverlayInterface( BaseOverlay& _baseoverlay, const NodeID& _nodeid, OverlayStructureEvents* _eventsReceiver ); /** * Destrcuts the overlay. */ virtual ~OverlayInterface(); /** * Creates the overlay. */ virtual void createOverlay() = 0; /** * Destroys the overlay. */ virtual void deleteOverlay() = 0; /** * Joins the overlay. Starts integration and stabilization of the overlay * Node. * * @param bootstrap The bootstrap end-point descriptor or the default * end-point, if this node is the initiator */ virtual void joinOverlay(const EndpointDescriptor& bootstrap = EndpointDescriptor::UNSPECIFIED ) = 0; /** * Leaves the overlay gracefully. */ virtual void leaveOverlay() = 0; /** * Resolves a overlay neighbor. * * @param node The node to resolve * @return Endpoint descriptor of local neighbor or UNSPECIFIED */ virtual const EndpointDescriptor& resolveNode(const NodeID& node) = 0; /** * Routes a message to a given node by using overlay routing. * * @param destnode The destination node. * @param msg The message to be routed. */ virtual void routeMessage(const NodeID& destnode, Message* msg) = 0; /** * Returns the nodes known to this overlay. * * Usually this are the direct neighbors in the overlay structure. * For instance, Chord would return his predecessor, successor and finger * nodes. On the other hand OneHop would likely return all participating * nodes in the overlay. * * @return The list of all known nodes */ virtual NodeList getKnownNodes() const = 0; //--- functions from CommunicationListener that we _can_ use as overlay --- /// @see CommunicationListener virtual void onLinkUp(const LinkID& lnk, const NodeID& remote); /// @see CommunicationListener virtual void onLinkDown(const LinkID& lnk, const NodeID& remote); /// @see CommunicationListener virtual void onLinkChanged(const LinkID& lnk, const NodeID& remote); /// @see CommunicationListener virtual void onLinkFail(const LinkID& lnk, const NodeID& remote); /// @see CommunicationListener virtual void onLinkQoSChanged(const LinkID& lnk, const NodeID& remote, const LinkProperties& prop); /// @see CommunicationListener virtual bool onLinkRequest(const NodeID& remote, const DataMessage& msg); /// @see CommunicationListener virtual void onMessage(const DataMessage& msg, const NodeID& remote, const LinkID& lnk = LinkID::UNSPECIFIED); protected: /// Reference to an active base overlay BaseOverlay& baseoverlay; /// The node identifier to use with this overlay const NodeID& nodeid; /// The listener used to inform about overlay structure changes OverlayStructureEvents* eventsReceiver; /// The service identifer of this overlay static ServiceID OVERLAY_SERVICE_ID; }; }} // namespace ariba, overlay #endif // __OVERLAY_INTERFACE_H