From d01f3b094bceb641ee523bfd42aff286d45da5a1 Mon Sep 17 00:00:00 2001 From: orignal Date: Tue, 10 Feb 2015 09:30:48 -0500 Subject: [PATCH] allow netDb cleanup after every 500 messages --- NetDb.cpp | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/NetDb.cpp b/NetDb.cpp index 703155ef..2f659e07 100644 --- a/NetDb.cpp +++ b/NetDb.cpp @@ -130,7 +130,8 @@ namespace data I2NPMessage * msg = m_Queue.GetNextWithTimeout (15000); // 15 sec if (msg) { - while (msg) + int numMsgs = 0; + while (msg && numMsgs < 500) { switch (msg->GetTypeID ()) { @@ -151,10 +152,10 @@ namespace data i2p::HandleI2NPMessage (msg); } msg = m_Queue.Get (); + numMsgs++; } - } - else - if (!m_IsRunning) break; + } + if (!m_IsRunning) break; uint64_t ts = i2p::util::GetSecondsSinceEpoch (); if (ts - lastManageRequest >= 15) // manage requests every 15 seconds