diff --git a/llarp/router/outbound_message_handler.cpp b/llarp/router/outbound_message_handler.cpp index 9e2e1b640..4aede4147 100644 --- a/llarp/router/outbound_message_handler.cpp +++ b/llarp/router/outbound_message_handler.cpp @@ -278,14 +278,15 @@ namespace llarp } MessageQueue &path_queue = itr_pair.first->second; - /* - if(path_queue.size() >= MAX_PATH_QUEUE_SIZE) + + if(path_queue.size() < MAX_PATH_QUEUE_SIZE) + { + path_queue.push(std::move(entry)); + } + else { m_queueStats.dropped++; - path_queue.pop(); // head drop } - */ - path_queue.push(std::move(entry)); } }