#include <source/ariba/overlay/BaseOverlay.h>
Public Member Functions | |
BaseOverlay () | |
virtual | ~BaseOverlay () |
void | start (BaseCommunication &_basecomm, const NodeID &_nodeid) |
void | stop () |
const LinkID | establishLink (const NodeID &node, const ServiceID &service, const LinkID &linkid=LinkID::UNSPECIFIED) |
establishes a link between two arbitrary nodes | |
const LinkID | establishLink (const EndpointDescriptor &ep, const ServiceID &service, const LinkID &linkid=LinkID::UNSPECIFIED) |
void | dropLink (const LinkID &link) |
drops a link | |
seqnum_t | sendMessage (const Message *message, const LinkID &link) |
sends a message over an existing link | |
seqnum_t | sendMessage (const Message *message, const NodeID &node, const ServiceID &service) |
sends a message to a node and a specific service | |
void | broadcastMessage (Message *message, const ServiceID &service) |
const EndpointDescriptor & | getEndpointDescriptor (const LinkID &link=LinkID::UNSPECIFIED) const |
vector< NodeID > | getOverlayNeighbors () const |
const EndpointDescriptor & | getEndpointDescriptor (const NodeID &node) const |
bool | bind (CommunicationListener *listener, const ServiceID &sid) |
bool | unbind (CommunicationListener *listener, const ServiceID &sid) |
bool | bind (NodeListener *listener) |
bool | unbind (NodeListener *listener) |
bool | registerSidePort (SideportListener *_sideport) |
bool | unregisterSidePort (SideportListener *_sideport) |
const NodeID & | getNodeID (const LinkID &lid=LinkID::UNSPECIFIED) const |
vector< LinkID > | getLinkIDs (const NodeID &nid=NodeID::UNSPECIFIED) const |
void | joinSpoVNet (const SpoVNetID &id, const EndpointDescriptor &boot) |
void | createSpoVNet (const SpoVNetID &id, const OverlayParameterSet ¶m=OverlayParameterSet::DEFAULT, const SecurityParameterSet &sec=SecurityParameterSet::DEFAULT, const QoSParameterSet &qos=QoSParameterSet::DEFAULT) |
void | leaveSpoVNet () |
Protected Member Functions | |
virtual void | onLinkUp (const LinkID &id, const NetworkLocator *local, const NetworkLocator *remote) |
virtual void | onLinkDown (const LinkID &id, const NetworkLocator *local, const NetworkLocator *remote) |
virtual void | onLinkChanged (const LinkID &id, const NetworkLocator *oldlocal, const NetworkLocator *newlocal, const NetworkLocator *oldremote, const NetworkLocator *newremote) |
virtual void | onLinkFail (const LinkID &id, const NetworkLocator *local, const NetworkLocator *remote) |
virtual void | onLinkQoSChanged (const LinkID &id, const NetworkLocator *local, const NetworkLocator *remote, const QoSParameterSet &qos) |
virtual bool | onLinkRequest (const LinkID &id, const NetworkLocator *local, const NetworkLocator *remote) |
virtual bool | receiveMessage (const Message *message, const LinkID &link, const NodeID &) |
virtual void | incomingRouteMessage (Message *msg) |
virtual void | onNodeJoin (const NodeID &node) |
virtual void | eventFunction () |
Private Types | |
enum | _BaseOverlayState { BaseOverlayStateInvalid = 0, BaseOverlayStateInitiator = 1, BaseOverlayStateJoinInitiated = 2, BaseOverlayStateCompleted = 3 } |
typedef vector< NodeListener * > | NodeListenerVector |
typedef enum ariba::overlay::BaseOverlay::_BaseOverlayState | BaseOverlayState |
typedef map< const LinkID, LinkItem > | LinkMapping |
typedef pair< const LinkID, LinkItem > | LinkPair |
typedef map< const uint32_t, LinkID > | PendingLinkMap |
typedef vector< NodeID > | JoiningNodes |
Private Member Functions | |
use_logging_h (BaseOverlay) | |
void | updateOvlVis (const NodeID &node) |
Private Attributes | |
BaseCommunication * | bc |
NodeID | nodeId |
SpoVNetID | spovnetId |
Demultiplexer < CommunicationListener *, ServiceID > | communicationListeners |
NodeListenerVector | nodeListeners |
SideportListener * | sideport |
OverlayInterface * | overlayInterface |
LinkID | initiatorLink |
BaseOverlayState | state |
NodeID | spovnetInitiator |
NodeID | min |
NodeID | max |
NodeID | succ |
NodeID | pred |
LinkMapping | linkMapping |
PendingLinkMap | pendingLinks |
JoiningNodes | joiningNodes |
Friends | |
class | OneHop |
class | Chord |
Classes | |
class | LinkItem |
Definition at line 114 of file BaseOverlay.h.
typedef vector<NodeListener*> ariba::overlay::BaseOverlay::NodeListenerVector [private] |
TODO
Definition at line 365 of file BaseOverlay.h.
typedef enum ariba::overlay::BaseOverlay::_BaseOverlayState ariba::overlay::BaseOverlay::BaseOverlayState [private] |
The state of the BaseOverlay
typedef map<const LinkID, LinkItem> ariba::overlay::BaseOverlay::LinkMapping [private] |
Definition at line 484 of file BaseOverlay.h.
typedef pair<const LinkID, LinkItem> ariba::overlay::BaseOverlay::LinkPair [private] |
Definition at line 485 of file BaseOverlay.h.
typedef map<const uint32_t, LinkID> ariba::overlay::BaseOverlay::PendingLinkMap [private] |
Definition at line 489 of file BaseOverlay.h.
typedef vector<NodeID> ariba::overlay::BaseOverlay::JoiningNodes [private] |
nodes with pending joines. TODO: should be cleaned every some seconds, add timestamps to each, and check on occasion
Definition at line 496 of file BaseOverlay.h.
enum ariba::overlay::BaseOverlay::_BaseOverlayState [private] |
The state of the BaseOverlay
BaseOverlayStateInvalid | |
BaseOverlayStateInitiator | |
BaseOverlayStateJoinInitiated | |
BaseOverlayStateCompleted |
Definition at line 392 of file BaseOverlay.h.
ariba::overlay::BaseOverlay::BaseOverlay | ( | ) |
Constructs an empty non-functional base overlay instance
Definition at line 56 of file BaseOverlay.cpp.
ariba::overlay::BaseOverlay::~BaseOverlay | ( | ) | [virtual] |
Destructs a base overlay instance
Definition at line 62 of file BaseOverlay.cpp.
ariba::overlay::BaseOverlay::use_logging_h | ( | BaseOverlay | ) | [private] |
void ariba::overlay::BaseOverlay::start | ( | BaseCommunication & | _basecomm, | |
const NodeID & | _nodeid | |||
) |
Starts the Base Overlay instance
Referenced by ariba::Node::initiate(), and ariba::Node::join().
void ariba::overlay::BaseOverlay::stop | ( | ) |
Stops the Base Overlay instance
Reimplemented from ariba::utility::Timer.
Definition at line 94 of file BaseOverlay.cpp.
References bc, logging_info, and ariba::utility::Timer::stop().
Referenced by ariba::Node::leave().
const LinkID ariba::overlay::BaseOverlay::establishLink | ( | const NodeID & | node, | |
const ServiceID & | service, | |||
const LinkID & | linkid = LinkID::UNSPECIFIED | |||
) |
establishes a link between two arbitrary nodes
Starts a link establishment procedure to the specfied node for the service with id service
node | Destination node id | |
service | Service to connect to | |
linkid | Link identifier to be used with this link |
Definition at line 208 of file BaseOverlay.cpp.
References bc, communicationListeners, ariba::utility::LinkID::create(), ariba::utility::Identifier::isUnspecified(), linkMapping, logging_debug, logging_error, overlayInterface, ariba::overlay::OverlayMsg::OverlayMessageTypeLinkRequest, pendingLinks, ariba::overlay::OverlayInterface::routeMessage(), ariba::utility::NodeID::UNSPECIFIED, and ariba::utility::LinkID::UNSPECIFIED.
Referenced by ariba::Node::establishLink(), ariba::overlay::OneHop::joinOverlay(), ariba::overlay::OneHop::onMessage(), sendMessage(), and ariba::overlay::Chord::setup().
const LinkID ariba::overlay::BaseOverlay::establishLink | ( | const EndpointDescriptor & | ep, | |
const ServiceID & | service, | |||
const LinkID & | linkid = LinkID::UNSPECIFIED | |||
) |
Starts a link establishment procedure to the specified
endpoint and to the specified service
Definition at line 248 of file BaseOverlay.cpp.
References bc, communicationListeners, linkMapping, logging_error, ariba::utility::ServiceID::toString(), ariba::utility::NodeID::UNSPECIFIED, and ariba::utility::LinkID::UNSPECIFIED.
void ariba::overlay::BaseOverlay::dropLink | ( | const LinkID & | link | ) |
drops a link
Definition at line 267 of file BaseOverlay.cpp.
References bc, ariba::overlay::BaseOverlay::LinkItem::deleteWaiting(), ariba::overlay::BaseOverlay::LinkItem::interface, linkMapping, logging_debug, logging_warn, ariba::overlay::BaseOverlay::LinkItem::node, nodeId, ariba::SideportListener::onLinkDown(), ariba::CommunicationListener::onLinkDown(), sideport, ariba::utility::Identifier::toString(), and ariba::overlay::BaseOverlay::LinkItem::waitingmsg.
Referenced by ariba::Node::dropLink(), ariba::overlay::Chord::eventFunction(), eventFunction(), leaveSpoVNet(), ariba::overlay::OneHop::onMessage(), ariba::overlay::Chord::onMessage(), and receiveMessage().
sends a message over an existing link
Definition at line 298 of file BaseOverlay.cpp.
References bc, data_serialize(), linkMapping, logging_debug, logging_error, logging_info, nodeId, ariba::overlay::OverlayMsg::OverlayMessageTypeData, and ariba::utility::Identifier::toString().
Referenced by broadcastMessage(), ariba::overlay::OneHop::leaveOverlay(), ariba::overlay::OneHop::onLinkUp(), ariba::overlay::OneHop::onMessage(), receiveMessage(), ariba::overlay::OneHop::routeMessage(), ariba::overlay::Chord::send(), sendMessage(), and ariba::Node::sendMessage().
seqnum_t ariba::overlay::BaseOverlay::sendMessage | ( | const Message * | message, | |
const NodeID & | node, | |||
const ServiceID & | service | |||
) |
sends a message to a node and a specific service
Definition at line 342 of file BaseOverlay.cpp.
References establishLink(), linkMapping, logging_debug, logging_error, logging_info, sendMessage(), ariba::utility::ServiceID::toString(), ariba::utility::Identifier::toString(), and ariba::utility::LinkID::UNSPECIFIED.
Send out a message to all nodes that are known in the overlay structure. Depending on the structure of the overlay, this can be very different.
Definition at line 1014 of file BaseOverlay.cpp.
References ariba::overlay::OverlayInterface::getKnownNodes(), logging_debug, nodeId, overlayInterface, sendMessage(), and ariba::utility::ServiceID::toString().
Referenced by ariba::Node::sendBroadcastMessage().
const EndpointDescriptor & ariba::overlay::BaseOverlay::getEndpointDescriptor | ( | const LinkID & | link = LinkID::UNSPECIFIED |
) | const |
Returns the end-point descriptor of a link.
link | the link id of the requested end-point |
Definition at line 401 of file BaseOverlay.cpp.
References bc.
Referenced by ariba::overlay::OneHop::eventFunction(), ariba::SideportListener::getEndpointDescription(), ariba::overlay::OneHop::onMessage(), receiveMessage(), ariba::overlay::OneHop::resolveNode(), ariba::overlay::Chord::resolveNode(), and ariba::overlay::Chord::send_discovery_to().
vector< NodeID > ariba::overlay::BaseOverlay::getOverlayNeighbors | ( | ) | const |
Get a list of overlay neighbors.
Definition at line 1030 of file BaseOverlay.cpp.
References ariba::overlay::OverlayInterface::getKnownNodes(), nodeId, and overlayInterface.
Referenced by ariba::Node::getNeighborNodes().
const EndpointDescriptor & ariba::overlay::BaseOverlay::getEndpointDescriptor | ( | const NodeID & | node | ) | const |
Returns a end-endpoint descriptor of a overlay neighbor. If the node is not known -- an unspecified endpoint descriptor is returned.
node | The node identifer of a overlay neighbor. |
Definition at line 406 of file BaseOverlay.cpp.
References bc, logging_error, nodeId, overlayInterface, ariba::overlay::OverlayInterface::resolveNode(), ariba::communication::EndpointDescriptor::UNSPECIFIED, and ariba::utility::NodeID::UNSPECIFIED.
bool ariba::overlay::BaseOverlay::bind | ( | CommunicationListener * | listener, | |
const ServiceID & | sid | |||
) |
Definition at line 421 of file BaseOverlay.cpp.
References communicationListeners, logging_debug, logging_error, and ariba::utility::ServiceID::toString().
Referenced by ariba::Node::bind().
bool ariba::overlay::BaseOverlay::unbind | ( | CommunicationListener * | listener, | |
const ServiceID & | sid | |||
) |
Definition at line 444 of file BaseOverlay.cpp.
References communicationListeners, logging_debug, logging_warn, and ariba::utility::ServiceID::toString().
Referenced by ariba::Node::unbind(), and ariba::overlay::OverlayInterface::~OverlayInterface().
bool ariba::overlay::BaseOverlay::bind | ( | NodeListener * | listener | ) |
Definition at line 463 of file BaseOverlay.cpp.
References logging_debug, logging_warn, and nodeListeners.
bool ariba::overlay::BaseOverlay::unbind | ( | NodeListener * | listener | ) |
Definition at line 476 of file BaseOverlay.cpp.
References logging_debug, logging_warn, and nodeListeners.
bool ariba::overlay::BaseOverlay::registerSidePort | ( | SideportListener * | _sideport | ) |
Definition at line 435 of file BaseOverlay.cpp.
References ariba::SideportListener::configure(), and sideport.
Referenced by ariba::Node::bind().
bool ariba::overlay::BaseOverlay::unregisterSidePort | ( | SideportListener * | _sideport | ) |
Definition at line 440 of file BaseOverlay.cpp.
References ariba::SideportListener::DEFAULT, and sideport.
const NodeID & ariba::overlay::BaseOverlay::getNodeID | ( | const LinkID & | lid = LinkID::UNSPECIFIED |
) | const |
Returns the own nodeID or the NodeID of the specified link
lid | The link identifier |
Definition at line 1072 of file BaseOverlay.cpp.
References linkMapping, nodeId, ariba::utility::NodeID::UNSPECIFIED, and ariba::utility::LinkID::UNSPECIFIED.
Referenced by ariba::SideportListener::getNodeID(), and ariba::Node::getNodeId().
vector< LinkID > ariba::overlay::BaseOverlay::getLinkIDs | ( | const NodeID & | nid = NodeID::UNSPECIFIED |
) | const |
Return all Links for the specified remote nodeid, or all links when the node id given is set to unspecified
nid | The node id to request links for, or unspecified for all links |
Definition at line 1081 of file BaseOverlay.cpp.
References linkMapping, and ariba::utility::NodeID::UNSPECIFIED.
Referenced by ariba::SideportListener::getLinkIDs().
void ariba::overlay::BaseOverlay::joinSpoVNet | ( | const SpoVNetID & | id, | |
const EndpointDescriptor & | boot | |||
) |
Join a existing sponaneous virtual network (spovnet).
id | A spovnet identifier | |
boot | A bootstrap node |
Definition at line 103 of file BaseOverlay.cpp.
References BaseOverlayStateJoinInitiated, bc, initiatorLink, logging_info, nodeId, ovl, ovlId, spovnetId, state, and ariba::utility::Identifier::toString().
Referenced by ariba::Node::join().
void ariba::overlay::BaseOverlay::createSpoVNet | ( | const SpoVNetID & | id, | |
const OverlayParameterSet & | param = OverlayParameterSet::DEFAULT , |
|||
const SecurityParameterSet & | sec = SecurityParameterSet::DEFAULT , |
|||
const QoSParameterSet & | qos = QoSParameterSet::DEFAULT | |||
) |
Initiates a new spontaneous virtual network. This makes this BaseOverlay to the SpoVNet-Initiator.
id | The spovnet identifier |
Referenced by ariba::Node::initiate().
void ariba::overlay::BaseOverlay::leaveSpoVNet | ( | ) |
Let the node leave the SpoVNet.
Definition at line 125 of file BaseOverlay.cpp.
References BaseOverlayStateInitiator, BaseOverlayStateInvalid, bc, dropLink(), initiatorLink, ariba::overlay::OverlayInterface::leaveOverlay(), linkMapping, logging_debug, logging_info, nodeId, nodeListeners, ariba::NodeListener::onLeaveCompleted(), ariba::NodeListener::onLeaveFailed(), ariba::overlay::OverlayInterface::OVERLAY_SERVICE_ID, overlayInterface, ariba::overlay::OverlayMsg::OverlayMessageTypeBye, ovl, ovlId, spovnetId, state, and ariba::utility::LinkID::UNSPECIFIED.
Referenced by ariba::Node::leave().
void ariba::overlay::BaseOverlay::onLinkUp | ( | const LinkID & | id, | |
const NetworkLocator * | local, | |||
const NetworkLocator * | remote | |||
) | [protected, virtual] |
Reimplemented from ariba::communication::CommunicationEvents.
Definition at line 489 of file BaseOverlay.cpp.
References BaseOverlayStateJoinInitiated, bc, ariba::CommunicationListener::DEFAULT, initiatorLink, linkMapping, logging_debug, logging_info, nodeId, ariba::overlay::OverlayMsg::OverlayMessageTypeJoinRequest, ariba::overlay::OverlayMsg::OverlayMessageTypeUpdate, state, ariba::utility::Identifier::toString(), ariba::utility::ServiceID::UNSPECIFIED, and ariba::utility::NodeID::UNSPECIFIED.
void ariba::overlay::BaseOverlay::onLinkDown | ( | const LinkID & | id, | |
const NetworkLocator * | local, | |||
const NetworkLocator * | remote | |||
) | [protected, virtual] |
Reimplemented from ariba::communication::CommunicationEvents.
Definition at line 559 of file BaseOverlay.cpp.
References linkMapping, logging_debug, logging_warn, nodeId, ariba::SideportListener::onLinkDown(), and sideport.
void ariba::overlay::BaseOverlay::onLinkChanged | ( | const LinkID & | id, | |
const NetworkLocator * | oldlocal, | |||
const NetworkLocator * | newlocal, | |||
const NetworkLocator * | oldremote, | |||
const NetworkLocator * | newremote | |||
) | [protected, virtual] |
Reimplemented from ariba::communication::CommunicationEvents.
Definition at line 593 of file BaseOverlay.cpp.
References linkMapping, logging_debug, nodeId, ariba::SideportListener::onLinkChanged(), and sideport.
void ariba::overlay::BaseOverlay::onLinkFail | ( | const LinkID & | id, | |
const NetworkLocator * | local, | |||
const NetworkLocator * | remote | |||
) | [protected, virtual] |
Reimplemented from ariba::communication::CommunicationEvents.
Definition at line 612 of file BaseOverlay.cpp.
References linkMapping, logging_debug, nodeId, ariba::SideportListener::onLinkFail(), and sideport.
virtual void ariba::overlay::BaseOverlay::onLinkQoSChanged | ( | const LinkID & | id, | |
const NetworkLocator * | local, | |||
const NetworkLocator * | remote, | |||
const QoSParameterSet & | qos | |||
) | [protected, virtual] |
Reimplemented from ariba::communication::CommunicationEvents.
bool ariba::overlay::BaseOverlay::onLinkRequest | ( | const LinkID & | id, | |
const NetworkLocator * | local, | |||
const NetworkLocator * | remote | |||
) | [protected, virtual] |
Reimplemented from ariba::communication::CommunicationEvents.
Definition at line 646 of file BaseOverlay.cpp.
References logging_debug.
bool ariba::overlay::BaseOverlay::receiveMessage | ( | const Message * | message, | |
const LinkID & | link, | |||
const NodeID & | ||||
) | [protected, virtual] |
Processes a received message.
Beware: nodeid is not valid in this case! (since this class implements nodeid's in the first place *g*)
Definition at line 656 of file BaseOverlay.cpp.
References BaseOverlayStateCompleted, BaseOverlayStateInitiator, BaseOverlayStateInvalid, BaseOverlayStateJoinInitiated, bc, communicationListeners, ariba::overlay::OverlayFactory::create(), ariba::CommunicationListener::DEFAULT, dropLink(), ariba::overlay::JoinReply::getBootstrapEndpoint(), ariba::overlay::LinkRequest::getEndpoint(), getEndpointDescriptor(), ariba::overlay::JoinReply::getJoinAllowed(), ariba::overlay::LinkRequest::getNonce(), ariba::overlay::JoinReply::getParam(), ariba::overlay::OverlayInterface::getParameters(), ariba::overlay::JoinReply::getSpoVNetID(), ariba::overlay::JoinRequest::getSpoVNetID(), initiatorLink, ariba::overlay::LinkRequest::isReply(), joiningNodes, linkMapping, logging_debug, logging_error, logging_fatal, logging_info, logging_warn, nodeId, nodeListeners, ariba::NodeListener::onJoinCompleted(), ariba::NodeListener::onJoinFailed(), ariba::NodeListener::onLeaveFailed(), ariba::CommunicationListener::onLinkRequest(), ariba::SideportListener::onLinkUp(), ariba::CommunicationListener::onLinkUp(), ariba::CommunicationListener::onMessage(), overlayInterface, ariba::overlay::OverlayMsg::OverlayMessageTypeBye, ariba::overlay::OverlayMsg::OverlayMessageTypeData, ariba::overlay::OverlayMsg::OverlayMessageTypeJoinReply, ariba::overlay::OverlayMsg::OverlayMessageTypeJoinRequest, ariba::overlay::OverlayMsg::OverlayMessageTypeLinkRequest, ariba::overlay::OverlayMsg::OverlayMessageTypeUpdate, ovl, ovlId, pendingLinks, ariba::overlay::OverlayInterface::routeMessage(), sendMessage(), sideport, spovnetInitiator, state, ariba::communication::EndpointDescriptor::toString(), ariba::utility::Identifier::toString(), ariba::utility::ServiceID::toString(), and ariba::utility::LinkID::UNSPECIFIED.
Referenced by incomingRouteMessage().
void ariba::overlay::BaseOverlay::incomingRouteMessage | ( | Message * | msg | ) | [protected, virtual] |
This method is called, when a routed message arrives from the overlay.
Reimplemented from ariba::overlay::OverlayStructureEvents.
Definition at line 1094 of file BaseOverlay.cpp.
References receiveMessage(), ariba::utility::NodeID::UNSPECIFIED, and ariba::utility::LinkID::UNSPECIFIED.
Referenced by ariba::overlay::OneHop::onMessage(), ariba::overlay::Chord::onMessage(), and ariba::overlay::Chord::routeMessage().
void ariba::overlay::BaseOverlay::onNodeJoin | ( | const NodeID & | node | ) | [protected, virtual] |
This method is called, when a new node joined the network
Reimplemented from ariba::overlay::OverlayStructureEvents.
Definition at line 1099 of file BaseOverlay.cpp.
References joiningNodes, logging_info, and ariba::utility::Identifier::toString().
void ariba::overlay::BaseOverlay::eventFunction | ( | ) | [protected, virtual] |
Timer Event method
Reimplemented from ariba::utility::Timer.
Definition at line 1110 of file BaseOverlay.cpp.
References dropLink(), linkMapping, logging_debug, and ariba::utility::Identifier::toString().
void ariba::overlay::BaseOverlay::updateOvlVis | ( | const NodeID & | node | ) | [private] |
Definition at line 1041 of file BaseOverlay.cpp.
References ariba::utility::Identifier::isUnspecified(), max, min, nodeId, ovl, ovlId, and succ.
friend class OneHop [friend] |
Definition at line 118 of file BaseOverlay.h.
friend class Chord [friend] |
Definition at line 119 of file BaseOverlay.h.
BaseCommunication* ariba::overlay::BaseOverlay::bc [private] |
The BaseCommunication the BaseOverlay communicates over
Definition at line 344 of file BaseOverlay.h.
Referenced by dropLink(), establishLink(), getEndpointDescriptor(), joinSpoVNet(), leaveSpoVNet(), onLinkUp(), receiveMessage(), sendMessage(), and stop().
NodeID ariba::overlay::BaseOverlay::nodeId [private] |
The nodeid of this BaseOverlay instance.
Definition at line 349 of file BaseOverlay.h.
Referenced by broadcastMessage(), dropLink(), getEndpointDescriptor(), getNodeID(), getOverlayNeighbors(), joinSpoVNet(), leaveSpoVNet(), onLinkChanged(), onLinkDown(), onLinkFail(), onLinkUp(), receiveMessage(), sendMessage(), and updateOvlVis().
The SpoVNetID that we are joined to or that we have created.
Definition at line 355 of file BaseOverlay.h.
Referenced by joinSpoVNet(), and leaveSpoVNet().
Demultiplexer<CommunicationListener*, ServiceID> ariba::overlay::BaseOverlay::communicationListeners [private] |
TODO
Definition at line 360 of file BaseOverlay.h.
Referenced by bind(), establishLink(), receiveMessage(), and unbind().
TODO
Definition at line 370 of file BaseOverlay.h.
Referenced by bind(), leaveSpoVNet(), receiveMessage(), and unbind().
TODO
Definition at line 375 of file BaseOverlay.h.
Referenced by dropLink(), onLinkChanged(), onLinkDown(), onLinkFail(), receiveMessage(), registerSidePort(), and unregisterSidePort().
The abstract overlay interface that implements the overlay specific functionality.
Definition at line 381 of file BaseOverlay.h.
Referenced by broadcastMessage(), establishLink(), getEndpointDescriptor(), getOverlayNeighbors(), leaveSpoVNet(), and receiveMessage().
The special link to the Initiator of the SpoVNet or LinkID::UNDEFINED if we are the Initiator
Definition at line 387 of file BaseOverlay.h.
Referenced by joinSpoVNet(), leaveSpoVNet(), onLinkUp(), and receiveMessage().
TODO
Definition at line 402 of file BaseOverlay.h.
Referenced by joinSpoVNet(), leaveSpoVNet(), onLinkUp(), and receiveMessage().
NodeID ariba::overlay::BaseOverlay::min [private] |
NodeID ariba::overlay::BaseOverlay::max [private] |
NodeID ariba::overlay::BaseOverlay::succ [private] |
NodeID ariba::overlay::BaseOverlay::pred [private] |
Definition at line 413 of file BaseOverlay.h.
Definition at line 486 of file BaseOverlay.h.
Referenced by dropLink(), establishLink(), eventFunction(), getLinkIDs(), getNodeID(), leaveSpoVNet(), onLinkChanged(), onLinkDown(), onLinkFail(), onLinkUp(), receiveMessage(), and sendMessage().