Changeset 6961 for source/ariba/overlay/BaseOverlay.cpp

Timestamp:

Nov 18, 2009, 9:44:28 PM (14 years ago)

Author:

mies

Message:

 

File:

• source/ariba/overlay/BaseOverlay.cpp (modified) (4 diffs)

source/ariba/overlay/BaseOverlay.cpp

@@ -360 +360 @@
                 if (!ld->up) continue;
 
+                // check if link is relayed and retry connecting directly
+                if ( ld->relayed && ld->retryCounter > 0) {
+                        ld->retryCounter--;
+                        ld->communicationId = bc->establishLink( ld->endpoint );
+                }
+
                 // remote used as relay flag
                 if ( ld->relaying && difftime( now, ld->timeRelaying ) > 10)
@@ -756 +762 @@
                         sideport(&SideportListener::DEFAULT), overlayInterface(NULL),
                         counter(0) {
-        dht = new DHT();
-        localDHT = new DHT();
+        initDHT();
 }
 
 BaseOverlay::~BaseOverlay() {
-        delete dht;
+        destroyDHT();
 }
 
@@ -1755 +1760 @@
 
         // try to replace relay link with direct link
-        ldn->communicationId =
-                        bc->establishLink( overlayMsg->getSourceEndpoint() );
+        ldn->retryCounter = 3;
+        ldn->endpoint = overlayMsg->getSourceEndpoint();
+        ldn->communicationId =  bc->establishLink( ldn->endpoint );
 
         return true;
@@ -2096 +2102 @@
 // ----------------------------------------------------------------------------
 
+void BaseOverlay::initDHT() {
+        dht = new DHT();
+        localDHT = new DHT();
+        republishCounter = 0;
+}
+
+void BaseOverlay::destroyDHT() {
+        delete dht;
+        delete localDHT;
+}
+
 /// stabilize DHT state
 void BaseOverlay::stabilizeDHT() {
+
+        // do not refresh every second
+        if (republishCounter < 2) {
+                republishCounter++;
+                return;
+        }
+        republishCounter = 0;
+
         // remove old values from DHT
         BOOST_FOREACH( DHTEntry& entry, dht->entries ) {