aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/ThirdParty/3Di/LoadBalancer
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs26
-rw-r--r--ThirdParty/3Di/LoadBalancer/TcpServer.cs2
2 files changed, 14 insertions, 14 deletions
diff --git a/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs b/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs
index 25147d0..bdddbbb 100644
--- a/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs
+++ b/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs
@@ -839,8 +839,8 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
839 { 839 {
840 //m_log.Info("[SPLITSCENE] "+String.Format("UpdatePhysics called {0}", regionID)); 840 //m_log.Info("[SPLITSCENE] "+String.Format("UpdatePhysics called {0}", regionID));
841 841
842 //m_log.Info("[SPLITSCENE] "+"LocalUpdatePhysics [region port:{0}, client:{1}, position:{2}, velocity:{3}, flying:{4}]", 842 //m_log.Info("[SPLITSCENE] "+"LocalUpdatePhysics [region port:{0}, client:{1}, position:{2}, velocity:{3}, flying:{4}]",
843 // regionPort, scenePresenceID.ToString(), position.ToString(), 843 // regionPort, scenePresenceID.ToString(), position.ToString(),
844 // velocity.ToString(), flying); 844 // velocity.ToString(), flying);
845 845
846 RegionInfo region = SearchRegionFromPortNum(regionPort); 846 RegionInfo region = SearchRegionFromPortNum(regionPort);
@@ -857,7 +857,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
857 return; 857 return;
858 } 858 }
859 859
860// m_log.Info("[SPLITSCENE] "+"LocalUpdatePhysics [region:{0}, client:{1}]", 860// m_log.Info("[SPLITSCENE] "+"LocalUpdatePhysics [region:{0}, client:{1}]",
861// regionID.ToString(), pre.UUID.ToString()); 861// regionID.ToString(), pre.UUID.ToString());
862 862
863 pre.AbsolutePosition = position; // will set PhysicsActor.Position 863 pre.AbsolutePosition = position; // will set PhysicsActor.Position
@@ -882,9 +882,9 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
882 { 882 {
883 LLClientView client = (LLClientView) pre.ControllingClient; 883 LLClientView client = (LLClientView) pre.ControllingClient;
884 884
885 // Because data changes by the physics simulation when the client doesn't move, 885 // Because data changes by the physics simulation when the client doesn't move,
886 // if MovementFlag is false, It is necessary to synchronize. 886 // if MovementFlag is false, It is necessary to synchronize.
887 //if (pre.MovementFlag!=0 && client.PacketProcessingEnabled==true) 887 //if (pre.MovementFlag!=0 && client.PacketProcessingEnabled==true)
888 if (client.IsActive) 888 if (client.IsActive)
889 { 889 {
890 //m_log.Info("[SPLITSCENE] "+String.Format("Client moving in {0} {1}", scene.RegionInfo.RegionID, pre.AbsolutePosition)); 890 //m_log.Info("[SPLITSCENE] "+String.Format("Client moving in {0} {1}", scene.RegionInfo.RegionID, pre.AbsolutePosition));
@@ -898,14 +898,14 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
898 898
899 if (isLocalNeighbour[i]) 899 if (isLocalNeighbour[i])
900 { 900 {
901 //m_log.Info("[SPLITSCENE] "+"Synchronize ScenePresence (Local) [region:{0}=>{1}, client:{2}]", 901 //m_log.Info("[SPLITSCENE] "+"Synchronize ScenePresence (Local) [region:{0}=>{1}, client:{2}]",
902 // scene.RegionInfo.RegionID, regionPortList[i], pre.UUID.ToString()); 902 // scene.RegionInfo.RegionID, regionPortList[i], pre.UUID.ToString());
903 LocalUpdatePhysics(regionPortList[i], pre.UUID, pre.AbsolutePosition, pre.Velocity, pre.PhysicsActor.Flying); 903 LocalUpdatePhysics(regionPortList[i], pre.UUID, pre.AbsolutePosition, pre.Velocity, pre.PhysicsActor.Flying);
904 } 904 }
905 else 905 else
906 { 906 {
907 //m_log.Info("[SPLITSCENE] "+"Synchronize ScenePresence (Remote) [region port:{0}, client:{1}, position:{2}, velocity:{3}, flying:{4}]", 907 //m_log.Info("[SPLITSCENE] "+"Synchronize ScenePresence (Remote) [region port:{0}, client:{1}, position:{2}, velocity:{3}, flying:{4}]",
908 // regionPortList[i], pre.UUID.ToString(), pre.AbsolutePosition.ToString(), 908 // regionPortList[i], pre.UUID.ToString(), pre.AbsolutePosition.ToString(),
909 // pre.Velocity.ToString(), pre.PhysicsActor.Flying); 909 // pre.Velocity.ToString(), pre.PhysicsActor.Flying);
910 910
911 911
@@ -917,8 +917,8 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
917/* 917/*
918 byte[] buff = new byte[12+12+1]; 918 byte[] buff = new byte[12+12+1];
919 919
920 Buffer.BlockCopy(pre.AbsolutePosition.GetBytes(), 0, buff, 0, 12); 920 Buffer.BlockCopy(pre.AbsolutePosition.GetBytes(), 0, buff, 0, 12);
921 Buffer.BlockCopy(pre.Velocity.GetBytes(), 0, buff, 12, 12); 921 Buffer.BlockCopy(pre.Velocity.GetBytes(), 0, buff, 12, 12);
922 buff[24] = (byte)((pre.PhysicsActor.Flying)?1:0); 922 buff[24] = (byte)((pre.PhysicsActor.Flying)?1:0);
923 923
924 // create header 924 // create header
@@ -959,13 +959,13 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
959 959
960 if (isLocalNeighbour[i]) 960 if (isLocalNeighbour[i])
961 { 961 {
962 //m_log.Info("[SPLITSCENE] "+"Synchronize Packet (Local) [type:{0}, client:{1}]", 962 //m_log.Info("[SPLITSCENE] "+"Synchronize Packet (Local) [type:{0}, client:{1}]",
963 // packet.Type.ToString(), agentID.ToString()); 963 // packet.Type.ToString(), agentID.ToString());
964 LocalUpdatePacket(regionPortList[i], agentID, packet, throttlePacketType); 964 LocalUpdatePacket(regionPortList[i], agentID, packet, throttlePacketType);
965 } 965 }
966 else 966 else
967 { 967 {
968 //m_log.Info("[SPLITSCENE] "+"Synchronize Packet (Remote) [type:{0}, client:{1}]", 968 //m_log.Info("[SPLITSCENE] "+"Synchronize Packet (Remote) [type:{0}, client:{1}]",
969 // packet.Type.ToString(), agentID.ToString()); 969 // packet.Type.ToString(), agentID.ToString());
970 // to bytes 970 // to bytes
971 byte[] buff = packet.ToBytes(); 971 byte[] buff = packet.ToBytes();
@@ -995,7 +995,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
995 995
996 RegionInfo region = SearchRegionFromPortNum(regionPort); 996 RegionInfo region = SearchRegionFromPortNum(regionPort);
997 997
998// m_log.Info("[SPLITSCENE] "+"LocalUpdatePacket [region port:{0}, client:{1}, packet type:{2}]", 998// m_log.Info("[SPLITSCENE] "+"LocalUpdatePacket [region port:{0}, client:{1}, packet type:{2}]",
999// regionPort, agentID.ToString(), packet.GetType().ToString()); 999// regionPort, agentID.ToString(), packet.GetType().ToString());
1000 1000
1001 if (sceneManager.TryGetScene(region.RegionID, out scene)) 1001 if (sceneManager.TryGetScene(region.RegionID, out scene))
diff --git a/ThirdParty/3Di/LoadBalancer/TcpServer.cs b/ThirdParty/3Di/LoadBalancer/TcpServer.cs
index 1457299..fd5e9e2 100644
--- a/ThirdParty/3Di/LoadBalancer/TcpServer.cs
+++ b/ThirdParty/3Di/LoadBalancer/TcpServer.cs
@@ -144,7 +144,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer
144 { 144 {
145 //MainLog.Instance.Verbose("TCPSERVER", "Processing body"); 145 //MainLog.Instance.Verbose("TCPSERVER", "Processing body");
146 146
147 // reading body 147 // reading body
148 byte[] packet = new byte[state.header.numbytes]; 148 byte[] packet = new byte[state.header.numbytes];
149 state.ms_ptr.Position = current_pos + TcpClient.internalPacketHeaderSize; 149 state.ms_ptr.Position = current_pos + TcpClient.internalPacketHeaderSize;
150 state.ms_ptr.Read(packet, 0, state.header.numbytes); 150 state.ms_ptr.Read(packet, 0, state.header.numbytes);