* Refactored IClientAPI.OutPacket to require a second mandatory parameter. This parameter has an enum:int ThrottleOutPacketType and contains types; Resend, Land, Wind, Cloud, Task, Texture, and Asset.

4 files changed, 23 insertions, 13 deletions

diff --git a/OpenSim/Framework/ClientManager.cs b/OpenSim/Framework/ClientManager.cs
index e34c051..629aab5 100644
--- a/OpenSim/Framework/ClientManager.cs
+++ b/OpenSim/Framework/ClientManager.cs
@@ -122,7 +122,7 @@ namespace OpenSim.Framework
                 {
                     packet.AgentData.AgentID = client.AgentId;
                     packet.AgentData.SessionID = client.SessionId;
-                    client.OutPacket(packet);
+                    client.OutPacket(packet,ThrottleOutPacketType.Task);
                 }
             }
         }
diff --git a/OpenSim/Framework/Communications/Cache/AssetCache.cs b/OpenSim/Framework/Communications/Cache/AssetCache.cs
index 99041c1..edca142 100644
--- a/OpenSim/Framework/Communications/Cache/AssetCache.cs
+++ b/OpenSim/Framework/Communications/Cache/AssetCache.cs
@@ -520,7 +520,7 @@ namespace OpenSim.Framework.Communications.Cache
                 }
                 Transfer.TransferInfo.Size = (int) req.AssetInf.Data.Length;
                 Transfer.TransferInfo.TransferID = req.TransferRequestID;
-                req.RequestUser.OutPacket(Transfer);
+                req.RequestUser.OutPacket(Transfer,ThrottleOutPacketType.Asset);
 
                 if (req.NumPackets == 1)
                 {
@@ -530,7 +530,7 @@ namespace OpenSim.Framework.Communications.Cache
                     TransferPacket.TransferData.TransferID = req.TransferRequestID;
                     TransferPacket.TransferData.Data = req.AssetInf.Data;
                     TransferPacket.TransferData.Status = 1;
-                    req.RequestUser.OutPacket(TransferPacket);
+                    req.RequestUser.OutPacket(TransferPacket, ThrottleOutPacketType.Asset);
                 }
                 else
                 {
@@ -546,7 +546,7 @@ namespace OpenSim.Framework.Communications.Cache
                         Array.Copy(req.AssetInf.Data, chunk, req.AssetInf.Data.Length);
                         TransferPacket.TransferData.Data = chunk;
                         TransferPacket.TransferData.Status = 1;
-                        req.RequestUser.OutPacket(TransferPacket);
+                        req.RequestUser.OutPacket(TransferPacket, ThrottleOutPacketType.Asset);
                     }
                     else
                     {
@@ -555,7 +555,7 @@ namespace OpenSim.Framework.Communications.Cache
 
                         TransferPacket.TransferData.Data = chunk;
                         TransferPacket.TransferData.Status = 0;
-                        req.RequestUser.OutPacket(TransferPacket);
+                        req.RequestUser.OutPacket(TransferPacket, ThrottleOutPacketType.Asset);
 
                         TransferPacket = new TransferPacketPacket();
                         TransferPacket.TransferData.Packet = 1;
@@ -565,7 +565,7 @@ namespace OpenSim.Framework.Communications.Cache
                         Array.Copy(req.AssetInf.Data, 1000, chunk1, 0, chunk1.Length);
                         TransferPacket.TransferData.Data = chunk1;
                         TransferPacket.TransferData.Status = 1;
-                        req.RequestUser.OutPacket(TransferPacket);
+                        req.RequestUser.OutPacket(TransferPacket, ThrottleOutPacketType.Asset);
                     }
                 }
             }
@@ -741,7 +741,7 @@ namespace OpenSim.Framework.Communications.Cache
                         im.ImageID.Size = (uint) req.ImageInfo.Data.Length;
                         im.ImageData.Data = req.ImageInfo.Data;
                         im.ImageID.Codec = 2;
-                        req.RequestUser.OutPacket(im);
+                        req.RequestUser.OutPacket(im, ThrottleOutPacketType.Texture);
                         req.PacketCounter++;
                         //req.ImageInfo.l= time;
                         //System.Console.WriteLine("sent texture: " + req.ImageInfo.FullID);
