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

Merge pull request #2564 from pobregat0/close-on-service

Browse Source 
call SendClose and Terminate through the service in Close
This commit is contained in:
orignal
2026-09-18 22:26:32 -04:00
committed by GitHub
parent 007d7a4357 68a4f90fa9
commit aa95047afc
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd/Streaming.cpp
+3 -3
View File
@@ -1403,19 +1403,19 @@ namespace stream
break;
case eStreamStatusReset:
// TODO: send reset
Terminate ();
boost::asio::post (GetService (), std::bind (&Stream::Terminate, shared_from_this (), true));
break;
case eStreamStatusClosing:
if (m_SentPackets.empty () && m_SendBuffer.IsEmpty ()) // nothing to send
{
m_Status = eStreamStatusClosed;
SendClose();
boost::asio::post (GetService (), std::bind (&Stream::SendClose, shared_from_this ()));
}
break;
case eStreamStatusClosed:
case eStreamStatusNew:
// already closed
Terminate ();
boost::asio::post (GetService (), std::bind (&Stream::Terminate, shared_from_this (), true));
break;
default:
LogPrint (eLogWarning, "Streaming: Unexpected stream status=", (int)m_Status, " for sSID=", m_SendStreamID);