aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/ThirdParty/3Di/LoadBalancer
diff options
context:
space:
mode:
Diffstat (limited to 'ThirdParty/3Di/LoadBalancer')
-rw-r--r--ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs30
1 files changed, 15 insertions, 15 deletions
diff --git a/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs b/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs
index 325385a..b552d62 100644
--- a/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs
+++ b/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs
@@ -296,7 +296,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
296 return; 296 return;
297 } 297 }
298 298
299 simMain.ProxyCommand(src_region.proxyUrl, "BlockClientMessages", src_url, src_port + proxyOffset); 299 Util.XmlRpcCommand(src_region.proxyUrl, "BlockClientMessages", src_url, src_port + proxyOffset);
300 300
301 // serialization of origin region's data 301 // serialization of origin region's data
302 SerializeRegion(src_region, serializeDir); 302 SerializeRegion(src_region, serializeDir);
@@ -313,8 +313,8 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
313 // import the source region's data 313 // import the source region's data
314 dst_region = DeserializeRegion(dst_port, true, serializeDir); 314 dst_region = DeserializeRegion(dst_port, true, serializeDir);
315 315
316 simMain.ProxyCommand(dst_region.proxyUrl, "ChangeRegion", src_port + proxyOffset, src_url, dst_port + proxyOffset, dst_url); 316 Util.XmlRpcCommand(dst_region.proxyUrl, "ChangeRegion", src_port + proxyOffset, src_url, dst_port + proxyOffset, dst_url);
317 simMain.ProxyCommand(dst_region.proxyUrl, "UnblockClientMessages", dst_url, dst_port + proxyOffset); 317 Util.XmlRpcCommand(dst_region.proxyUrl, "UnblockClientMessages", dst_url, dst_port + proxyOffset);
318 } 318 }
319 319
320 private void DeserializeRegion_Clone(int src_port, int dst_port, string src_url, string dst_url) 320 private void DeserializeRegion_Clone(int src_port, int dst_port, string src_url, string dst_url)
@@ -331,11 +331,11 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
331 // Decide who is in charge for each section 331 // Decide who is in charge for each section
332 int[] port = new int[] { src_port, dst_port }; 332 int[] port = new int[] { src_port, dst_port };
333 string[] url = new string[] { "http://" + src_url + ":" + commandServer.Port, "http://" + dst_url + ":" + commandServer.Port }; 333 string[] url = new string[] { "http://" + src_url + ":" + commandServer.Port, "http://" + dst_url + ":" + commandServer.Port };
334 for(int i=0; i<2; i++) simMain.XmlRpcCommand(url[i], "SplitRegion", i, 2, port[0], port[1], url[0], url[1]); 334 for(int i=0; i<2; i++) Util.XmlRpcCommand(url[i], "SplitRegion", i, 2, port[0], port[1], url[0], url[1]);
335 335
336 // Enable the proxy 336 // Enable the proxy
337 simMain.ProxyCommand(dst_region.proxyUrl, "AddRegion", src_port + proxyOffset, src_url, dst_port + proxyOffset, dst_url); 337 Util.XmlRpcCommand(dst_region.proxyUrl, "AddRegion", src_port + proxyOffset, src_url, dst_port + proxyOffset, dst_url);
338 simMain.ProxyCommand(dst_region.proxyUrl, "UnblockClientMessages", dst_url, dst_port + proxyOffset); 338 Util.XmlRpcCommand(dst_region.proxyUrl, "UnblockClientMessages", dst_url, dst_port + proxyOffset);
339 } 339 }
340 340
341 private void TerminateRegion(object param) 341 private void TerminateRegion(object param)
@@ -758,7 +758,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
758 ++i; 758 ++i;
759 } 759 }
760 } 760 }
761 761
762 scene.splitID = myID; 762 scene.splitID = myID;
763 scene.SynchronizeScene = new Scene.SynchronizeSceneHandler(SynchronizeScenes); 763 scene.SynchronizeScene = new Scene.SynchronizeSceneHandler(SynchronizeScenes);
764 isSplit = true; 764 isSplit = true;
@@ -789,7 +789,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
789 789
790 RegionInfo region = SearchRegionFromPortNum(src_port); 790 RegionInfo region = SearchRegionFromPortNum(src_port);
791 791
792 simMain.ProxyCommand(region.proxyUrl, "BlockClientMessages", src_url, src_port + proxyOffset); 792 Util.XmlRpcCommand(region.proxyUrl, "BlockClientMessages", src_url, src_port + proxyOffset);
793 793
794 Scene scene; 794 Scene scene;
795 if (sceneManager.TryGetScene(region.RegionID, out scene)) 795 if (sceneManager.TryGetScene(region.RegionID, out scene))
@@ -815,12 +815,12 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
815 for(int i=1; i<sceneURL.Length; i++) 815 for(int i=1; i<sceneURL.Length; i++)
816 { 816 {
817 string url = (sceneURL[i].Split('/')[2]).Split(':')[0]; // get URL part from EP 817 string url = (sceneURL[i].Split('/')[2]).Split(':')[0]; // get URL part from EP
818 simMain.ProxyCommand(region.proxyUrl, "DeleteRegion", regionPortList[i] + proxyOffset, url); 818 Util.XmlRpcCommand(region.proxyUrl, "DeleteRegion", regionPortList[i] + proxyOffset, url);
819 Thread.Sleep(1000); 819 Thread.Sleep(1000);
820 simMain.XmlRpcCommand(sceneURL[i], "TerminateRegion", regionPortList[i]); // TODO: need + proxyOffset? 820 Util.XmlRpcCommand(sceneURL[i], "TerminateRegion", regionPortList[i]); // TODO: need + proxyOffset?
821 } 821 }
822 822
823 simMain.ProxyCommand(region.proxyUrl, "UnblockClientMessages", src_url, src_port + proxyOffset); 823 Util.XmlRpcCommand(region.proxyUrl, "UnblockClientMessages", src_url, src_port + proxyOffset);
824 } 824 }
825 catch (Exception e) 825 catch (Exception e)
826 { 826 {
@@ -922,10 +922,10 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
922 // pre.Velocity.ToString(), pre.PhysicsActor.Flying); 922 // pre.Velocity.ToString(), pre.PhysicsActor.Flying);
923 923
924 924
925 simMain.XmlRpcCommand(sceneURL[i], "UpdatePhysics", 925 Util.XmlRpcCommand(sceneURL[i], "UpdatePhysics",
926 regionPortList[i], pre.UUID.GetBytes(), 926 regionPortList[i], pre.UUID.GetBytes(),
927 pre.AbsolutePosition.GetBytes(), pre.Velocity.GetBytes(), 927 pre.AbsolutePosition.GetBytes(), pre.Velocity.GetBytes(),
928 pre.PhysicsActor.Flying); 928 pre.PhysicsActor.Flying);
929 929
930/* 930/*
931 byte[] buff = new byte[12+12+1]; 931 byte[] buff = new byte[12+12+1];