@@ -758,7 +758,7 @@ namespace OpenSim.Framework.Communications.Cache
                         im.ImageData.Data = new byte[600];
                         Array.Copy(req.ImageInfo.Data, 0, im.ImageData.Data, 0, 600);
                         im.ImageID.Codec = 2;
-                        req.RequestUser.OutPacket(im);
+                        req.RequestUser.OutPacket(im, ThrottleOutPacketType.Texture);
 
                         req.PacketCounter++;
                         //req.ImageInfo.last_used = time;
@@ -780,7 +780,7 @@ namespace OpenSim.Framework.Communications.Cache
                     //Console.WriteLine("length= {0} counter= {1} size= {2}",req.ImageInfo.Data.Length, req.PacketCounter, size);
                     im.ImageData.Data = new byte[size];
                     Array.Copy(req.ImageInfo.Data, 600 + (1000*(req.PacketCounter - 1)), im.ImageData.Data, 0, size);
-                    req.RequestUser.OutPacket(im);
+                    req.RequestUser.OutPacket(im, ThrottleOutPacketType.Texture);
                     req.PacketCounter++;
                     //req.ImageInfo.last_used = time;
                     //System.Console.WriteLine("sent a packet of texture: "+req.ImageInfo.FullID);
diff --git a/OpenSim/Framework/Communications/Cache/AssetTransactions.cs b/OpenSim/Framework/Communications/Cache/AssetTransactions.cs
index 9e9ec05..acd57b6 100644
--- a/OpenSim/Framework/Communications/Cache/AssetTransactions.cs
+++ b/OpenSim/Framework/Communications/Cache/AssetTransactions.cs
@@ -221,7 +221,7 @@ namespace OpenSim.Framework.Communications.Cache
                     ConfirmXferPacketPacket newPack = new ConfirmXferPacketPacket();
                     newPack.XferID.ID = xferID;
                     newPack.XferID.Packet = packetID;
-                    ourClient.OutPacket(newPack);
+                    ourClient.OutPacket(newPack, ThrottleOutPacketType.Asset);
                     if ((packetID & 0x80000000) != 0)
                     {
                         SendCompleteMessage();
@@ -262,7 +262,7 @@ namespace OpenSim.Framework.Communications.Cache
                 newPack.XferID.VFileID = Asset.FullID;
                 newPack.XferID.FilePath = 0;
                 newPack.XferID.Filename = new byte[0];
-                ourClient.OutPacket(newPack);
+                ourClient.OutPacket(newPack, ThrottleOutPacketType.Asset);
             }
 
             protected void SendCompleteMessage()
@@ -272,7 +272,7 @@ namespace OpenSim.Framework.Communications.Cache
                 newPack.AssetBlock.Type = Asset.Type;
                 newPack.AssetBlock.Success = true;
                 newPack.AssetBlock.UUID = Asset.FullID;
-                ourClient.OutPacket(newPack);
+                ourClient.OutPacket(newPack, ThrottleOutPacketType.Asset);
                 m_finished = true;
                 if (m_createItem)
                 {
diff --git a/OpenSim/Framework/IClientAPI.cs b/OpenSim/Framework/IClientAPI.cs
index 23181bf..0e8b82d 100644
--- a/OpenSim/Framework/IClientAPI.cs
+++ b/OpenSim/Framework/IClientAPI.cs
@@ -54,6 +54,16 @@ namespace OpenSim.Framework
         StopTyping = 5,
         Broadcast = 0xFF
     } ;
+    public enum ThrottleOutPacketType : int
+    {
+        Resend = 0,
+        Land = 1, 
+        Wind = 2,
+        Cloud = 3,
+        Task = 4,
+        Texture = 5,
+        Asset = 6
+    }
 
     /// <summary>
     /// ChatFromViewer Arguments
@@ -378,7 +388,7 @@ namespace OpenSim.Framework
 
         uint CircuitCode { get; set; }
 
-        void OutPacket(Packet newPack);
+        void OutPacket(Packet newPack, ThrottleOutPacketType packType);
         void SendWearables(AvatarWearable[] wearables, int serial);
         void SendAppearance(LLUUID agentID, byte[] visualParams, byte[] textureEntry);
         void SendStartPingCheck(byte seq);