diff options
Diffstat (limited to '')
-rw-r--r-- | OpenSim/Region/ClientStack/LindenUDP/UnackedPacketCollection.cs | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/OpenSim/Region/ClientStack/LindenUDP/UnackedPacketCollection.cs b/OpenSim/Region/ClientStack/LindenUDP/UnackedPacketCollection.cs index 12f0c0a..bd5fe1c 100644 --- a/OpenSim/Region/ClientStack/LindenUDP/UnackedPacketCollection.cs +++ b/OpenSim/Region/ClientStack/LindenUDP/UnackedPacketCollection.cs | |||
@@ -85,6 +85,8 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
85 | /// <param name="sequenceNumber">Sequence number of the packet to | 85 | /// <param name="sequenceNumber">Sequence number of the packet to |
86 | /// acknowledge</param> | 86 | /// acknowledge</param> |
87 | /// <param name="currentTime">Current value of Environment.TickCount</param> | 87 | /// <param name="currentTime">Current value of Environment.TickCount</param> |
88 | /// <remarks>This does not immediately acknowledge the packet, it only | ||
89 | /// queues the ack so it can be handled in a thread-safe way later</remarks> | ||
88 | public void Remove(uint sequenceNumber, int currentTime, bool fromResend) | 90 | public void Remove(uint sequenceNumber, int currentTime, bool fromResend) |
89 | { | 91 | { |
90 | m_pendingRemoves.Enqueue(new PendingAck(sequenceNumber, currentTime, fromResend)); | 92 | m_pendingRemoves.Enqueue(new PendingAck(sequenceNumber, currentTime, fromResend)); |
@@ -108,7 +110,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
108 | 110 | ||
109 | if (m_packets.Count > 0) | 111 | if (m_packets.Count > 0) |
110 | { | 112 | { |
111 | int now = Environment.TickCount; | 113 | int now = Environment.TickCount & Int32.MaxValue; |
112 | 114 | ||
113 | foreach (OutgoingPacket packet in m_packets.Values) | 115 | foreach (OutgoingPacket packet in m_packets.Values) |
114 | { | 116 | { |
@@ -123,10 +125,10 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
123 | expiredPackets = new List<OutgoingPacket>(); | 125 | expiredPackets = new List<OutgoingPacket>(); |
124 | expiredPackets.Add(packet); | 126 | expiredPackets.Add(packet); |
125 | } | 127 | } |
126 | else | 128 | /*else |
127 | { | 129 | { |
128 | break; | 130 | break; |
129 | } | 131 | }*/ |
130 | } | 132 | } |
131 | } | 133 | } |
132 | 134 | ||