PurpleI2P/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2025-01-22 08:14:15 +00:00
Code Issues Releases Activity

close stream if delete requested

Browse Source
This commit is contained in:
orignal 2022-05-08 11:49:11 -04:00
parent bc8e4494c4
commit 714d1cc993
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
libi2pd/Streaming.cpp
View File

@ -1285,7 +1285,12 @@ namespace stream
auto it = m_Streams.find (recvStreamID); auto it = m_Streams.find (recvStreamID);
if (it == m_Streams.end ()) if (it == m_Streams.end ())
return false; return false;
DeleteStream (it->second); m_Owner->GetService ().post ([this, s = it->second]()
{
s->Close (); // try to send FIN
s->Terminate (false);
DeleteStream (s);
});
return true; return true;
} }