aboutsummaryrefslogtreecommitdiffstatshomepage
diff options
context:
space:
mode:
-rw-r--r--OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs16
1 files changed, 8 insertions, 8 deletions
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs b/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs
index 20f0410..2d58b94 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs
@@ -468,7 +468,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
468 for (int i = 0; i < THROTTLE_CATEGORY_COUNT; i++) 468 for (int i = 0; i < THROTTLE_CATEGORY_COUNT; i++)
469 { 469 {
470 bucket = m_throttleCategories[i]; 470 bucket = m_throttleCategories[i];
471 if (m_udpServer.EmergencyMonitoring && i == 4) 471 if (i == 4)
472 queueDebugOutput += m_packetOutboxes[i].Count + " "; // Serious debug business 472 queueDebugOutput += m_packetOutboxes[i].Count + " "; // Serious debug business
473 473
474 if (m_nextPackets[i] != null) 474 if (m_nextPackets[i] != null)
@@ -477,17 +477,17 @@ namespace OpenSim.Region.ClientStack.LindenUDP
477 // leaving a dequeued packet still waiting to be sent out. Try to 477 // leaving a dequeued packet still waiting to be sent out. Try to
478 // send it again 478 // send it again
479 OutgoingPacket nextPacket = m_nextPackets[i]; 479 OutgoingPacket nextPacket = m_nextPackets[i];
480 if (m_udpServer.EmergencyMonitoring && i == 4) queueDebugOutput += "m_nextPackets[i] != null, " + nextPacket.Buffer.DataLength; 480 if (i == 4) queueDebugOutput += "m_nextPackets[i] != null, " + nextPacket.Buffer.DataLength;
481 if (bucket.RemoveTokens(nextPacket.Buffer.DataLength)) 481 if (bucket.RemoveTokens(nextPacket.Buffer.DataLength))
482 { 482 {
483 if (m_udpServer.EmergencyMonitoring && i == 4) queueDebugOutput += " removed tokens "; 483 if (i == 4) queueDebugOutput += " removed tokens ";
484 // Send the packet 484 // Send the packet
485 m_udpServer.SendPacketFinal(nextPacket); 485 m_udpServer.SendPacketFinal(nextPacket);
486 m_nextPackets[i] = null; 486 m_nextPackets[i] = null;
487 packetSent = true; 487 packetSent = true;
488 } 488 }
489 else 489 else
490 if (m_udpServer.EmergencyMonitoring && i == 4) queueDebugOutput += " did not remove tokens "; 490 if (i == 4) queueDebugOutput += " did not remove tokens ";
491 } 491 }
492 else 492 else
493 { 493 {
@@ -496,7 +496,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
496 queue = m_packetOutboxes[i]; 496 queue = m_packetOutboxes[i];
497 if (queue.Dequeue(out packet)) 497 if (queue.Dequeue(out packet))
498 { 498 {
499 if (m_udpServer.EmergencyMonitoring && i == 4) queueDebugOutput += "m_nextPackets[i] == null, dq ok " + packet.Buffer.DataLength; 499 if (i == 4) queueDebugOutput += "m_nextPackets[i] == null, dq ok " + packet.Buffer.DataLength;
500 // A packet was pulled off the queue. See if we have 500 // A packet was pulled off the queue. See if we have
501 // enough tokens in the bucket to send it out 501 // enough tokens in the bucket to send it out
502 if (bucket.RemoveTokens(packet.Buffer.DataLength)) 502 if (bucket.RemoveTokens(packet.Buffer.DataLength))
@@ -504,13 +504,13 @@ namespace OpenSim.Region.ClientStack.LindenUDP
504 // Send the packet 504 // Send the packet
505 m_udpServer.SendPacketFinal(packet); 505 m_udpServer.SendPacketFinal(packet);
506 packetSent = true; 506 packetSent = true;
507 if (m_udpServer.EmergencyMonitoring && i == 4) queueDebugOutput += " removed tokens "; 507 if (i == 4) queueDebugOutput += " removed tokens ";
508 } 508 }
509 else 509 else
510 { 510 {
511 // Save the dequeued packet for the next iteration 511 // Save the dequeued packet for the next iteration
512 m_nextPackets[i] = packet; 512 m_nextPackets[i] = packet;
513 if (m_udpServer.EmergencyMonitoring && i == 4) queueDebugOutput += " did not remove tokens "; 513 if (i == 4) queueDebugOutput += " did not remove tokens ";
514 } 514 }
515 515
516 // If the queue is empty after this dequeue, fire the queue 516 // If the queue is empty after this dequeue, fire the queue
@@ -521,7 +521,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
521 } 521 }
522 else 522 else
523 { 523 {
524 if (m_udpServer.EmergencyMonitoring && i == 4) queueDebugOutput += "m_nextPackets[i] == null, dq nok "; 524 if (i == 4) queueDebugOutput += "m_nextPackets[i] == null, dq nok ";
525 // No packets in this queue. Fire the queue empty callback 525 // No packets in this queue. Fire the queue empty callback
526 // if it has not been called recently 526 // if it has not been called recently
527 emptyCategories |= CategoryToFlag(i); 527 emptyCategories |= CategoryToFlag(i);