Changeset 5481 for source/ariba/overlay

Timestamp:

Jul 30, 2009, 1:06:58 PM (15 years ago)

Author:

mies

Message:

 

Location:

source/ariba/overlay

Files:

• BaseOverlay.cpp (modified) (5 diffs)
• BaseOverlay.h (modified) (1 diff)

source/ariba/overlay/BaseOverlay.cpp

@@ -114 +114 @@
 
 /// find a proper relay node
-const NodeID BaseOverlay::findRelayNode( const NodeID& id ) {
+const NodeID BaseOverlay::findRelayNode( const NodeID id ) {
         LinkDescriptor* rld = NULL;
         NodeID relayNode = NodeID::UNSPECIFIED;
@@ -133 +133 @@
                 else relayNode = rld->remoteNode;
         }
-        logging_force( "Potential relay node " << relayNode.toString() );
+
+        // if first relay is unknown choose a arbitrary direct node as relay
+        if ( relayNode.isUnspecified() ) {
+                for (size_t i=0; i<links.size(); i++)
+                        if (links[i]->up &&
+                                links[i]->communicationUp &&
+                                !links[i]->relay &&
+                                links[i]->keepAliveMissed <= 1 &&
+                                links[i]->service == OverlayInterface::OVERLAY_SERVICE_ID) {
+                                relayNode = links[i]->remoteNode;
+                                break;
+                        }
+        }
+
         // do not return myself or use the node as relay node
         if (relayNode == nodeId)
@@ -189 +202 @@
 }
 
+/// routes a message over the overlay or directly sends it when a link is open
+seqnum_t BaseOverlay::sendOverlay( Message* message, const NodeID& nodeid ) {
+        for (size_t i=0; i<links.size(); i++)
+                if ( links[i]->up &&
+                links[i]->communicationUp &&
+                !links[i]->relay &&
+                links[i]->keepAliveMissed <= 1 &&
+                links[i]->remoteNode == nodeid &&
+                links[i]->service == OverlayInterface::OVERLAY_SERVICE_ID) {
+                        return sendMessage( message, links[i] );
+                        break;
+                }
+        overlayInterface->routeMessage(nodeid, message);
+        return 0;
+}
+
 /// creates a link descriptor, apply relay semantics if possible
 LinkDescriptor* BaseOverlay::createLinkDescriptor(
-        const NodeID& remoteNode, const ServiceID& service, const LinkID& link_id ) {
+        const NodeID remoteNode, const ServiceID service, const LinkID link_id ) {
 
         // find listener
@@ -1321 +1350 @@
                                         if (relayMsg->getRelayNode() == nodeId || relayMsg->getRelayNode().isUnspecified()) {
                                                 logging_info("Routing relay message to " << relayMsg->getDestNode().toString() );
-                                                overlayInterface->routeMessage(relayMsg->getDestNode(), &_overMsg );
+                                                sendOverlay( &_overMsg, relayMsg->getDestNode() );
                                         } else {
                                                 logging_info("Routing relay message to " << relayMsg->getRelayNode().toString() );
-                                                overlayInterface->routeMessage(relayMsg->getRelayNode(), &_overMsg );
+                                                sendOverlay( &_overMsg, relayMsg->getRelayNode() );
                                         }
                                         return true;
@@ -1354 +1383 @@
 
                                                 /// this must be handled by using relay link!
-                                                overlayInterface->routeMessage(relayMsg->getDestNode(), &_overMsg );
+                                                sendOverlay(&_overMsg, relayMsg->getDestNode());
                                                 return true;
                                         }

source/ariba/overlay/BaseOverlay.h

@@ -415 +415 @@
 
         /// find a proper relay node that is directly connected to this node
-        const NodeID findRelayNode( const NodeID& id );
+        const NodeID findRelayNode( const NodeID id );
 
         /// forwards a message over relays/overlay/directly using link descriptor
         seqnum_t sendMessage( Message* message, const LinkDescriptor* ld );
 
+        /// routes a message over the overlay or directly sends it when a link is open
+        seqnum_t sendOverlay( Message* message, const NodeID& nodeid );
+
         /// creates a link descriptor, applys relay semantics if possible
         LinkDescriptor* createLinkDescriptor(
-                const NodeID& remoteNode, const ServiceID& service, const LinkID& link_id );
+                const NodeID remoteNode, const ServiceID service, const LinkID link_id );
 
         // map of a link request map a nonce to a LinkID