From c00eb8cf4456a9010557fefd2b985e2e6334ed61 Mon Sep 17 00:00:00 2001
From: orignal <i2porignal@yandex.ru>
Date: Wed, 22 May 2024 10:07:01 -0400
Subject: [PATCH] handle requests completions in netdb requests thread

---
 libi2pd/NetDbRequests.cpp | 41 +++++++++++++++++++++------------------
 1 file changed, 22 insertions(+), 19 deletions(-)

diff --git a/libi2pd/NetDbRequests.cpp b/libi2pd/NetDbRequests.cpp
index 4c6ed3fc..0ce6508d 100644
--- a/libi2pd/NetDbRequests.cpp
+++ b/libi2pd/NetDbRequests.cpp
@@ -173,25 +173,28 @@ namespace data
 
 	void NetDbRequests::RequestComplete (const IdentHash& ident, std::shared_ptr<RouterInfo> r)
 	{
-		std::shared_ptr<RequestedDestination> request;
-		{
-			std::unique_lock<std::mutex> l(m_RequestedDestinationsMutex);
-			auto it = m_RequestedDestinations.find (ident);
-			if (it != m_RequestedDestinations.end ())
-			{
-				request = it->second;
-				if (request->IsExploratory ())
-					m_RequestedDestinations.erase (it);
-				// otherwise cache for a while
-			}
-		}
-		if (request)
-		{
-			if (r)
-				request->Success (r);
-			else
-				request->Fail ();
-		}
+		GetIOService ().post ([this, ident, r]()
+			{                      
+				std::shared_ptr<RequestedDestination> request;
+				{
+					std::unique_lock<std::mutex> l(m_RequestedDestinationsMutex);
+					auto it = m_RequestedDestinations.find (ident);
+					if (it != m_RequestedDestinations.end ())
+					{
+						request = it->second;
+						if (request->IsExploratory ())
+							m_RequestedDestinations.erase (it);
+						// otherwise cache for a while
+					}
+				}
+				if (request)
+				{
+					if (r)
+						request->Success (r);
+					else
+						request->Fail ();
+				}
+			});
 	}
 
 	std::shared_ptr<RequestedDestination> NetDbRequests::FindRequest (const IdentHash& ident) const