aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs10
1 files changed, 10 insertions, 0 deletions
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs b/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs
index 7be8a0a..01d7122 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs
@@ -153,6 +153,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
153 153
154 private int m_defaultRTO = 1000; // 1sec is the recommendation in the RFC 154 private int m_defaultRTO = 1000; // 1sec is the recommendation in the RFC
155 private int m_maxRTO = 60000; 155 private int m_maxRTO = 60000;
156 public bool m_deliverPackets = true;
156 157
157 /// <summary> 158 /// <summary>
158 /// Default constructor 159 /// Default constructor
@@ -438,6 +439,13 @@ namespace OpenSim.Region.ClientStack.LindenUDP
438 if (category >= 0 && category < m_packetOutboxes.Length) 439 if (category >= 0 && category < m_packetOutboxes.Length)
439 { 440 {
440 OpenSim.Framework.LocklessQueue<OutgoingPacket> queue = m_packetOutboxes[category]; 441 OpenSim.Framework.LocklessQueue<OutgoingPacket> queue = m_packetOutboxes[category];
442
443 if (m_deliverPackets == false)
444 {
445 queue.Enqueue(packet);
446 return true;
447 }
448
441 TokenBucket bucket = m_throttleCategories[category]; 449 TokenBucket bucket = m_throttleCategories[category];
442 450
443 // Don't send this packet if there is already a packet waiting in the queue 451 // Don't send this packet if there is already a packet waiting in the queue
@@ -487,6 +495,8 @@ namespace OpenSim.Region.ClientStack.LindenUDP
487 /// <returns>True if any packets were sent, otherwise false</returns> 495 /// <returns>True if any packets were sent, otherwise false</returns>
488 public bool DequeueOutgoing() 496 public bool DequeueOutgoing()
489 { 497 {
498 if (m_deliverPackets == false) return false;
499
490 OutgoingPacket packet; 500 OutgoingPacket packet;
491 OpenSim.Framework.LocklessQueue<OutgoingPacket> queue; 501 OpenSim.Framework.LocklessQueue<OutgoingPacket> queue;
492 TokenBucket bucket; 502 TokenBucket bucket;