Changeset 5539

Timestamp:

Jul 31, 2009, 4:39:08 PM (15 years ago)

Author:

mies

Message:

 

Location:

source/ariba/overlay

Files:

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

source/ariba/overlay/BaseOverlay.cpp

@@ -205 +205 @@
 }
 
+LinkDescriptor* BaseOverlay::getSendDescriptor( const NodeID& nodeid ) {
+        for (size_t i=0; i<links.size(); i++)
+                if ( !links[i]->relay &&
+                        links[i]->up &&
+                        links[i]->communicationUp &&
+                        links[i]->keepAliveMissed <= 1 &&
+                        links[i]->remoteNode == nodeid &&
+                        links[i]->service == OverlayInterface::OVERLAY_SERVICE_ID) {
+                        links[i]->markAsRelay();
+                        return links[i];
+                }
+        LinkDescriptor* ld = getDescriptor(overlayInterface->getNextLinkId(nodeid));
+        if (ld->relay)
+                return getRelayDescriptor(ld->localRelay);
+}
+
 /// routes a message over the overlay or directly sends it when a link is open
 seqnum_t BaseOverlay::sendOverlay( Message* message, const NodeID& nodeid ) {
@@ -1460 +1476 @@
                         return false;
                 }
-
         } /* switch */
 

source/ariba/overlay/BaseOverlay.h

@@ -420 +420 @@
         seqnum_t sendMessage( Message* message, const LinkDescriptor* ld );
 
+        LinkDescriptor* getSendDescriptor( const NodeID& nodeid );
+
         /// routes a message over the overlay or directly sends it when a link is open
         seqnum_t sendOverlay( Message* message, const NodeID& nodeid );