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

pause between stop and deletion of torrents tunnel

Browse Source
This commit is contained in:
orignal
2026-09-13 08:04:39 -04:00
parent 1d96c2ac69
commit d7e3750fd3
2 changed files with 18 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd_client/ClientContext.cpp
+17 -14
View File
@@ -170,19 +170,6 @@ namespace client
}
m_ServerTunnels.clear ();
#ifndef NO_TORRENTS
// start torrents RPC server
for (auto& it: m_TorrentsRPCServers)
it.second->Stop ();
for (auto& it: m_TorrentsTunnels)
{
LogPrint(eLogInfo, "Clients: Stopping torrents tunnel");
it.second->Stop ();
}
m_TorrentsTunnels.clear ();
#endif
if (m_SamBridge)
{
LogPrint(eLogInfo, "Clients: Stopping SAM bridge");
@@ -217,10 +204,26 @@ namespace client
m_ClientForwards.clear();
}
#ifndef NO_TORRENTS
// start torrents RPC server
for (auto& it: m_TorrentsRPCServers)
it.second->Stop ();
for (auto& it: m_TorrentsTunnels)
{
// let tunnels finish
LogPrint(eLogInfo, "Clients: Stopping torrents tunnel");
it.second->Stop ();
}
if (!m_TorrentsTunnels.empty ())
{
// let torrent tunnels finish
LogPrint(eLogInfo, "Clients: Waiting for ", STOP_DESTINATIONS_TIMEOUT, "seconds");
std::this_thread::sleep_for (std::chrono::seconds (STOP_DESTINATIONS_TIMEOUT));
}
m_TorrentsTunnels.clear ();
#endif
{
// stop destinations
LogPrint(eLogInfo, "Clients: Stopping Destinations");
std::lock_guard<std::mutex> lock(m_DestinationsMutex);