From ab77bf98ee320835e5dc50ed9b013442221f96e8 Mon Sep 17 00:00:00 2001 From: Loic Blot Date: Tue, 31 Mar 2015 09:22:44 +0200 Subject: [PATCH] RunCommandQueues: little optimization remove command from queue on success, else do nothing, instead of remove command from queue and push it front on success --- src/network/connection.cpp | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/src/network/connection.cpp b/src/network/connection.cpp index 5ea739dd4..b808c3ab6 100644 --- a/src/network/connection.cpp +++ b/src/network/connection.cpp @@ -1190,15 +1190,18 @@ void UDPPeer::RunCommandQueues( (commands_processed < maxcommands)) { try { ConnectionCommand c = channels[i].queued_commands.front(); - channels[i].queued_commands.pop_front(); - LOG(dout_con<getDesc() - <<" processing queued reliable command "<getDesc() + + LOG(dout_con << m_connection->getDesc() + << " processing queued reliable command " << std::endl); + + // Packet is processed, remove it from queue + if (processReliableSendCommand(c,max_packet_size)) { + channels[i].queued_commands.pop_front(); + } else { + LOG(dout_con << m_connection->getDesc() << " Failed to queue packets for peer_id: " << c.peer_id << ", delaying sending of " << c.data.getSize() << " bytes" << std::endl); - channels[i].queued_commands.push_front(c); } } catch (ItemNotFoundException &e) {