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

notify keys pair supplier thread after mutex unlocked

Browse Source
This commit is contained in:
orignal
2026-05-23 19:21:27 -04:00
parent 6978027089
commit c8a4c1c34a
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd/Transports.cpp
+12 -7
View File
@@ -44,8 +44,9 @@ namespace transport
{
std::unique_lock<std::mutex> l(m_AcquiredMutex);
m_IsRunning = false;
m_Acquired.notify_one ();
}
m_Acquired.notify_one ();
if (m_Thread)
{
m_Thread->join ();
@@ -105,7 +106,7 @@ namespace transport
{
auto pair = m_KeysPool.AcquireSharedMt ();
pair->GenerateKeys ();
newKeys.push_back (pair);
newKeys.emplace_back (pair);
}
std::unique_lock<std::mutex> l(m_AcquiredMutex);
m_Queue.splice (m_Queue.end (), newKeys);
@@ -120,18 +121,22 @@ namespace transport
std::shared_ptr<i2p::crypto::X25519Keys> X25519KeysPairSupplier::Acquire ()
{
std::shared_ptr<i2p::crypto::X25519Keys> pair;
{
std::unique_lock<std::mutex> l(m_AcquiredMutex);
if (!m_Queue.empty ())
{
auto pair = m_Queue.front ();
pair = m_Queue.front ();
m_Queue.pop_front ();
m_Acquired.notify_one ();
return pair;
}
}
if (pair)
{
m_Acquired.notify_one ();
return pair;
}
// queue is empty, create new
auto pair = m_KeysPool.AcquireSharedMt ();
pair = m_KeysPool.AcquireSharedMt ();
pair->GenerateKeys ();
return pair;
}
@@ -142,7 +147,7 @@ namespace transport
{
std::unique_lock<std::mutex> l(m_AcquiredMutex);
if ((int)m_Queue.size () < 2*m_QueueSize)
m_Queue.push_back (pair);
m_Queue.emplace_back (pair);
}
else
LogPrint(eLogError, "Transports: Return null keys");