mirrors/opendht
1
0 Fork 0
mirror of https://github.com/savoirfairelinux/opendht.git synced 2026-11-08 04:21:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

dhtrunner: add async/non-blocking version of getNodeInfo

Browse Source
This commit is contained in:
Adrien Béraud committed 2020-01-16 13:24:37 -05:00
1 parent 91e1e942ab
commit 7f1d960a56
3 files changed
+28 -7
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

src/dht_proxy_server.cpp
+8 -7
View File
@@ -378,13 +378,14 @@ DhtProxyServer::handlePrintStats(const asio::error_code &ec)
if (auto dht = dht_) {
// Refresh stats cache
auto newInfo = std::make_shared<NodeInfo>(dht->getNodeInfo());
stats_ = updateStats(newInfo);
nodeInfo_ = newInfo;
auto json = newInfo->toJson();
auto str = Json::writeString(jsonBuilder_, json);
if (logger_)
logger_->d("[proxy:server] [stats] %s", str.c_str());
dht->getNodeInfo([this](std::shared_ptr<NodeInfo> newInfo){
stats_ = updateStats(newInfo);
nodeInfo_ = newInfo;
if (logger_) {
auto str = Json::writeString(jsonBuilder_, newInfo->toJson());
logger_->d("[proxy:server] [stats] %s", str.c_str());
}
});
}
printStatsTimer_->expires_at(printStatsTimer_->expiry() + PRINT_STATS_PERIOD);
printStatsTimer_->async_wait(std::bind(&DhtProxyServer::handlePrintStats, this, std::placeholders::_1));