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

cleanup terminated sessions

Browse Source
This commit is contained in:
orignal 2022-06-26 21:35:26 -04:00
parent b5d139f7b2
commit a99fcfe54f
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
libi2pd/SSU2.cpp
View File

@ -376,6 +376,9 @@ namespace transport
m_LastSession->SetRemoteEndpoint (senderEndpoint); m_LastSession->SetRemoteEndpoint (senderEndpoint);
m_LastSession->ProcessPeerTest (buf, len); m_LastSession->ProcessPeerTest (buf, len);
break; break;
case eSSU2SessionStateTerminated:
m_LastSession = nullptr;
break;
default: default:
LogPrint (eLogWarning, "SSU2: Invalid session state ", (int)m_LastSession->GetState ()); LogPrint (eLogWarning, "SSU2: Invalid session state ", (int)m_LastSession->GetState ());
} }
@ -608,7 +611,8 @@ namespace transport
for (auto it = m_Sessions.begin (); it != m_Sessions.end ();) for (auto it = m_Sessions.begin (); it != m_Sessions.end ();)
{ {
if (it->second->IsTerminationTimeoutExpired (ts)) if (it->second->GetState () == eSSU2SessionStateTerminated ||
it->second->IsTerminationTimeoutExpired (ts))
{ {
if (it->second->IsEstablished ()) if (it->second->IsEstablished ())
it->second->TerminateByTimeout (); it->second->TerminateByTimeout ();