diff options
Diffstat (limited to '')
-rw-r--r-- | OpenSim/Region/ClientStack/ClientView.cs | 60 |
1 files changed, 32 insertions, 28 deletions
diff --git a/OpenSim/Region/ClientStack/ClientView.cs b/OpenSim/Region/ClientStack/ClientView.cs index 58cb9a2..7161942 100644 --- a/OpenSim/Region/ClientStack/ClientView.cs +++ b/OpenSim/Region/ClientStack/ClientView.cs | |||
@@ -2217,44 +2217,48 @@ namespace OpenSim.Region.ClientStack | |||
2217 | public virtual void InPacket(Packet NewPack) | 2217 | public virtual void InPacket(Packet NewPack) |
2218 | { | 2218 | { |
2219 | // Handle appended ACKs | 2219 | // Handle appended ACKs |
2220 | if (NewPack.Header.AppendedAcks) | 2220 | if (NewPack != null) |
2221 | { | 2221 | { |
2222 | lock (m_needAck) | 2222 | if (NewPack.Header.AppendedAcks) |
2223 | { | 2223 | { |
2224 | foreach (uint ack in NewPack.Header.AckList) | 2224 | lock (m_needAck) |
2225 | { | 2225 | { |
2226 | m_needAck.Remove(ack); | 2226 | foreach (uint ack in NewPack.Header.AckList) |
2227 | { | ||
2228 | m_needAck.Remove(ack); | ||
2229 | } | ||
2227 | } | 2230 | } |
2228 | } | 2231 | } |
2229 | } | 2232 | |
2230 | |||
2231 | // Handle PacketAck packets | ||
2232 | if (NewPack.Type == PacketType.PacketAck) | ||
2233 | { | ||
2234 | PacketAckPacket ackPacket = (PacketAckPacket) NewPack; | ||
2235 | 2233 | ||
2236 | lock (m_needAck) | 2234 | // Handle PacketAck packets |
2235 | if (NewPack.Type == PacketType.PacketAck) | ||
2237 | { | 2236 | { |
2238 | foreach (PacketAckPacket.PacketsBlock block in ackPacket.Packets) | 2237 | PacketAckPacket ackPacket = (PacketAckPacket) NewPack; |
2238 | |||
2239 | lock (m_needAck) | ||
2239 | { | 2240 | { |
2240 | m_needAck.Remove(block.ID); | 2241 | foreach (PacketAckPacket.PacketsBlock block in ackPacket.Packets) |
2242 | { | ||
2243 | m_needAck.Remove(block.ID); | ||
2244 | } | ||
2241 | } | 2245 | } |
2242 | } | 2246 | } |
2243 | } | 2247 | else if ((NewPack.Type == PacketType.StartPingCheck)) |
2244 | else if ((NewPack.Type == PacketType.StartPingCheck)) | 2248 | { |
2245 | { | 2249 | //reply to pingcheck |
2246 | //reply to pingcheck | 2250 | StartPingCheckPacket startPing = (StartPingCheckPacket) NewPack; |
2247 | StartPingCheckPacket startPing = (StartPingCheckPacket) NewPack; | 2251 | CompletePingCheckPacket endPing = new CompletePingCheckPacket(); |
2248 | CompletePingCheckPacket endPing = new CompletePingCheckPacket(); | 2252 | endPing.PingID.PingID = startPing.PingID.PingID; |
2249 | endPing.PingID.PingID = startPing.PingID.PingID; | 2253 | OutPacket(endPing, ThrottleOutPacketType.Task); |
2250 | OutPacket(endPing, ThrottleOutPacketType.Task); | 2254 | } |
2251 | } | 2255 | else |
2252 | else | 2256 | { |
2253 | { | 2257 | QueItem item = new QueItem(); |
2254 | QueItem item = new QueItem(); | 2258 | item.Packet = NewPack; |
2255 | item.Packet = NewPack; | 2259 | item.Incoming = true; |
2256 | item.Incoming = true; | 2260 | m_packetQueue.Enqueue(item); |
2257 | m_packetQueue.Enqueue(item); | 2261 | } |
2258 | } | 2262 | } |
2259 | } | 2263 | } |
2260 | 2264 | ||