peer discovery: re-publish and re-discover immediately when a node di…

…sconnects, instead of on the connectivityChanged signal.
savoirfairelinux · Jun 21, 2024 · 47724bb · 47724bb
1 parent 313b69d
commit 47724bb
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/src/dhtrunner.cpp b/src/dhtrunner.cpp
@@ -264,6 +264,13 @@ DhtRunner::run(const Config& config, Context&& context)
                 }
             }
         }
+        if (config.peer_discovery && config.peer_publish) {
+            context.statusChangedCallback = [this](NodeStatus status4, NodeStatus status6) {
+                if (status4 == NodeStatus::Disconnected && status6 == NodeStatus::Disconnected) {
+                    peerDiscovery_->connectivityChanged();
+                }
+            };
+        }
 #endif
     }
 }
@@ -1039,10 +1046,6 @@ DhtRunner::connectivityChanged()
     std::lock_guard<std::mutex> lck(storage_mtx);
     pending_ops_prio.emplace([=](SecureDht& dht) {
         dht.connectivityChanged();
-#ifdef OPENDHT_PEER_DISCOVERY
-        if (peerDiscovery_)
-            peerDiscovery_->connectivityChanged();
-#endif
     });
     cv.notify_all();
 }