diff options
Diffstat (limited to '')
-rw-r--r-- | OpenSim/Region/ClientStack/LindenUDP/LLUDPClient.cs | 10 |
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; |