dandri/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2026-08-29 05:28:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

let pending operations complete when stream received FIN

Browse Source
This commit is contained in:
orignal
2026-07-28 21:47:03 -04:00
parent c49ca9cbdd
commit e6088eb30f
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd/Streaming.cpp
+2 -2
View File
@@ -177,11 +177,11 @@ namespace stream
void Stream::Terminate (bool deleteFromDestination) // should be called from StreamingDestination::Stop only
{
m_Status = eStreamStatusTerminated;
m_AckSendTimer.cancel ();
m_ReceiveTimer.cancel ();
m_ResendTimer.cancel ();
m_SendTimer.cancel ();
m_Status = eStreamStatusTerminated;
//CleanUp (); /* Need to recheck - broke working on windows */
if (deleteFromDestination)
m_LocalDestination.DeleteStream (shared_from_this ());
@@ -442,7 +442,7 @@ namespace stream
if (m_Status != eStreamStatusClosed)
SendClose ();
m_Status = eStreamStatusClosed;
Terminate ();
boost::asio::post (GetService (), std::bind (&Stream::Terminate, shared_from_this (), true));
}
}