Skip to content
Snippets Groups Projects
Commit c6b4e317 authored by Adrien Béraud's avatar Adrien Béraud
Browse files

dhtrunner: only start peer discovery if proxy is disabled

parent 44267a72
No related branches found
No related tags found
No related merge requests found
......@@ -219,6 +219,7 @@ DhtRunner::run(const Config& config, Context&& context)
}
});
if (config.proxy_server.empty()) {
if (config.peer_discovery or config.peer_publish) {
#ifdef OPENDHT_PEER_DISCOVERY
peerDiscovery_ = context.peerDiscovery ?
......@@ -244,22 +245,25 @@ DhtRunner::run(const Config& config, Context&& context)
NodeInsertionPack adc;
adc.net = netId;
adc.nodeId = dht_->getNodeId();
if (auto socket = dht_->getSocket()) {
// IPv4
if (const auto& bound4 = dht_->getSocket()->getBoundRef(AF_INET)) {
if (const auto& bound4 = socket->getBoundRef(AF_INET)) {
adc.port = bound4.getPort();
msgpack::pack(sbuf_node, adc);
peerDiscovery_->startPublish(AF_INET, PEER_DISCOVERY_DHT_SERVICE, sbuf_node);
}
// IPv6
if (const auto& bound6 = dht_->getSocket()->getBoundRef(AF_INET6)) {
if (const auto& bound6 = socket->getBoundRef(AF_INET6)) {
adc.port = bound6.getPort();
sbuf_node.clear();
msgpack::pack(sbuf_node, adc);
peerDiscovery_->startPublish(AF_INET6, PEER_DISCOVERY_DHT_SERVICE, sbuf_node);
}
}
}
#endif
}
}
void
DhtRunner::shutdown(ShutdownCallback cb, bool stop) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment