dandri/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2026-10-20 14:32:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

return numHeardFrom and numFailedPeers in dht-stats response

Browse Source
This commit is contained in:
orignal
2026-10-11 11:26:47 -04:00
parent cbb5a924f2
commit 0800440a42
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd_client/TorrentsDHT.h
+2
View File
@@ -238,6 +238,8 @@ namespace torrents
size_t GetNumBuckets () const { return m_RoutingTable ? m_RoutingTable->GetNumBuckets () : 0; }
size_t GetNumNodes () const { return m_RoutingTable ? m_RoutingTable->GetNumNodes () : 0; }
size_t GetNumTorrents () const { return m_Torrents.size (); }
size_t GetNumHeardFrom () const { return m_HeardFrom.size (); }
size_t GetNumFailedPeers () const { return m_FailedPeers.size (); }
private:
libi2pd_client/TorrentsRPC.cpp
+6 -2
View File
@@ -776,9 +776,9 @@ namespace torrents
response["supported"] = isDHTSupported;
if (isDHTSupported)
{
size_t numNodes = 0, numBuckets = 0, numTorrents = 0;
size_t numNodes = 0, numBuckets = 0, numTorrents = 0, numHeardFrom = 0, numFailedPeers = 0;
boost::asio::post (m_Tunnel->GetService (),
boost::asio::use_future ([this, &numNodes, &numBuckets, &numTorrents]()
boost::asio::use_future ([this, &numNodes, &numBuckets, &numTorrents, &numHeardFrom, &numFailedPeers]()
{
const auto& dht = m_Tunnel->GetDHT ();
if (dht)
@@ -786,11 +786,15 @@ namespace torrents
numNodes = dht->GetNumNodes ();
numBuckets = dht->GetNumBuckets ();
numTorrents = dht->GetNumTorrents ();
numHeardFrom = dht->GetNumHeardFrom ();
numFailedPeers = dht->GetNumFailedPeers ();
}
})).wait ();
response["numNodes"] = numNodes;
response["numBuckets"] = numBuckets;
response["numTorrents"] = numTorrents;
response["numHeardFrom"] = numHeardFrom;
response["numFailedPeers"] = numFailedPeers;
}
return SuccessResponse (GetTag (jsonRequest), std::move (response));
}