diff options
author | Justin Clarke Casey | 2008-10-03 18:06:45 +0000 |
---|---|---|
committer | Justin Clarke Casey | 2008-10-03 18:06:45 +0000 |
commit | 743e336bf340f623a50bebd53d98798c04eb0345 (patch) | |
tree | d6a0055ff71d99e7c0e132bb7ae51d0922949e0c /OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs | |
parent | Cause objects to be removed from the database when they go temp or get (diff) | |
download | opensim-SC_OLD-743e336bf340f623a50bebd53d98798c04eb0345.zip opensim-SC_OLD-743e336bf340f623a50bebd53d98798c04eb0345.tar.gz opensim-SC_OLD-743e336bf340f623a50bebd53d98798c04eb0345.tar.bz2 opensim-SC_OLD-743e336bf340f623a50bebd53d98798c04eb0345.tar.xz |
* Put in some infrastructure to allow tweaking of packet queue throttle values for the total throttle (the one that throttles all packet output)
* Not complete yet
Diffstat (limited to 'OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs')
-rw-r--r-- | OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs | 19 |
1 files changed, 14 insertions, 5 deletions
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs b/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs index e4e5e9a..1e03c88 100644 --- a/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs +++ b/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs | |||
@@ -34,6 +34,7 @@ using OpenMetaverse.Packets; | |||
34 | using OpenSim.Framework; | 34 | using OpenSim.Framework; |
35 | using OpenSim.Framework.Statistics; | 35 | using OpenSim.Framework.Statistics; |
36 | using OpenSim.Framework.Statistics.Interfaces; | 36 | using OpenSim.Framework.Statistics.Interfaces; |
37 | using OpenSim.Region.ClientStack; | ||
37 | using Timer=System.Timers.Timer; | 38 | using Timer=System.Timers.Timer; |
38 | 39 | ||
39 | 40 | ||
@@ -45,7 +46,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
45 | = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); | 46 | = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); |
46 | 47 | ||
47 | /// <summary> | 48 | /// <summary> |
48 | /// Is throttling enabled at all? | 49 | /// Is queueing enabled at all? |
49 | /// </summary> | 50 | /// </summary> |
50 | private bool m_enabled = true; | 51 | private bool m_enabled = true; |
51 | 52 | ||
@@ -88,7 +89,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
88 | 89 | ||
89 | private UUID m_agentId; | 90 | private UUID m_agentId; |
90 | 91 | ||
91 | public LLPacketQueue(UUID agentId) | 92 | public LLPacketQueue(UUID agentId, ClientStackUserSettings userSettings) |
92 | { | 93 | { |
93 | // While working on this, the BlockingQueue had me fooled for a bit. | 94 | // While working on this, the BlockingQueue had me fooled for a bit. |
94 | // The Blocking queue causes the thread to stop until there's something | 95 | // The Blocking queue causes the thread to stop until there's something |
@@ -108,7 +109,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
108 | TextureOutgoingPacketQueue = new Queue<LLQueItem>(); | 109 | TextureOutgoingPacketQueue = new Queue<LLQueItem>(); |
109 | AssetOutgoingPacketQueue = new Queue<LLQueItem>(); | 110 | AssetOutgoingPacketQueue = new Queue<LLQueItem>(); |
110 | 111 | ||
111 | |||
112 | // Set up the throttle classes (min, max, current) in bytes | 112 | // Set up the throttle classes (min, max, current) in bytes |
113 | ResendThrottle = new LLPacketThrottle(5000, 100000, 16000); | 113 | ResendThrottle = new LLPacketThrottle(5000, 100000, 16000); |
114 | LandThrottle = new LLPacketThrottle(1000, 100000, 2000); | 114 | LandThrottle = new LLPacketThrottle(1000, 100000, 2000); |
@@ -117,9 +117,18 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
117 | TaskThrottle = new LLPacketThrottle(1000, 800000, 3000); | 117 | TaskThrottle = new LLPacketThrottle(1000, 800000, 3000); |
118 | AssetThrottle = new LLPacketThrottle(1000, 800000, 1000); | 118 | AssetThrottle = new LLPacketThrottle(1000, 800000, 1000); |
119 | TextureThrottle = new LLPacketThrottle(1000, 800000, 4000); | 119 | TextureThrottle = new LLPacketThrottle(1000, 800000, 4000); |
120 | |||
120 | // Total Throttle trumps all | 121 | // Total Throttle trumps all |
121 | // Number of bytes allowed to go out per second. (256kbps per client) | 122 | // Number of bytes allowed to go out per second. |
122 | TotalThrottle = new LLPacketThrottle(0, 1500000, 28000); | 123 | ThrottleSettings totalThrottleSettings = userSettings.TotalThrottleSettings; |
124 | if (null == totalThrottleSettings) | ||
125 | { | ||
126 | totalThrottleSettings = new ThrottleSettings(0, 1500000, 28000); | ||
127 | } | ||
128 | |||
129 | TotalThrottle | ||
130 | = new LLPacketThrottle( | ||
131 | totalThrottleSettings.Min, totalThrottleSettings.Max, totalThrottleSettings.Current); | ||
123 | 132 | ||
124 | throttleTimer = new Timer((int) (throttletimems/throttleTimeDivisor)); | 133 | throttleTimer = new Timer((int) (throttletimems/throttleTimeDivisor)); |
125 | throttleTimer.Elapsed += new ElapsedEventHandler(ThrottleTimerElapsed); | 134 | throttleTimer.Elapsed += new ElapsedEventHandler(ThrottleTimerElapsed); |