drop earlier if delayed queue is semi-full

PurpleI2P · Feb 1, 2024 · 8f28cee · 8f28cee
1 parent 96cf6ca
commit 8f28cee
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/libi2pd/Transports.cpp b/libi2pd/Transports.cpp
@@ -477,7 +477,10 @@ namespace transport
 					}	
 				}	
 				for (auto& it1: msgs)
-					it->second.delayedMessages.push_back (it1);
+					if (sz > MAX_NUM_DELAYED_MESSAGES/2 && it1->onDrop)
+						it1->Drop (); // drop earlier because we can handle it
+					else
+						it->second.delayedMessages.push_back (it1);
 			}
 			else
 			{