diff options
author | Adam Frisby | 2008-05-02 18:26:19 +0000 |
---|---|---|
committer | Adam Frisby | 2008-05-02 18:26:19 +0000 |
commit | 67bbfadc06f36b5175cd5f7268ba876769667dca (patch) | |
tree | bd4f485b5f72ef7a702af067d8656745f0dc3986 | |
parent | adding a few more prep parts for this object (diff) | |
download | opensim-SC-67bbfadc06f36b5175cd5f7268ba876769667dca.zip opensim-SC-67bbfadc06f36b5175cd5f7268ba876769667dca.tar.gz opensim-SC-67bbfadc06f36b5175cd5f7268ba876769667dca.tar.bz2 opensim-SC-67bbfadc06f36b5175cd5f7268ba876769667dca.tar.xz |
* More refactorings of UDPServer.
* Removed all references where possible.
* Renamed lots of variables from UDPServerXYZ to clientServerXYZ
-rw-r--r-- | OpenSim/Framework/Servers/CheckSumServer.cs | 100 | ||||
-rw-r--r-- | OpenSim/Region/Application/OpenSimMain.cs | 39 | ||||
-rw-r--r-- | OpenSim/Region/Application/OpenSimMainConsole.cs | 1 | ||||
-rw-r--r-- | OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs | 2 | ||||
-rw-r--r-- | OpenSim/Region/ClientStack/RegionApplicationBase.cs | 10 | ||||
-rw-r--r-- | OpenSim/Region/Environment/Scenes/Scene.cs | 2 | ||||
-rw-r--r-- | OpenSim/Region/Environment/Scenes/ScenePresence.cs | 2 | ||||
-rw-r--r-- | ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs | 22 | ||||
-rw-r--r-- | ThirdParty/3Di/RegionProxy/RegionProxyPlugin.cs | 2 |
9 files changed, 32 insertions, 148 deletions
diff --git a/OpenSim/Framework/Servers/CheckSumServer.cs b/OpenSim/Framework/Servers/CheckSumServer.cs index 86bdfba..63059f0 100644 --- a/OpenSim/Framework/Servers/CheckSumServer.cs +++ b/OpenSim/Framework/Servers/CheckSumServer.cs | |||
@@ -24,103 +24,3 @@ | |||
24 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS | 24 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
25 | * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 25 | * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
26 | */ | 26 | */ |
27 | |||
28 | namespace OpenSim.Framework.Servers | ||
29 | { | ||
30 | /* | ||
31 | public class CheckSumServer : UDPServerBase | ||
32 | { | ||
33 | private static readonly log4net.ILog m_log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); | ||
34 | |||
35 | public CheckSumServer(int port) | ||
36 | : base(port) | ||
37 | { | ||
38 | } | ||
39 | |||
40 | protected override void OnReceivedData(IAsyncResult result) | ||
41 | { | ||
42 | ipeSender = new IPEndPoint(IPAddress.Any, 0); | ||
43 | epSender = (EndPoint)ipeSender; | ||
44 | Packet packet = null; | ||
45 | int numBytes = Server.EndReceiveFrom(result, ref epSender); | ||
46 | int packetEnd = numBytes - 1; | ||
47 | |||
48 | packet = Packet.BuildPacket(RecvBuffer, ref packetEnd, ZeroBuffer); | ||
49 | |||
50 | if (packet.Type == PacketType.SecuredTemplateChecksumRequest) | ||
51 | { | ||
52 | SecuredTemplateChecksumRequestPacket checksum = (SecuredTemplateChecksumRequestPacket)packet; | ||
53 | TemplateChecksumReplyPacket checkreply = new TemplateChecksumReplyPacket(); | ||
54 | checkreply.DataBlock.Checksum = 3220703154;//180572585; | ||
55 | checkreply.DataBlock.Flags = 0; | ||
56 | checkreply.DataBlock.MajorVersion = 1; | ||
57 | checkreply.DataBlock.MinorVersion = 15; | ||
58 | checkreply.DataBlock.PatchVersion = 0; | ||
59 | checkreply.DataBlock.ServerVersion = 0; | ||
60 | checkreply.TokenBlock.Token = checksum.TokenBlock.Token; | ||
61 | this.SendPacket(checkreply, epSender); | ||
62 | |||
63 | /* | ||
64 | //if we wanted to echo the the checksum/ version from the client (so that any client worked) | ||
65 | SecuredTemplateChecksumRequestPacket checkrequest = new SecuredTemplateChecksumRequestPacket(); | ||
66 | checkrequest.TokenBlock.Token = checksum.TokenBlock.Token; | ||
67 | this.SendPacket(checkrequest, epSender); | ||
68 | |||
69 | } | ||
70 | else if (packet.Type == PacketType.TemplateChecksumReply) | ||
71 | { | ||
72 | //echo back the client checksum reply (Hegemon's method) | ||
73 | TemplateChecksumReplyPacket checksum2 = (TemplateChecksumReplyPacket)packet; | ||
74 | TemplateChecksumReplyPacket checkreply2 = new TemplateChecksumReplyPacket(); | ||
75 | checkreply2.DataBlock.Checksum = checksum2.DataBlock.Checksum; | ||
76 | checkreply2.DataBlock.Flags = checksum2.DataBlock.Flags; | ||
77 | checkreply2.DataBlock.MajorVersion = checksum2.DataBlock.MajorVersion; | ||
78 | checkreply2.DataBlock.MinorVersion = checksum2.DataBlock.MinorVersion; | ||
79 | checkreply2.DataBlock.PatchVersion = checksum2.DataBlock.PatchVersion; | ||
80 | checkreply2.DataBlock.ServerVersion = checksum2.DataBlock.ServerVersion; | ||
81 | checkreply2.TokenBlock.Token = checksum2.TokenBlock.Token; | ||
82 | this.SendPacket(checkreply2, epSender); | ||
83 | } | ||
84 | else | ||
85 | { | ||
86 | } | ||
87 | |||
88 | Server.BeginReceiveFrom(RecvBuffer, 0, RecvBuffer.Length, SocketFlags.None, ref epSender, ReceivedData, null); | ||
89 | } | ||
90 | |||
91 | private void SendPacket(Packet Pack, EndPoint endp) | ||
92 | { | ||
93 | if (!Pack.Header.Resent) | ||
94 | { | ||
95 | Pack.Header.Sequence = 1; | ||
96 | } | ||
97 | |||
98 | byte[] ZeroOutBuffer = new byte[4096]; | ||
99 | byte[] sendbuffer; | ||
100 | sendbuffer = Pack.ToBytes(); | ||
101 | |||
102 | try | ||
103 | { | ||
104 | if (Pack.Header.Zerocoded) | ||
105 | { | ||
106 | int packetsize = Helpers.ZeroEncode(sendbuffer, sendbuffer.Length, ZeroOutBuffer); | ||
107 | this.SendPackTo(ZeroOutBuffer, packetsize, SocketFlags.None, endp); | ||
108 | } | ||
109 | else | ||
110 | { | ||
111 | this.SendPackTo(sendbuffer, sendbuffer.Length, SocketFlags.None, endp); | ||
112 | } | ||
113 | } | ||
114 | catch (Exception) | ||
115 | { | ||
116 | m_log.Warn("CheckSumServer.cs:ProcessOutPacket() - WARNING: Socket exception occurred on connection "); | ||
117 | } | ||
118 | } | ||
119 | |||
120 | private void SendPackTo(byte[] buffer, int size, SocketFlags flags, EndPoint endp) | ||
121 | { | ||
122 | this.Server.SendTo(buffer, size, flags, endp); | ||
123 | } | ||
124 | * } | ||
125 | */ | ||
126 | } | ||
diff --git a/OpenSim/Region/Application/OpenSimMain.cs b/OpenSim/Region/Application/OpenSimMain.cs index 7924421..5b44813 100644 --- a/OpenSim/Region/Application/OpenSimMain.cs +++ b/OpenSim/Region/Application/OpenSimMain.cs | |||
@@ -40,7 +40,6 @@ using OpenSim.Framework.Communications.Cache; | |||
40 | using OpenSim.Framework.Servers; | 40 | using OpenSim.Framework.Servers; |
41 | using OpenSim.Framework.Statistics; | 41 | using OpenSim.Framework.Statistics; |
42 | using OpenSim.Region.ClientStack; | 42 | using OpenSim.Region.ClientStack; |
43 | using OpenSim.Region.ClientStack.LindenUDP; | ||
44 | using OpenSim.Region.Communications.Local; | 43 | using OpenSim.Region.Communications.Local; |
45 | using OpenSim.Region.Communications.OGS1; | 44 | using OpenSim.Region.Communications.OGS1; |
46 | using OpenSim.Region.Environment; | 45 | using OpenSim.Region.Environment; |
@@ -106,7 +105,7 @@ namespace OpenSim | |||
106 | get { return m_httpServer; } | 105 | get { return m_httpServer; } |
107 | } | 106 | } |
108 | 107 | ||
109 | public List<IClientNetworkServer> UdpServers | 108 | public List<IClientNetworkServer> ClientServers |
110 | { | 109 | { |
111 | get { return m_clientServers; } | 110 | get { return m_clientServers; } |
112 | } | 111 | } |
@@ -409,12 +408,6 @@ namespace OpenSim | |||
409 | plugin.Initialise(this); | 408 | plugin.Initialise(this); |
410 | m_plugins.Add(plugin); | 409 | m_plugins.Add(plugin); |
411 | } | 410 | } |
412 | |||
413 | // Start UDP servers | ||
414 | //for (int i = 0; i < m_udpServers.Count; i++) | ||
415 | //{ | ||
416 | // m_udpServers[i].ServerListener(); | ||
417 | // } | ||
418 | } | 411 | } |
419 | 412 | ||
420 | protected override void Initialize() | 413 | protected override void Initialize() |
@@ -496,8 +489,8 @@ namespace OpenSim | |||
496 | Util.XmlRpcCommand(proxyUrl, "AddPort", port, port + proxyOffset, regionInfo.ExternalHostName); | 489 | Util.XmlRpcCommand(proxyUrl, "AddPort", port, port + proxyOffset, regionInfo.ExternalHostName); |
497 | } | 490 | } |
498 | 491 | ||
499 | IClientNetworkServer udpServer; | 492 | IClientNetworkServer clientServer; |
500 | Scene scene = SetupScene(regionInfo, proxyOffset, out udpServer, m_permissions); | 493 | Scene scene = SetupScene(regionInfo, proxyOffset, out clientServer, m_permissions); |
501 | 494 | ||
502 | m_log.Info("[MODULES]: Loading Region's modules"); | 495 | m_log.Info("[MODULES]: Loading Region's modules"); |
503 | 496 | ||
@@ -549,9 +542,9 @@ namespace OpenSim | |||
549 | 542 | ||
550 | m_sceneManager.Add(scene); | 543 | m_sceneManager.Add(scene); |
551 | 544 | ||
552 | m_clientServers.Add(udpServer); | 545 | m_clientServers.Add(clientServer); |
553 | m_regionData.Add(regionInfo); | 546 | m_regionData.Add(regionInfo); |
554 | udpServer.Start(); | 547 | clientServer.Start(); |
555 | 548 | ||
556 | if (do_post_init) | 549 | if (do_post_init) |
557 | { | 550 | { |
@@ -561,7 +554,7 @@ namespace OpenSim | |||
561 | } | 554 | } |
562 | } | 555 | } |
563 | 556 | ||
564 | return udpServer; | 557 | return clientServer; |
565 | } | 558 | } |
566 | 559 | ||
567 | protected override StorageManager CreateStorageManager(string connectionstring) | 560 | protected override StorageManager CreateStorageManager(string connectionstring) |
@@ -583,24 +576,23 @@ namespace OpenSim | |||
583 | public void handleRestartRegion(RegionInfo whichRegion) | 576 | public void handleRestartRegion(RegionInfo whichRegion) |
584 | { | 577 | { |
585 | m_log.Error("[OPENSIM MAIN]: Got restart signal from SceneManager"); | 578 | m_log.Error("[OPENSIM MAIN]: Got restart signal from SceneManager"); |
586 | // Shutting down the UDP server | 579 | // Shutting down the client server |
587 | bool foundUDPServer = false; | 580 | bool foundClientServer = false; |
588 | int UDPServerElement = 0; | 581 | int clientServerElement = 0; |
589 | 582 | ||
590 | for (int i = 0; i < m_clientServers.Count; i++) | 583 | for (int i = 0; i < m_clientServers.Count; i++) |
591 | { | 584 | { |
592 | if (m_clientServers[i].HandlesRegion(new Location(whichRegion.RegionHandle))) | 585 | if (m_clientServers[i].HandlesRegion(new Location(whichRegion.RegionHandle))) |
593 | { | 586 | { |
594 | UDPServerElement = i; | 587 | clientServerElement = i; |
595 | foundUDPServer = true; | 588 | foundClientServer = true; |
596 | break; | 589 | break; |
597 | } | 590 | } |
598 | } | 591 | } |
599 | if (foundUDPServer) | 592 | if (foundClientServer) |
600 | { | 593 | { |
601 | // m_udpServers[UDPServerElement].Server.End | 594 | m_clientServers[clientServerElement].Server.Close(); |
602 | m_clientServers[UDPServerElement].Server.Close(); | 595 | m_clientServers.RemoveAt(clientServerElement); |
603 | m_clientServers.RemoveAt(UDPServerElement); | ||
604 | } | 596 | } |
605 | 597 | ||
606 | //Removing the region from the sim's database of regions.. | 598 | //Removing the region from the sim's database of regions.. |
@@ -618,9 +610,6 @@ namespace OpenSim | |||
618 | } | 610 | } |
619 | 611 | ||
620 | CreateRegion(whichRegion, true); | 612 | CreateRegion(whichRegion, true); |
621 | //UDPServer restartingRegion = CreateRegion(whichRegion); | ||
622 | //restartingRegion.ServerListener(); | ||
623 | //m_sceneManager.SendSimOnlineNotification(restartingRegion.RegionHandle); | ||
624 | } | 613 | } |
625 | 614 | ||
626 | # region Setup methods | 615 | # region Setup methods |
diff --git a/OpenSim/Region/Application/OpenSimMainConsole.cs b/OpenSim/Region/Application/OpenSimMainConsole.cs index 586e2cb..38cae66 100644 --- a/OpenSim/Region/Application/OpenSimMainConsole.cs +++ b/OpenSim/Region/Application/OpenSimMainConsole.cs | |||
@@ -38,7 +38,6 @@ using Nini.Config; | |||
38 | using OpenSim.Framework; | 38 | using OpenSim.Framework; |
39 | using OpenSim.Framework.Console; | 39 | using OpenSim.Framework.Console; |
40 | using OpenSim.Framework.Statistics; | 40 | using OpenSim.Framework.Statistics; |
41 | using OpenSim.Region.ClientStack.LindenUDP; | ||
42 | using OpenSim.Region.Environment.Interfaces; | 41 | using OpenSim.Region.Environment.Interfaces; |
43 | using OpenSim.Region.Environment.Scenes; | 42 | using OpenSim.Region.Environment.Scenes; |
44 | using Timer=System.Timers.Timer; | 43 | using Timer=System.Timers.Timer; |
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs b/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs index 5d45d99..f4dd127 100644 --- a/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs +++ b/OpenSim/Region/ClientStack/LindenUDP/LLClientView.cs | |||
@@ -4915,7 +4915,7 @@ namespace OpenSim.Region.ClientStack.LindenUDP | |||
4915 | } | 4915 | } |
4916 | catch (Exception) | 4916 | catch (Exception) |
4917 | { | 4917 | { |
4918 | //MainLog.Instance.Debug("UDPSERVER", e.ToString()); | 4918 | |
4919 | } | 4919 | } |
4920 | 4920 | ||
4921 | m_needAck.Add(key, packet); | 4921 | m_needAck.Add(key, packet); |
diff --git a/OpenSim/Region/ClientStack/RegionApplicationBase.cs b/OpenSim/Region/ClientStack/RegionApplicationBase.cs index 3fa2371..ba0b9b4 100644 --- a/OpenSim/Region/ClientStack/RegionApplicationBase.cs +++ b/OpenSim/Region/ClientStack/RegionApplicationBase.cs | |||
@@ -107,12 +107,12 @@ namespace OpenSim.Region.ClientStack | |||
107 | return physicsPluginManager.GetPhysicsScene(engine, meshEngine); | 107 | return physicsPluginManager.GetPhysicsScene(engine, meshEngine); |
108 | } | 108 | } |
109 | 109 | ||
110 | protected Scene SetupScene(RegionInfo regionInfo, out IClientNetworkServer udpServer, bool m_permissions) | 110 | protected Scene SetupScene(RegionInfo regionInfo, out IClientNetworkServer clientServer, bool m_permissions) |
111 | { | 111 | { |
112 | return SetupScene(regionInfo, 0, out udpServer, m_permissions); | 112 | return SetupScene(regionInfo, 0, out clientServer, m_permissions); |
113 | } | 113 | } |
114 | 114 | ||
115 | protected Scene SetupScene(RegionInfo regionInfo, int proxyOffset, out IClientNetworkServer udpServer, bool m_permissions) | 115 | protected Scene SetupScene(RegionInfo regionInfo, int proxyOffset, out IClientNetworkServer clientServer, bool m_permissions) |
116 | { | 116 | { |
117 | AgentCircuitManager circuitManager = new AgentCircuitManager(); | 117 | AgentCircuitManager circuitManager = new AgentCircuitManager(); |
118 | IPAddress listenIP = regionInfo.InternalEndPoint.Address; | 118 | IPAddress listenIP = regionInfo.InternalEndPoint.Address; |
@@ -120,12 +120,12 @@ namespace OpenSim.Region.ClientStack | |||
120 | // listenIP = IPAddress.Parse("0.0.0.0"); | 120 | // listenIP = IPAddress.Parse("0.0.0.0"); |
121 | 121 | ||
122 | uint port = (uint) regionInfo.InternalEndPoint.Port; | 122 | uint port = (uint) regionInfo.InternalEndPoint.Port; |
123 | udpServer = new LLUDPServer(listenIP, ref port, proxyOffset, regionInfo.m_allow_alternate_ports, m_assetCache, circuitManager); | 123 | clientServer = new LLUDPServer(listenIP, ref port, proxyOffset, regionInfo.m_allow_alternate_ports, m_assetCache, circuitManager); |
124 | regionInfo.InternalEndPoint.Port = (int)port; | 124 | regionInfo.InternalEndPoint.Port = (int)port; |
125 | 125 | ||
126 | Scene scene = CreateScene(regionInfo, m_storageManager, circuitManager); | 126 | Scene scene = CreateScene(regionInfo, m_storageManager, circuitManager); |
127 | 127 | ||
128 | udpServer.AddScene(scene); | 128 | clientServer.AddScene(scene); |
129 | 129 | ||
130 | scene.LoadWorldMap(); | 130 | scene.LoadWorldMap(); |
131 | 131 | ||
diff --git a/OpenSim/Region/Environment/Scenes/Scene.cs b/OpenSim/Region/Environment/Scenes/Scene.cs index 532d646..7d66bf4 100644 --- a/OpenSim/Region/Environment/Scenes/Scene.cs +++ b/OpenSim/Region/Environment/Scenes/Scene.cs | |||
@@ -1594,8 +1594,6 @@ namespace OpenSim.Region.Environment.Scenes | |||
1594 | client.OnMoveInventoryItem += MoveInventoryItem; | 1594 | client.OnMoveInventoryItem += MoveInventoryItem; |
1595 | client.OnRemoveInventoryItem += RemoveInventoryItem; | 1595 | client.OnRemoveInventoryItem += RemoveInventoryItem; |
1596 | client.OnRemoveInventoryFolder += RemoveInventoryFolder; | 1596 | client.OnRemoveInventoryFolder += RemoveInventoryFolder; |
1597 | // client.OnAssetUploadRequest += CommsManager.TransactionsManager.HandleUDPUploadRequest; | ||
1598 | // client.OnXferReceive += CommsManager.TransactionsManager.HandleXfer; | ||
1599 | client.OnRezScript += RezScript; | 1597 | client.OnRezScript += RezScript; |
1600 | 1598 | ||
1601 | client.OnRequestTaskInventory += RequestTaskInventory; | 1599 | client.OnRequestTaskInventory += RequestTaskInventory; |
diff --git a/OpenSim/Region/Environment/Scenes/ScenePresence.cs b/OpenSim/Region/Environment/Scenes/ScenePresence.cs index 74e9cdc..6a50336 100644 --- a/OpenSim/Region/Environment/Scenes/ScenePresence.cs +++ b/OpenSim/Region/Environment/Scenes/ScenePresence.cs | |||
@@ -224,7 +224,7 @@ namespace OpenSim.Region.Environment.Scenes | |||
224 | } | 224 | } |
225 | 225 | ||
226 | /// <summary> | 226 | /// <summary> |
227 | /// This works out to be the ClientView object associated with this avatar, or it's UDP connection manager | 227 | /// This works out to be the ClientView object associated with this avatar, or it's client connection manager |
228 | /// </summary> | 228 | /// </summary> |
229 | private IClientAPI m_controllingClient; | 229 | private IClientAPI m_controllingClient; |
230 | 230 | ||
diff --git a/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs b/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs index 668b413..9bccc0b 100644 --- a/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs +++ b/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs | |||
@@ -39,7 +39,6 @@ using Mono.Addins; | |||
39 | using Nwc.XmlRpc; | 39 | using Nwc.XmlRpc; |
40 | using OpenSim.Framework; | 40 | using OpenSim.Framework; |
41 | using OpenSim.Framework.Servers; | 41 | using OpenSim.Framework.Servers; |
42 | //using OpenSim.Region.ClientStack.LindenUDP; | ||
43 | using OpenSim.Region.ClientStack; | 42 | using OpenSim.Region.ClientStack; |
44 | using OpenSim.Region.ClientStack.LindenUDP; | 43 | using OpenSim.Region.ClientStack.LindenUDP; |
45 | using OpenSim.Region.Environment.Scenes; | 44 | using OpenSim.Region.Environment.Scenes; |
@@ -88,7 +87,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
88 | AsynchronousSocketListener.PacketHandler = new AsynchronousSocketListener.PacketRecieveHandler(SynchronizePacketRecieve); | 87 | AsynchronousSocketListener.PacketHandler = new AsynchronousSocketListener.PacketRecieveHandler(SynchronizePacketRecieve); |
89 | 88 | ||
90 | sceneManager = openSim.SceneManager; | 89 | sceneManager = openSim.SceneManager; |
91 | m_clientServers = openSim.UdpServers; | 90 | m_clientServers = openSim.ClientServers; |
92 | regionData = openSim.RegionData; | 91 | regionData = openSim.RegionData; |
93 | simMain = openSim; | 92 | simMain = openSim; |
94 | commandServer = openSim.HttpServer; | 93 | commandServer = openSim.HttpServer; |
@@ -390,7 +389,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
390 | return result; | 389 | return result; |
391 | } | 390 | } |
392 | 391 | ||
393 | private IClientNetworkServer SearchUDPServerFromPortNum(int portnum) | 392 | private IClientNetworkServer SearchClientServerFromPortNum(int portnum) |
394 | { | 393 | { |
395 | return m_clientServers.Find(delegate(IClientNetworkServer server) { return (portnum + proxyOffset == ((IPEndPoint)server.Server.LocalEndPoint).Port); }); | 394 | return m_clientServers.Find(delegate(IClientNetworkServer server) { return (portnum + proxyOffset == ((IPEndPoint)server.Server.LocalEndPoint).Port); }); |
396 | } | 395 | } |
@@ -522,12 +521,11 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
522 | Scene scene = null; | 521 | Scene scene = null; |
523 | string[] files = null; | 522 | string[] files = null; |
524 | IClientAPI controller = null; | 523 | IClientAPI controller = null; |
525 | IClientNetworkServer udpserv = null; | 524 | IClientNetworkServer clientserv = null; |
526 | 525 | ||
527 | if (sceneManager.TryGetScene(dst_region.RegionID, out scene)) | 526 | if (sceneManager.TryGetScene(dst_region.RegionID, out scene)) |
528 | { | 527 | { |
529 | // search udpserver | 528 | clientserv = SearchClientServerFromPortNum(scene.RegionInfo.InternalEndPoint.Port); |
530 | udpserv = SearchUDPServerFromPortNum(scene.RegionInfo.InternalEndPoint.Port); | ||
531 | 529 | ||
532 | // restore the scene presence | 530 | // restore the scene presence |
533 | for (int i = 0;; i++) | 531 | for (int i = 0;; i++) |
@@ -565,9 +563,9 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
565 | 563 | ||
566 | // BUG: Will only work with LLUDPServer. | 564 | // BUG: Will only work with LLUDPServer. |
567 | // TODO: This needs to be abstracted and converted into IClientNetworkServer | 565 | // TODO: This needs to be abstracted and converted into IClientNetworkServer |
568 | if (udpserv is LLUDPServer) | 566 | if (clientserv is LLUDPServer) |
569 | { | 567 | { |
570 | ((LLUDPServer) udpserv).RestoreClient(agentdata, data.userEP, data.proxyEP); | 568 | ((LLUDPServer) clientserv).RestoreClient(agentdata, data.userEP, data.proxyEP); |
571 | } | 569 | } |
572 | 570 | ||
573 | // waiting for the scene-presense restored | 571 | // waiting for the scene-presense restored |
@@ -627,12 +625,12 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
627 | } | 625 | } |
628 | 626 | ||
629 | // Shutting down the UDP server | 627 | // Shutting down the UDP server |
630 | IClientNetworkServer udpsvr = SearchUDPServerFromPortNum(port); | 628 | IClientNetworkServer clientsvr = SearchClientServerFromPortNum(port); |
631 | 629 | ||
632 | if (udpsvr != null) | 630 | if (clientsvr != null) |
633 | { | 631 | { |
634 | udpsvr.Server.Close(); | 632 | clientsvr.Server.Close(); |
635 | m_clientServers.Remove(udpsvr); | 633 | m_clientServers.Remove(clientsvr); |
636 | } | 634 | } |
637 | } | 635 | } |
638 | 636 | ||
diff --git a/ThirdParty/3Di/RegionProxy/RegionProxyPlugin.cs b/ThirdParty/3Di/RegionProxy/RegionProxyPlugin.cs index eaafe6c..e8ae8a9 100644 --- a/ThirdParty/3Di/RegionProxy/RegionProxyPlugin.cs +++ b/ThirdParty/3Di/RegionProxy/RegionProxyPlugin.cs | |||
@@ -295,7 +295,7 @@ namespace OpenSim.ApplicationPlugins.RegionProxy | |||
295 | 295 | ||
296 | try | 296 | try |
297 | { | 297 | { |
298 | m_log.InfoFormat("[PROXY] Opening UDP socket on {0}", sd.clientEP); | 298 | m_log.InfoFormat("[PROXY] Opening special UDP socket on {0}", sd.clientEP); |
299 | sd.serverIP = new IPEndPoint(IPAddress.Parse("0.0.0.0"), ((IPEndPoint) sd.clientEP).Port); | 299 | sd.serverIP = new IPEndPoint(IPAddress.Parse("0.0.0.0"), ((IPEndPoint) sd.clientEP).Port); |
300 | sd.server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); | 300 | sd.server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); |
301 | sd.server.Bind(sd.serverIP); | 301 | sd.server.Bind(sd.serverIP); |