dandri/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2026-09-17 01:34:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

use lock_guard for streams mutex

Browse Source
This commit is contained in:
PobreGato
2026-08-17 03:45:16 +03:00
parent a5ded7f5a3
commit d2a6ed9100
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd/Streaming.cpp
+4 -4
View File
@@ -2162,7 +2162,7 @@ namespace stream
m_PendingIncomingTimer.cancel ();
m_PendingIncomingStreams.clear ();
{
std::unique_lock<std::mutex> l(m_StreamsMutex);
std::lock_guard<std::mutex> l(m_StreamsMutex);
for (auto it: m_Streams)
it.second->Terminate (false); // we delete here
m_Streams.clear ();
@@ -2326,7 +2326,7 @@ namespace stream
std::shared_ptr<Stream> StreamingDestination::CreateNewOutgoingStream (std::shared_ptr<const i2p::data::LeaseSet> remote, int port)
{
auto s = std::make_shared<Stream> (m_Owner->GetService (), *this, remote, port);
std::unique_lock<std::mutex> l(m_StreamsMutex);
std::lock_guard<std::mutex> l(m_StreamsMutex);
m_Streams.emplace (s->GetRecvStreamID (), s);
return s;
}
@@ -2340,7 +2340,7 @@ namespace stream
std::shared_ptr<Stream> StreamingDestination::CreateNewIncomingStream (uint32_t receiveStreamID)
{
auto s = std::make_shared<Stream> (m_Owner->GetService (), *this);
std::unique_lock<std::mutex> l(m_StreamsMutex);
std::lock_guard<std::mutex> l(m_StreamsMutex);
m_Streams.emplace (s->GetRecvStreamID (), s);
m_IncomingStreams.emplace (receiveStreamID, s);
return s;
@@ -2350,7 +2350,7 @@ namespace stream
{
if (stream)
{
std::unique_lock<std::mutex> l(m_StreamsMutex);
std::lock_guard<std::mutex> l(m_StreamsMutex);
m_Streams.erase (stream->GetRecvStreamID ());
if (stream->IsIncoming ())
m_IncomingStreams.erase (stream->GetSendStreamID ());