diff --git a/OpenSim/Region/ClientStack/Linden/Caps/GetMeshModule.cs b/OpenSim/Region/ClientStack/Linden/Caps/GetMeshModule.cs index 95d9c995b6..f66ef57ace 100644 --- a/OpenSim/Region/ClientStack/Linden/Caps/GetMeshModule.cs +++ b/OpenSim/Region/ClientStack/Linden/Caps/GetMeshModule.cs @@ -389,11 +389,6 @@ namespace OpenSim.Region.ClientStack.Linden private volatile int currenttime = 0; private volatile int lastTimeElapsed = 0; private volatile int BytesSent = 0; - private int Lod3 = 0; - private int Lod2 = 0; -// private int Lod1 = 0; - private int UserSetThrottle = 0; - private int UDPSetThrottle = 0; private int CapSetThrottle = 0; private float CapThrottleDistributon = 0.30f; private readonly Scene m_scene; @@ -403,6 +398,8 @@ namespace OpenSim.Region.ClientStack.Linden public MeshCapsDataThrottler(int pBytes, int max, int min, Scene pScene, UUID puser) { ThrottleBytes = pBytes; + if(ThrottleBytes < 10000) + ThrottleBytes = 10000; lastTimeElapsed = Util.EnvironmentTickCount(); Throttle = ThrottleOutPacketType.Asset; m_scene = pScene; @@ -411,21 +408,10 @@ namespace OpenSim.Region.ClientStack.Linden public bool hasEvents(UUID key, Dictionary responses) { - const float ThirtyPercent = 0.30f; - const float FivePercent = 0.05f; PassTime(); // Note, this is called IN LOCK bool haskey = responses.ContainsKey(key); - if (responses.Count > 2) - { - SplitThrottle(ThirtyPercent); - } - else - { - SplitThrottle(FivePercent); - } - if (!haskey) { return false; @@ -433,29 +419,10 @@ namespace OpenSim.Region.ClientStack.Linden aPollResponse response; if (responses.TryGetValue(key, out response)) { - float LOD3Over = (((ThrottleBytes*CapThrottleDistributon)%50000) + 1); - float LOD2Over = (((ThrottleBytes*CapThrottleDistributon)%10000) + 1); // Normal - if (BytesSent + response.bytes <= ThrottleBytes) + if (BytesSent <= ThrottleBytes) { - BytesSent += response.bytes; - - return true; - } - // Lod3 Over Throttle protection to keep things processing even when the throttle bandwidth is set too little. - else if (response.bytes > ThrottleBytes && Lod3 <= ((LOD3Over < 1)? 1: LOD3Over) ) - { - Interlocked.Increment(ref Lod3); - BytesSent += response.bytes; - - return true; - } - // Lod2 Over Throttle protection to keep things processing even when the throttle bandwidth is set too little. - else if (response.bytes > ThrottleBytes && Lod2 <= ((LOD2Over < 1) ? 1 : LOD2Over)) - { - Interlocked.Increment(ref Lod2); - BytesSent += response.bytes; - + BytesSent += response.bytes; return true; } else @@ -463,27 +430,8 @@ namespace OpenSim.Region.ClientStack.Linden return false; } } - return haskey; } - public void SubtractBytes(int bytes,int lod) - { - BytesSent -= bytes; - } - private void SplitThrottle(float percentMultiplier) - { - - if (CapThrottleDistributon != percentMultiplier) // don't switch it if it's already set at the % multipler - { - CapThrottleDistributon = percentMultiplier; - ScenePresence p; - if (m_scene.TryGetScenePresence(User, out p)) // If we don't get a user they're not here anymore. - { -// AlterThrottle(UserSetThrottle, p); - UpdateThrottle(UserSetThrottle, p); - } - } - } public void ProcessTime() { @@ -494,18 +442,11 @@ namespace OpenSim.Region.ClientStack.Linden { currenttime = Util.EnvironmentTickCount(); int timeElapsed = Util.EnvironmentTickCountSubtract(currenttime, lastTimeElapsed); - //processTimeBasedActions(responses); - if (currenttime - timeElapsed >= 1000) + if (timeElapsed >= 100) { - lastTimeElapsed = Util.EnvironmentTickCount(); - BytesSent -= ThrottleBytes; + lastTimeElapsed = currenttime; + BytesSent -= (ThrottleBytes * timeElapsed / 1000); if (BytesSent < 0) BytesSent = 0; - if (BytesSent < ThrottleBytes) - { - Lod3 = 0; - Lod2 = 0; -// Lod1 = 0; - } } } @@ -517,25 +458,20 @@ namespace OpenSim.Region.ClientStack.Linden public int ThrottleBytes { get { return CapSetThrottle; } - set { CapSetThrottle = value; } + set + { + if (value > 10000) + CapSetThrottle = value; + else + CapSetThrottle = 10000; + } } internal void UpdateThrottle(int pimagethrottle, ScenePresence p) { // Client set throttle ! - UserSetThrottle = pimagethrottle; - CapSetThrottle = (int)(pimagethrottle*CapThrottleDistributon); -// UDPSetThrottle = (int) (pimagethrottle*(100 - CapThrottleDistributon)); - - float udp = 1.0f - CapThrottleDistributon; - if(udp < 0.7f) - udp = 0.7f; - UDPSetThrottle = (int) ((float)pimagethrottle * udp); - if (CapSetThrottle < 4068) - CapSetThrottle = 4068; // at least two discovery mesh - p.ControllingClient.SetAgentThrottleSilent((int) Throttle, UDPSetThrottle); + CapSetThrottle = 2 * pimagethrottle; ProcessTime(); - } } } diff --git a/OpenSim/Region/ClientStack/Linden/Caps/GetTextureModule.cs b/OpenSim/Region/ClientStack/Linden/Caps/GetTextureModule.cs index 0c4e227e21..14a59feb0e 100644 --- a/OpenSim/Region/ClientStack/Linden/Caps/GetTextureModule.cs +++ b/OpenSim/Region/ClientStack/Linden/Caps/GetTextureModule.cs @@ -356,7 +356,9 @@ namespace OpenSim.Region.ClientStack.Linden internal void UpdateThrottle(int pimagethrottle) { - m_throttler.ThrottleBytes = pimagethrottle; + m_throttler.ThrottleBytes = 2 * pimagethrottle; + if(m_throttler.ThrottleBytes < 10000) + m_throttler.ThrottleBytes = 10000; } } @@ -425,10 +427,11 @@ namespace OpenSim.Region.ClientStack.Linden private volatile int currenttime = 0; private volatile int lastTimeElapsed = 0; private volatile int BytesSent = 0; - private int oversizedImages = 0; public CapsDataThrottler(int pBytes, int max, int min) { ThrottleBytes = pBytes; + if(ThrottleBytes < 10000) + ThrottleBytes = 10000; lastTimeElapsed = Util.EnvironmentTickCount(); } public bool hasEvents(UUID key, Dictionary responses) @@ -448,20 +451,9 @@ namespace OpenSim.Region.ClientStack.Linden return true; // Normal - if (BytesSent + response.bytes <= ThrottleBytes) + if (BytesSent <= ThrottleBytes) { BytesSent += response.bytes; - //TimeBasedAction timeBasedAction = new TimeBasedAction { byteRemoval = response.bytes, requestId = key, timeMS = currenttime + 1000, unlockyn = false }; - //m_actions.Add(timeBasedAction); - return true; - } - // Big textures - else if (response.bytes > ThrottleBytes && oversizedImages <= ((ThrottleBytes % 50000) + 1)) - { - Interlocked.Increment(ref oversizedImages); - BytesSent += response.bytes; - //TimeBasedAction timeBasedAction = new TimeBasedAction { byteRemoval = response.bytes, requestId = key, timeMS = currenttime + (((response.bytes % ThrottleBytes)+1)*1000) , unlockyn = false }; - //m_actions.Add(timeBasedAction); return true; } else @@ -483,15 +475,11 @@ namespace OpenSim.Region.ClientStack.Linden currenttime = Util.EnvironmentTickCount(); int timeElapsed = Util.EnvironmentTickCountSubtract(currenttime, lastTimeElapsed); //processTimeBasedActions(responses); - if (Util.EnvironmentTickCountSubtract(currenttime, timeElapsed) >= 1000) + if (timeElapsed >= 100) { - lastTimeElapsed = Util.EnvironmentTickCount(); - BytesSent -= ThrottleBytes; + lastTimeElapsed = currenttime; + BytesSent -= (ThrottleBytes * timeElapsed / 1000); if (BytesSent < 0) BytesSent = 0; - if (BytesSent < ThrottleBytes) - { - oversizedImages = 0; - } } } public int ThrottleBytes;