Reapply the packet optimization patch, with changes

1 files changed, 24 insertions, 34 deletions

diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLPacketHandler.cs b/OpenSim/Region/ClientStack/LindenUDP/LLPacketHandler.cs
index 5f26469..89f3339 100644
--- a/OpenSim/Region/ClientStack/LindenUDP/LLPacketHandler.cs
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLPacketHandler.cs
@@ -99,26 +99,8 @@ namespace OpenSim.Region.ClientStack.LindenUDP
         //
         private Dictionary<uint, uint> m_PendingAcks = new Dictionary<uint, uint>();
 
-        // Dictionary of the packets that need acks from the client.
-        //
-        private class AckData
-        {
-            public AckData(Packet packet, Object identifier, int tickCount, int resends)
-            {
-                Packet = packet;
-                Identifier = identifier;
-                TickCount = tickCount;
-                Resends = resends;
-            }
-
-            public Packet Packet;
-            public Object Identifier;
-            public int TickCount;
-            public int Resends;
-        }
-
-        private Dictionary<uint, AckData> m_NeedAck =
-                new Dictionary<uint, AckData>();
+        private Dictionary<uint, LLQueItem> m_NeedAck =
+                new Dictionary<uint, LLQueItem>();
 
         /// <summary>
         /// The number of milliseconds that can pass before a packet that needs an ack is resent.
@@ -314,6 +296,8 @@ namespace OpenSim.Region.ClientStack.LindenUDP
             item.throttleType = throttlePacketType;
             item.TickCount = System.Environment.TickCount;
             item.Identifier = id;
+            item.Resends = 0;
+            item.Length = packet.ToBytes().Length;
 
             m_PacketQueue.Enqueue(item);
             m_PacketsSent++;
@@ -333,7 +317,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
                 if (m_DropSafeTimeout > now ||
                         intervalMs > 500) // We were frozen!
                 {
-                    foreach (AckData data in new List<AckData>
+                    foreach (LLQueItem data in new List<LLQueItem>
                             (m_NeedAck.Values))
                     {
                         if (m_DropSafeTimeout > now)
@@ -364,7 +348,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
 
                 int resent = 0;
 
-                foreach (AckData data in new List<AckData>(m_NeedAck.Values))
+                foreach (LLQueItem data in new List<LLQueItem>(m_NeedAck.Values))
                 {
                     Packet packet = data.Packet;
 
@@ -630,7 +614,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
 
         private void ProcessAck(uint id)
         {
-            AckData data;
+            LLQueItem data;
             Packet packet;
 
             lock (m_NeedAck)
@@ -640,11 +624,9 @@ namespace OpenSim.Region.ClientStack.LindenUDP
                 if (!m_NeedAck.TryGetValue(id, out data))
                     return;
 
-                packet = data.Packet;
-
                 m_NeedAck.Remove(id);
-                m_UnackedBytes -= packet.ToBytes().Length;
                 PacketPool.Instance.ReturnPacket(data.Packet);
+                m_UnackedBytes -= data.Length;
             }
         }
 
@@ -697,7 +679,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
         public void SetClientInfo(ClientInfo info)
         {
             m_PendingAcks = info.pendingAcks;
-            m_NeedAck = new Dictionary<uint, AckData>();
+            m_NeedAck = new Dictionary<uint, LLQueItem>();
 
             Packet packet = null;
             int packetEnd = 0;
@@ -716,7 +698,15 @@ namespace OpenSim.Region.ClientStack.LindenUDP
                 {
                 }
 
-                m_NeedAck.Add(key, new AckData(packet, null, System.Environment.TickCount, 0));
+                LLQueItem item = new LLQueItem();
+                item.Packet = packet;
+                item.Incoming = false;
+                item.throttleType = 0;
+                item.TickCount = System.Environment.TickCount;
+                item.Identifier = 0;
+                item.Resends = 0;
+                item.Length = packet.ToBytes().Length;
+                m_NeedAck.Add(key, item);
             }
 
             m_Sequence = info.sequence;
@@ -740,7 +730,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
 
         private void DropResend(Object id)
         {
-            foreach (AckData data in new List<AckData>(m_NeedAck.Values))
+            foreach (LLQueItem data in new List<LLQueItem>(m_NeedAck.Values))
             {
                 if (data.Identifier != null && data.Identifier == id)
                 {
@@ -777,12 +767,12 @@ namespace OpenSim.Region.ClientStack.LindenUDP
                     // We want to see that packet arrive if it's reliable
                     if (packet.Header.Reliable)
                     {
-                        m_UnackedBytes += packet.ToBytes().Length;
+                        m_UnackedBytes += item.Length;
 
                         // Keep track of when this packet was sent out
-                        m_NeedAck[packet.Header.Sequence] = new AckData(packet,
-                                item.Identifier, System.Environment.TickCount,
-                                0);
+                        item.TickCount = System.Environment.TickCount;
+
+                        m_NeedAck[packet.Header.Sequence] = item;
                     }
                 }
             }
@@ -792,7 +782,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP
                 Abort();
 
             // Actually make the byte array and send it
-            byte[] sendbuffer = packet.ToBytes();
+            byte[] sendbuffer = item.Packet.ToBytes();
 
             //m_log.DebugFormat(
             //    "[CLIENT]: In {0} sending packet {1}",