diff options
author | Teravus Ovares | 2008-09-06 07:52:41 +0000 |
---|---|---|
committer | Teravus Ovares | 2008-09-06 07:52:41 +0000 |
commit | 7d89e122930be39e84a6d174548fa2d12ac0484a (patch) | |
tree | e5aa5752f988a9aba2a969f49e5e208985eda80c /ThirdParty/3Di/LoadBalancer | |
parent | * minor: speculatively try a change to bamboo.build to see if this generates ... (diff) | |
download | opensim-SC_OLD-7d89e122930be39e84a6d174548fa2d12ac0484a.zip opensim-SC_OLD-7d89e122930be39e84a6d174548fa2d12ac0484a.tar.gz opensim-SC_OLD-7d89e122930be39e84a6d174548fa2d12ac0484a.tar.bz2 opensim-SC_OLD-7d89e122930be39e84a6d174548fa2d12ac0484a.tar.xz |
* This is the fabled LibOMV update with all of the libOMV types from JHurliman
* This is a HUGE OMG update and will definitely have unknown side effects.. so this is really only for the strong hearted at this point. Regular people should let the dust settle.
* This has been tested to work with most basic functions. However.. make sure you back up 'everything' before using this. It's that big!
* Essentially we're back at square 1 in the testing phase.. so lets identify things that broke.
Diffstat (limited to 'ThirdParty/3Di/LoadBalancer')
-rw-r--r-- | ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs | 38 |
1 files changed, 19 insertions, 19 deletions
diff --git a/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs b/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs index a724a23..396ad59 100644 --- a/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs +++ b/ThirdParty/3Di/LoadBalancer/LoadBalancerPlugin.cs | |||
@@ -32,8 +32,8 @@ using System.IO; | |||
32 | using System.Net; | 32 | using System.Net; |
33 | using System.Reflection; | 33 | using System.Reflection; |
34 | using System.Threading; | 34 | using System.Threading; |
35 | using libsecondlife; | 35 | using OpenMetaverse; |
36 | using libsecondlife.Packets; | 36 | using OpenMetaverse.Packets; |
37 | using log4net; | 37 | using log4net; |
38 | using Mono.Addins; | 38 | using Mono.Addins; |
39 | using Nwc.XmlRpc; | 39 | using Nwc.XmlRpc; |
@@ -600,7 +600,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
600 | { | 600 | { |
601 | if (createID_flag) | 601 | if (createID_flag) |
602 | { | 602 | { |
603 | dst_region.RegionID = LLUUID.Random(); | 603 | dst_region.RegionID = UUID.Random(); |
604 | } | 604 | } |
605 | 605 | ||
606 | // change RegionInfo (memory only) | 606 | // change RegionInfo (memory only) |
@@ -611,7 +611,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
611 | simMain.CreateRegion(dst_region, false); | 611 | simMain.CreateRegion(dst_region, false); |
612 | } | 612 | } |
613 | 613 | ||
614 | private void RemoveRegion(LLUUID regionID, int port) | 614 | private void RemoveRegion(UUID regionID, int port) |
615 | { | 615 | { |
616 | Scene killScene; | 616 | Scene killScene; |
617 | if (sceneManager.TryGetScene(regionID, out killScene)) | 617 | if (sceneManager.TryGetScene(regionID, out killScene)) |
@@ -834,9 +834,9 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
834 | // this callback receives physic scene updates from the other sub-scenes (in split mode) | 834 | // this callback receives physic scene updates from the other sub-scenes (in split mode) |
835 | 835 | ||
836 | int regionPort = (int) request.Params[0]; | 836 | int regionPort = (int) request.Params[0]; |
837 | LLUUID scenePresenceID = new LLUUID((byte[]) request.Params[1], 0); | 837 | UUID scenePresenceID = new UUID((byte[]) request.Params[1], 0); |
838 | LLVector3 position = new LLVector3((byte[]) request.Params[2], 0); | 838 | Vector3 position = new Vector3((byte[]) request.Params[2], 0); |
839 | LLVector3 velocity = new LLVector3((byte[]) request.Params[3], 0); | 839 | Vector3 velocity = new Vector3((byte[]) request.Params[3], 0); |
840 | bool flying = (bool) request.Params[4]; | 840 | bool flying = (bool) request.Params[4]; |
841 | 841 | ||
842 | LocalUpdatePhysics(regionPort, scenePresenceID, position, velocity, flying); | 842 | LocalUpdatePhysics(regionPort, scenePresenceID, position, velocity, flying); |
@@ -844,7 +844,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
844 | return new XmlRpcResponse(); | 844 | return new XmlRpcResponse(); |
845 | } | 845 | } |
846 | 846 | ||
847 | private void LocalUpdatePhysics(int regionPort, LLUUID scenePresenceID, LLVector3 position, LLVector3 velocity, bool flying) | 847 | private void LocalUpdatePhysics(int regionPort, UUID scenePresenceID, Vector3 position, Vector3 velocity, bool flying) |
848 | { | 848 | { |
849 | //m_log.Info("[SPLITSCENE] "+String.Format("UpdatePhysics called {0}", regionID)); | 849 | //m_log.Info("[SPLITSCENE] "+String.Format("UpdatePhysics called {0}", regionID)); |
850 | 850 | ||
@@ -867,7 +867,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
867 | } | 867 | } |
868 | 868 | ||
869 | // m_log.Info("[SPLITSCENE] "+"LocalUpdatePhysics [region:{0}, client:{1}]", | 869 | // m_log.Info("[SPLITSCENE] "+"LocalUpdatePhysics [region:{0}, client:{1}]", |
870 | // regionID.ToString(), pre.UUID.ToString()); | 870 | // regionID.ToString(), pre.ToString()); |
871 | 871 | ||
872 | pre.AbsolutePosition = position; // will set PhysicsActor.Position | 872 | pre.AbsolutePosition = position; // will set PhysicsActor.Position |
873 | pre.Velocity = velocity; // will set PhysicsActor.Velocity | 873 | pre.Velocity = velocity; // will set PhysicsActor.Velocity |
@@ -908,13 +908,13 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
908 | if (isLocalNeighbour[i]) | 908 | if (isLocalNeighbour[i]) |
909 | { | 909 | { |
910 | //m_log.Info("[SPLITSCENE] "+"Synchronize ScenePresence (Local) [region:{0}=>{1}, client:{2}]", | 910 | //m_log.Info("[SPLITSCENE] "+"Synchronize ScenePresence (Local) [region:{0}=>{1}, client:{2}]", |
911 | // scene.RegionInfo.RegionID, regionPortList[i], pre.UUID.ToString()); | 911 | // scene.RegionInfo.RegionID, regionPortList[i], pre.ToString()); |
912 | LocalUpdatePhysics(regionPortList[i], pre.UUID, pre.AbsolutePosition, pre.Velocity, pre.PhysicsActor.Flying); | 912 | LocalUpdatePhysics(regionPortList[i], pre.UUID, pre.AbsolutePosition, pre.Velocity, pre.PhysicsActor.Flying); |
913 | } | 913 | } |
914 | else | 914 | else |
915 | { | 915 | { |
916 | //m_log.Info("[SPLITSCENE] "+"Synchronize ScenePresence (Remote) [region port:{0}, client:{1}, position:{2}, velocity:{3}, flying:{4}]", | 916 | //m_log.Info("[SPLITSCENE] "+"Synchronize ScenePresence (Remote) [region port:{0}, client:{1}, position:{2}, velocity:{3}, flying:{4}]", |
917 | // regionPortList[i], pre.UUID.ToString(), pre.AbsolutePosition.ToString(), | 917 | // regionPortList[i], pre.ToString(), pre.AbsolutePosition.ToString(), |
918 | // pre.Velocity.ToString(), pre.PhysicsActor.Flying); | 918 | // pre.Velocity.ToString(), pre.PhysicsActor.Flying); |
919 | 919 | ||
920 | 920 | ||
@@ -936,7 +936,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
936 | header.type = 1; | 936 | header.type = 1; |
937 | header.throttlePacketType = 0; | 937 | header.throttlePacketType = 0; |
938 | header.numbytes = buff.Length; | 938 | header.numbytes = buff.Length; |
939 | header.agent_id = pre.UUID.UUID; | 939 | header.agent_id = pre.UUID.Guid; |
940 | header.region_port = regionPortList[i]; | 940 | header.region_port = regionPortList[i]; |
941 | 941 | ||
942 | //Send | 942 | //Send |
@@ -950,7 +950,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
950 | } | 950 | } |
951 | } | 951 | } |
952 | 952 | ||
953 | public bool SynchronizePackets(IScene scene, Packet packet, LLUUID agentID, ThrottleOutPacketType throttlePacketType) | 953 | public bool SynchronizePackets(IScene scene, Packet packet, UUID agentID, ThrottleOutPacketType throttlePacketType) |
954 | { | 954 | { |
955 | if (!isSplit) | 955 | if (!isSplit) |
956 | { | 956 | { |
@@ -985,7 +985,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
985 | header.type = 0; | 985 | header.type = 0; |
986 | header.throttlePacketType = (int) throttlePacketType; | 986 | header.throttlePacketType = (int) throttlePacketType; |
987 | header.numbytes = buff.Length; | 987 | header.numbytes = buff.Length; |
988 | header.agent_id = agentID.UUID; | 988 | header.agent_id = agentID.Guid; |
989 | header.region_port = regionPortList[i]; | 989 | header.region_port = regionPortList[i]; |
990 | 990 | ||
991 | //Send | 991 | //Send |
@@ -998,7 +998,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
998 | return true; | 998 | return true; |
999 | } | 999 | } |
1000 | 1000 | ||
1001 | private void LocalUpdatePacket(int regionPort, LLUUID agentID, Packet packet, ThrottleOutPacketType throttlePacketType) | 1001 | private void LocalUpdatePacket(int regionPort, UUID agentID, Packet packet, ThrottleOutPacketType throttlePacketType) |
1002 | { | 1002 | { |
1003 | Scene scene; | 1003 | Scene scene; |
1004 | 1004 | ||
@@ -1060,7 +1060,7 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
1060 | 1060 | ||
1061 | Packet packet = PacketPool.Instance.GetPacket(buff, ref packetEnd, zero); | 1061 | Packet packet = PacketPool.Instance.GetPacket(buff, ref packetEnd, zero); |
1062 | 1062 | ||
1063 | LocalUpdatePacket(header.region_port, new LLUUID(header.agent_id), | 1063 | LocalUpdatePacket(header.region_port, new UUID(header.agent_id), |
1064 | packet, (ThrottleOutPacketType) header.throttlePacketType); | 1064 | packet, (ThrottleOutPacketType) header.throttlePacketType); |
1065 | } | 1065 | } |
1066 | catch (Exception e) | 1066 | catch (Exception e) |
@@ -1074,9 +1074,9 @@ namespace OpenSim.ApplicationPlugins.LoadBalancer | |||
1074 | case 1: | 1074 | case 1: |
1075 | 1075 | ||
1076 | int regionPort = header.region_port; | 1076 | int regionPort = header.region_port; |
1077 | LLUUID scenePresenceID = new LLUUID(header.agent_id); | 1077 | UUID scenePresenceID = new UUID(header.agent_id); |
1078 | LLVector3 position = new LLVector3(buff, 0); | 1078 | Vector3 position = new Vector3(buff, 0); |
1079 | LLVector3 velocity = new LLVector3(buff, 12); | 1079 | Vector3 velocity = new Vector3(buff, 12); |
1080 | bool flying = ((buff[24] == 1) ? true : false); | 1080 | bool flying = ((buff[24] == 1) ? true : false); |
1081 | 1081 | ||
1082 | LocalUpdatePhysics(regionPort, scenePresenceID, position, velocity, flying); | 1082 | LocalUpdatePhysics(regionPort, scenePresenceID, position, velocity, flying); |