diff options
Diffstat (limited to '')
4 files changed, 18 insertions, 6 deletions
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs b/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs index d272667..dee5d80 100644 --- a/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs +++ b/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs | |||
@@ -1961,7 +1961,6 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
1961 | 1961 | ||
1962 | public void SendAgentDataUpdate(UUID agentid, UUID activegroupid, string firstname, string lastname, ulong grouppowers, string groupname, string grouptitle) | 1962 | public void SendAgentDataUpdate(UUID agentid, UUID activegroupid, string firstname, string lastname, ulong grouppowers, string groupname, string grouptitle) |
1963 | { | 1963 | { |
1964 | |||
1965 | m_activeGroupID = activegroupid; | 1964 | m_activeGroupID = activegroupid; |
1966 | m_activeGroupName = groupname; | 1965 | m_activeGroupName = groupname; |
1967 | m_activeGroupPowers = grouppowers; | 1966 | m_activeGroupPowers = grouppowers; |
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs b/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs index bf95045..9abde5d 100644 --- a/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs +++ b/OpenSim/Region/ClientStack/LindenUDP/LLPacketQueue.cs | |||
@@ -322,6 +322,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
322 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 322 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
323 | ResendThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 323 | ResendThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
324 | } | 324 | } |
325 | |||
325 | if (LandThrottle.UnderLimit() && LandOutgoingPacketQueue.Count > 0) | 326 | if (LandThrottle.UnderLimit() && LandOutgoingPacketQueue.Count > 0) |
326 | { | 327 | { |
327 | LLQueItem qpack = LandOutgoingPacketQueue.Dequeue(); | 328 | LLQueItem qpack = LandOutgoingPacketQueue.Dequeue(); |
@@ -330,6 +331,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
330 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 331 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
331 | LandThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 332 | LandThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
332 | } | 333 | } |
334 | |||
333 | if (WindThrottle.UnderLimit() && WindOutgoingPacketQueue.Count > 0) | 335 | if (WindThrottle.UnderLimit() && WindOutgoingPacketQueue.Count > 0) |
334 | { | 336 | { |
335 | LLQueItem qpack = WindOutgoingPacketQueue.Dequeue(); | 337 | LLQueItem qpack = WindOutgoingPacketQueue.Dequeue(); |
@@ -338,6 +340,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
338 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 340 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
339 | WindThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 341 | WindThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
340 | } | 342 | } |
343 | |||
341 | if (CloudThrottle.UnderLimit() && CloudOutgoingPacketQueue.Count > 0) | 344 | if (CloudThrottle.UnderLimit() && CloudOutgoingPacketQueue.Count > 0) |
342 | { | 345 | { |
343 | LLQueItem qpack = CloudOutgoingPacketQueue.Dequeue(); | 346 | LLQueItem qpack = CloudOutgoingPacketQueue.Dequeue(); |
@@ -346,6 +349,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
346 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 349 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
347 | CloudThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 350 | CloudThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
348 | } | 351 | } |
352 | |||
349 | if (TaskThrottle.UnderLimit() && (TaskOutgoingPacketQueue.Count > 0 || TaskLowpriorityPacketQueue.Count > 0)) | 353 | if (TaskThrottle.UnderLimit() && (TaskOutgoingPacketQueue.Count > 0 || TaskLowpriorityPacketQueue.Count > 0)) |
350 | { | 354 | { |
351 | LLQueItem qpack; | 355 | LLQueItem qpack; |
@@ -362,6 +366,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
362 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 366 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
363 | TaskThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 367 | TaskThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
364 | } | 368 | } |
369 | |||
365 | if (TextureThrottle.UnderLimit() && TextureOutgoingPacketQueue.Count > 0) | 370 | if (TextureThrottle.UnderLimit() && TextureOutgoingPacketQueue.Count > 0) |
366 | { | 371 | { |
367 | LLQueItem qpack = TextureOutgoingPacketQueue.Dequeue(); | 372 | LLQueItem qpack = TextureOutgoingPacketQueue.Dequeue(); |
@@ -370,6 +375,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
370 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 375 | TotalThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
371 | TextureThrottle.AddBytes(qpack.Packet.ToBytes().Length); | 376 | TextureThrottle.AddBytes(qpack.Packet.ToBytes().Length); |
372 | } | 377 | } |
378 | |||
373 | if (AssetThrottle.UnderLimit() && AssetOutgoingPacketQueue.Count > 0) | 379 | if (AssetThrottle.UnderLimit() && AssetOutgoingPacketQueue.Count > 0) |
374 | { | 380 | { |
375 | LLQueItem qpack = AssetOutgoingPacketQueue.Dequeue(); | 381 | LLQueItem qpack = AssetOutgoingPacketQueue.Dequeue(); |
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs b/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs index ba4e18b..cbe6eff 100644 --- a/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs +++ b/OpenSim/Region/ClientStack/LindenUDP/LLUDPServer.cs | |||
@@ -33,6 +33,7 @@ using System.Net.Sockets; | |||
33 | using System.Reflection; | 33 | using System.Reflection; |
34 | using OpenMetaverse.Packets; | 34 | using OpenMetaverse.Packets; |
35 | using log4net; | 35 | using log4net; |
36 | using Nini.Config; | ||
36 | using OpenSim.Framework; | 37 | using OpenSim.Framework; |
37 | using OpenSim.Framework.Communications.Cache; | 38 | using OpenSim.Framework.Communications.Cache; |
38 | using OpenSim.Region.Environment.Scenes; | 39 | using OpenSim.Region.Environment.Scenes; |
@@ -127,10 +128,10 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
127 | } | 128 | } |
128 | 129 | ||
129 | public LLUDPServer( | 130 | public LLUDPServer( |
130 | IPAddress _listenIP, ref uint port, int proxyPortOffset, bool allow_alternate_port, ClientStackUserSettings userSettings, | 131 | IPAddress _listenIP, ref uint port, int proxyPortOffset, bool allow_alternate_port, IConfigSource configSource, |
131 | AssetCache assetCache, AgentCircuitManager authenticateClass) | 132 | AssetCache assetCache, AgentCircuitManager authenticateClass) |
132 | { | 133 | { |
133 | Initialise(_listenIP, ref port, proxyPortOffset, allow_alternate_port, userSettings, assetCache, authenticateClass); | 134 | Initialise(_listenIP, ref port, proxyPortOffset, allow_alternate_port, configSource, assetCache, authenticateClass); |
134 | } | 135 | } |
135 | 136 | ||
136 | /// <summary> | 137 | /// <summary> |
@@ -140,13 +141,17 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
140 | /// <param name="port"></param> | 141 | /// <param name="port"></param> |
141 | /// <param name="proxyPortOffsetParm"></param> | 142 | /// <param name="proxyPortOffsetParm"></param> |
142 | /// <param name="allow_alternate_port"></param> | 143 | /// <param name="allow_alternate_port"></param> |
143 | /// <param name="userSettings"></param> | 144 | /// <param name="configSource"></param> |
144 | /// <param name="assetCache"></param> | 145 | /// <param name="assetCache"></param> |
145 | /// <param name="circuitManager"></param> | 146 | /// <param name="circuitManager"></param> |
146 | public void Initialise( | 147 | public void Initialise( |
147 | IPAddress _listenIP, ref uint port, int proxyPortOffsetParm, bool allow_alternate_port, ClientStackUserSettings userSettings, | 148 | IPAddress _listenIP, ref uint port, int proxyPortOffsetParm, bool allow_alternate_port, IConfigSource configSource, |
148 | AssetCache assetCache, AgentCircuitManager circuitManager) | 149 | AssetCache assetCache, AgentCircuitManager circuitManager) |
149 | { | 150 | { |
151 | // XXX Temporary until we start unpacking the config source | ||
152 | // TODO: Don't forget to account for the null possibility | ||
153 | ClientStackUserSettings userSettings = new ClientStackUserSettings(); | ||
154 | |||
150 | proxyPortOffset = proxyPortOffsetParm; | 155 | proxyPortOffset = proxyPortOffsetParm; |
151 | listenPort = (uint) (port + proxyPortOffsetParm); | 156 | listenPort = (uint) (port + proxyPortOffsetParm); |
152 | listenIP = _listenIP; | 157 | listenIP = _listenIP; |
diff --git a/OpenSim/Region/ClientStack/LindenUDP/Tests/BasicCircuitTests.cs b/OpenSim/Region/ClientStack/LindenUDP/Tests/BasicCircuitTests.cs index 352f697..d55f423 100644 --- a/OpenSim/Region/ClientStack/LindenUDP/Tests/BasicCircuitTests.cs +++ b/OpenSim/Region/ClientStack/LindenUDP/Tests/BasicCircuitTests.cs | |||
@@ -27,6 +27,7 @@ | |||
27 | 27 | ||
28 | using System.Net; | 28 | using System.Net; |
29 | using log4net; | 29 | using log4net; |
30 | using Nini.Config; | ||
30 | using NUnit.Framework; | 31 | using NUnit.Framework; |
31 | using NUnit.Framework.SyntaxHelpers; | 32 | using NUnit.Framework.SyntaxHelpers; |
32 | using OpenMetaverse; | 33 | using OpenMetaverse; |
@@ -68,12 +69,13 @@ namespace OpenSim.Region.ClientStack.LindenUDP.Tests | |||
68 | IScene scene, out TestLLUDPServer testLLUDPServer, out TestLLPacketServer testPacketServer, | 69 | IScene scene, out TestLLUDPServer testLLUDPServer, out TestLLPacketServer testPacketServer, |
69 | out AgentCircuitManager acm) | 70 | out AgentCircuitManager acm) |
70 | { | 71 | { |
72 | IConfigSource configSource = new IniConfigSource(); | ||
71 | ClientStackUserSettings userSettings = new ClientStackUserSettings(); | 73 | ClientStackUserSettings userSettings = new ClientStackUserSettings(); |
72 | testLLUDPServer = new TestLLUDPServer(); | 74 | testLLUDPServer = new TestLLUDPServer(); |
73 | acm = new AgentCircuitManager(); | 75 | acm = new AgentCircuitManager(); |
74 | 76 | ||
75 | uint port = 666; | 77 | uint port = 666; |
76 | testLLUDPServer.Initialise(null, ref port, 0, false, userSettings, null, acm); | 78 | testLLUDPServer.Initialise(null, ref port, 0, false, configSource, null, acm); |
77 | testPacketServer = new TestLLPacketServer(testLLUDPServer, userSettings); | 79 | testPacketServer = new TestLLPacketServer(testLLUDPServer, userSettings); |
78 | testLLUDPServer.LocalScene = scene; | 80 | testLLUDPServer.LocalScene = scene; |
79 | } | 81 | } |