|
|
@ -130,7 +130,8 @@ namespace data |
|
|
|
I2NPMessage * msg = m_Queue.GetNextWithTimeout (15000); // 15 sec
|
|
|
|
I2NPMessage * msg = m_Queue.GetNextWithTimeout (15000); // 15 sec
|
|
|
|
if (msg) |
|
|
|
if (msg) |
|
|
|
{ |
|
|
|
{ |
|
|
|
while (msg) |
|
|
|
int numMsgs = 0; |
|
|
|
|
|
|
|
while (msg && numMsgs < 500) |
|
|
|
{ |
|
|
|
{ |
|
|
|
switch (msg->GetTypeID ()) |
|
|
|
switch (msg->GetTypeID ()) |
|
|
|
{ |
|
|
|
{ |
|
|
@ -151,9 +152,9 @@ namespace data |
|
|
|
i2p::HandleI2NPMessage (msg); |
|
|
|
i2p::HandleI2NPMessage (msg); |
|
|
|
} |
|
|
|
} |
|
|
|
msg = m_Queue.Get (); |
|
|
|
msg = m_Queue.Get (); |
|
|
|
|
|
|
|
numMsgs++; |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
else |
|
|
|
|
|
|
|
if (!m_IsRunning) break; |
|
|
|
if (!m_IsRunning) break; |
|
|
|
|
|
|
|
|
|
|
|
uint64_t ts = i2p::util::GetSecondsSinceEpoch (); |
|
|
|
uint64_t ts = i2p::util::GetSecondsSinceEpoch (); |
|
|
|