From 0ca782ed717bc8ad631efd4bf252c1b78894b72b Mon Sep 17 00:00:00 2001
From: orignal <i2porignal@yandex.ru>
Date: Tue, 30 Jan 2024 18:02:14 -0500
Subject: [PATCH] drop unsent messages if session disconnects

---
 libi2pd/NTCP2.cpp       | 2 ++
 libi2pd/SSU2Session.cpp | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/libi2pd/NTCP2.cpp b/libi2pd/NTCP2.cpp
index ad8ef51d..6fe88509 100644
--- a/libi2pd/NTCP2.cpp
+++ b/libi2pd/NTCP2.cpp
@@ -373,6 +373,8 @@ namespace transport
 			m_Socket.close ();
 			transports.PeerDisconnected (shared_from_this ());
 			m_Server.RemoveNTCP2Session (shared_from_this ());
+			for (auto& it: m_SendQueue)
+				it->Drop ();
 			m_SendQueue.clear ();
 			SetSendQueueSize (0);
 			auto remoteIdentity = GetRemoteIdentity ();
diff --git a/libi2pd/SSU2Session.cpp b/libi2pd/SSU2Session.cpp
index fa6d9eca..9180ccc8 100644
--- a/libi2pd/SSU2Session.cpp
+++ b/libi2pd/SSU2Session.cpp
@@ -262,6 +262,8 @@ namespace transport
 			m_SentHandshakePacket.reset (nullptr);
 			m_SessionConfirmedFragment.reset (nullptr);
 			m_PathChallenge.reset (nullptr);
+			for (auto& it: m_SendQueue)
+				it->Drop ();
 			m_SendQueue.clear ();
 			SetSendQueueSize (0);
 			m_SentPackets.clear ();