simplify http textures and meshs Throttles

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<UUID, aPollResponse> 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;
-                       
                         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 (timeElapsed >= 100)
-                if (currenttime - timeElapsed >= 1000)
                 {
-                    lastTimeElapsed = Util.EnvironmentTickCount();
+                    lastTimeElapsed = currenttime;
-                    BytesSent -= ThrottleBytes;
+                    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 = 2 * 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);
                 ProcessTime();
-
             }
         }
     }

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<UUID, GetTextureModule.aPollResponse> 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();
+                    lastTimeElapsed = currenttime;
-                    BytesSent -= ThrottleBytes;
+                    BytesSent -= (ThrottleBytes * timeElapsed / 1000);
                     if (BytesSent < 0) BytesSent = 0;
-                    if (BytesSent < ThrottleBytes)
-                    {
-                        oversizedImages = 0;
-                    }
                 }
             }
             public int ThrottleBytes;