PurpleI2P/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2025-02-10 02:24:14 +00:00
Code Issues Releases Activity

don't wait for completion explicitly

Browse Source
This commit is contained in:
orignal 2025-01-28 21:30:48 -05:00
parent 1bff42042d
commit 774c606b09
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
libi2pd/RouterContext.cpp
View File

@ -78,8 +78,8 @@ namespace i2p
m_Service->Stop (); m_Service->Stop ();
CleanUp (); // GarlicDestination CleanUp (); // GarlicDestination
} }
if (m_SavingRouterInfo.valid () && m_SavingRouterInfo.wait_for(std::chrono::seconds(0)) != std::future_status::ready) if (m_SavingRouterInfo.valid ())
m_SavingRouterInfo.wait (); m_SavingRouterInfo.get ();
} }
std::shared_ptr<i2p::data::RouterInfo::Buffer> RouterContext::CopyRouterInfoBuffer () const std::shared_ptr<i2p::data::RouterInfo::Buffer> RouterContext::CopyRouterInfoBuffer () const
@ -265,12 +265,7 @@ namespace i2p
m_LastUpdateTime = i2p::util::GetSecondsSinceEpoch (); m_LastUpdateTime = i2p::util::GetSecondsSinceEpoch ();
// defer saving buffer to disk // defer saving buffer to disk
if (m_SavingRouterInfo.valid ()) if (m_SavingRouterInfo.valid ())
{
if (m_SavingRouterInfo.wait_for(std::chrono::seconds(0)) != std::future_status::ready)
// wait until previous update complete
m_SavingRouterInfo.wait ();
m_SavingRouterInfo.get (); m_SavingRouterInfo.get ();
}
m_SavingRouterInfo = std::async (std::launch::async, m_SavingRouterInfo = std::async (std::launch::async,
[buffer = std::move(buffer)]() [buffer = std::move(buffer)]()
{ {