From 615b40b68b2311433b855f8c1e961a8b71eb9b65 Mon Sep 17 00:00:00 2001 From: Teravus Ovares Date: Sun, 18 Nov 2007 15:54:05 +0000 Subject: * 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. --- OpenSim/Framework/Communications/Cache/AssetCache.cs | 16 ++++++++-------- .../Framework/Communications/Cache/AssetTransactions.cs | 6 +++--- 2 files changed, 11 insertions(+), 11 deletions(-) (limited to 'OpenSim/Framework/Communications/Cache') 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) { -- cgit v1.1