File tree 1 file changed +9
-6
lines changed
1 file changed +9
-6
lines changed Original file line number Diff line number Diff line change @@ -1190,15 +1190,18 @@ void UDPPeer::RunCommandQueues(
1190
1190
(commands_processed < maxcommands)) {
1191
1191
try {
1192
1192
ConnectionCommand c = channels[i].queued_commands .front ();
1193
- channels[i].queued_commands .pop_front ();
1194
- LOG (dout_con<<m_connection->getDesc ()
1195
- <<" processing queued reliable command " <<std::endl);
1196
- if (!processReliableSendCommand (c,max_packet_size)) {
1197
- LOG (dout_con<<m_connection->getDesc ()
1193
+
1194
+ LOG (dout_con << m_connection->getDesc ()
1195
+ << " processing queued reliable command " << std::endl);
1196
+
1197
+ // Packet is processed, remove it from queue
1198
+ if (processReliableSendCommand (c,max_packet_size)) {
1199
+ channels[i].queued_commands .pop_front ();
1200
+ } else {
1201
+ LOG (dout_con << m_connection->getDesc ()
1198
1202
<< " Failed to queue packets for peer_id: " << c.peer_id
1199
1203
<< " , delaying sending of " << c.data .getSize ()
1200
1204
<< " bytes" << std::endl);
1201
- channels[i].queued_commands .push_front (c);
1202
1205
}
1203
1206
}
1204
1207
catch (ItemNotFoundException &e) {
You can’t perform that action at this time.
0 commit comments