diff options
author | Justin Clarke Casey | 2008-11-25 15:19:00 +0000 |
---|---|---|
committer | Justin Clarke Casey | 2008-11-25 15:19:00 +0000 |
commit | e187972377c19bdd85093677c4c54034e4f9196e (patch) | |
tree | cc1bb5f003628b018b823eafc9ee0a67f98df31c /OpenSim/Region/Environment/Scenes/Hypergrid/HGSceneCommunicationService.cs | |
parent | * Adding some virtual hooks and making some privaets protected for great just... (diff) | |
download | opensim-SC-e187972377c19bdd85093677c4c54034e4f9196e.zip opensim-SC-e187972377c19bdd85093677c4c54034e4f9196e.tar.gz opensim-SC-e187972377c19bdd85093677c4c54034e4f9196e.tar.bz2 opensim-SC-e187972377c19bdd85093677c4c54034e4f9196e.tar.xz |
* Apply http://opensimulator.org/mantis/view.php?id=2640
* This is Diva's hypergrid patch, as perviously discussed on the opensim-dev mailing list
* Applied some minor prebuild.xml jiggling to resolve a dependency issue
* Thanks Diva!
Diffstat (limited to 'OpenSim/Region/Environment/Scenes/Hypergrid/HGSceneCommunicationService.cs')
-rw-r--r-- | OpenSim/Region/Environment/Scenes/Hypergrid/HGSceneCommunicationService.cs | 263 |
1 files changed, 263 insertions, 0 deletions
diff --git a/OpenSim/Region/Environment/Scenes/Hypergrid/HGSceneCommunicationService.cs b/OpenSim/Region/Environment/Scenes/Hypergrid/HGSceneCommunicationService.cs new file mode 100644 index 0000000..501584a --- /dev/null +++ b/OpenSim/Region/Environment/Scenes/Hypergrid/HGSceneCommunicationService.cs | |||
@@ -0,0 +1,263 @@ | |||
1 | /** | ||
2 | * Copyright (c) 2008, Contributors. All rights reserved. | ||
3 | * See CONTRIBUTORS.TXT for a full list of copyright holders. | ||
4 | * | ||
5 | * Redistribution and use in source and binary forms, with or without modification, | ||
6 | * are permitted provided that the following conditions are met: | ||
7 | * | ||
8 | * * Redistributions of source code must retain the above copyright notice, | ||
9 | * this list of conditions and the following disclaimer. | ||
10 | * * Redistributions in binary form must reproduce the above copyright notice, | ||
11 | * this list of conditions and the following disclaimer in the documentation | ||
12 | * and/or other materials provided with the distribution. | ||
13 | * * Neither the name of the Organizations nor the names of Individual | ||
14 | * Contributors may be used to endorse or promote products derived from | ||
15 | * this software without specific prior written permission. | ||
16 | * | ||
17 | * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND | ||
18 | * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES | ||
19 | * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL | ||
20 | * THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, | ||
21 | * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE | ||
22 | * GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED | ||
23 | * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING | ||
24 | * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED | ||
25 | * OF THE POSSIBILITY OF SUCH DAMAGE. | ||
26 | * | ||
27 | */ | ||
28 | |||
29 | using System; | ||
30 | using System.Collections.Generic; | ||
31 | using System.Reflection; | ||
32 | using System.Threading; | ||
33 | |||
34 | using OpenMetaverse; | ||
35 | |||
36 | using log4net; | ||
37 | using OpenSim.Framework; | ||
38 | using OpenSim.Framework.Communications; | ||
39 | using OpenSim.Framework.Communications.Cache; | ||
40 | using OpenSim.Region.Environment.Scenes; | ||
41 | using OpenSim.Region.Environment; | ||
42 | using OpenSim.Region.Interfaces; | ||
43 | using OSD = OpenMetaverse.StructuredData.OSD; | ||
44 | |||
45 | namespace OpenSim.Region.Environment.Scenes.Hypergrid | ||
46 | { | ||
47 | public class HGSceneCommunicationService : SceneCommunicationService | ||
48 | { | ||
49 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | ||
50 | |||
51 | private IHyperlink m_hg; | ||
52 | |||
53 | public HGSceneCommunicationService(CommunicationsManager commsMan, IHyperlink hg) : base(commsMan) | ||
54 | { | ||
55 | m_hg = hg; | ||
56 | } | ||
57 | |||
58 | |||
59 | /// <summary> | ||
60 | /// Try to teleport an agent to a new region. | ||
61 | /// </summary> | ||
62 | /// <param name="remoteClient"></param> | ||
63 | /// <param name="RegionHandle"></param> | ||
64 | /// <param name="position"></param> | ||
65 | /// <param name="lookAt"></param> | ||
66 | /// <param name="flags"></param> | ||
67 | public override void RequestTeleportToLocation(ScenePresence avatar, ulong regionHandle, Vector3 position, | ||
68 | Vector3 lookAt, uint teleportFlags) | ||
69 | { | ||
70 | if (!avatar.Scene.Permissions.CanTeleport(avatar.UUID)) | ||
71 | return; | ||
72 | |||
73 | bool destRegionUp = false; | ||
74 | |||
75 | IEventQueue eq = avatar.Scene.RequestModuleInterface<IEventQueue>(); | ||
76 | |||
77 | if (regionHandle == m_regionInfo.RegionHandle) | ||
78 | { | ||
79 | // Teleport within the same region | ||
80 | if (position.X < 0 || position.X > Constants.RegionSize || position.Y < 0 || position.Y > Constants.RegionSize || position.Z < 0) | ||
81 | { | ||
82 | Vector3 emergencyPos = new Vector3(128, 128, 128); | ||
83 | |||
84 | m_log.WarnFormat( | ||
85 | "[HGSceneCommService]: RequestTeleportToLocation() was given an illegal position of {0} for avatar {1}, {2}. Substituting {3}", | ||
86 | position, avatar.Name, avatar.UUID, emergencyPos); | ||
87 | position = emergencyPos; | ||
88 | } | ||
89 | // TODO: Get proper AVG Height | ||
90 | float localAVHeight = 1.56f; | ||
91 | float posZLimit = (float)avatar.Scene.GetLandHeight((int)position.X, (int)position.Y); | ||
92 | float newPosZ = posZLimit + localAVHeight; | ||
93 | if (posZLimit >= (position.Z - (localAVHeight / 2)) && !(Single.IsInfinity(newPosZ) || Single.IsNaN(newPosZ))) | ||
94 | { | ||
95 | position.Z = newPosZ; | ||
96 | } | ||
97 | |||
98 | // Only send this if the event queue is null | ||
99 | if (eq == null) | ||
100 | avatar.ControllingClient.SendTeleportLocationStart(); | ||
101 | |||
102 | |||
103 | avatar.ControllingClient.SendLocalTeleport(position, lookAt, teleportFlags); | ||
104 | avatar.Teleport(position); | ||
105 | } | ||
106 | else | ||
107 | { | ||
108 | RegionInfo reg = RequestNeighbouringRegionInfo(regionHandle); | ||
109 | if (reg != null) | ||
110 | { | ||
111 | /// | ||
112 | /// Hypergrid mod start | ||
113 | /// | ||
114 | /// | ||
115 | bool isHyperLink = m_hg.IsHyperlinkRegion(reg.RegionHandle); | ||
116 | bool isHomeUser = true; | ||
117 | ulong realHandle = regionHandle; | ||
118 | CachedUserInfo uinfo = m_commsProvider.UserProfileCacheService.GetUserDetails(avatar.UUID); | ||
119 | if (uinfo != null) | ||
120 | { | ||
121 | isHomeUser = HGNetworkServersInfo.Singleton.IsLocalUser(uinfo.UserProfile.UserAssetURI); | ||
122 | realHandle = m_hg.FindRegionHandle(regionHandle); | ||
123 | Console.WriteLine("XXX ---- home user? " + isHomeUser + " --- hyperlink? " + isHyperLink + " --- real handle: " + realHandle.ToString()); | ||
124 | } | ||
125 | /// | ||
126 | /// Hypergrid mod stop | ||
127 | /// | ||
128 | /// | ||
129 | |||
130 | if (eq == null) | ||
131 | avatar.ControllingClient.SendTeleportLocationStart(); | ||
132 | |||
133 | AgentCircuitData agent = avatar.ControllingClient.RequestClientInfo(); | ||
134 | agent.BaseFolder = UUID.Zero; | ||
135 | agent.InventoryFolder = UUID.Zero; | ||
136 | agent.startpos = position; | ||
137 | agent.child = true; | ||
138 | |||
139 | if (reg.RemotingAddress != "" && reg.RemotingPort != 0) | ||
140 | { | ||
141 | // region is remote. see if it is up | ||
142 | destRegionUp = m_commsProvider.InterRegion.CheckRegion(reg.RemotingAddress, reg.RemotingPort); | ||
143 | } | ||
144 | else | ||
145 | { | ||
146 | // assume local regions are always up | ||
147 | destRegionUp = true; | ||
148 | } | ||
149 | |||
150 | if (destRegionUp) | ||
151 | { | ||
152 | // Fixing a bug where teleporting while sitting results in the avatar ending up removed from | ||
153 | // both regions | ||
154 | if (avatar.ParentID != (uint)0) | ||
155 | avatar.StandUp(); | ||
156 | if (!avatar.ValidateAttachments()) | ||
157 | { | ||
158 | avatar.ControllingClient.SendTeleportFailed("Inconsistent attachment state"); | ||
159 | return; | ||
160 | } | ||
161 | |||
162 | // the avatar.Close below will clear the child region list. We need this below for (possibly) | ||
163 | // closing the child agents, so save it here (we need a copy as it is Clear()-ed). | ||
164 | List<ulong> childRegions = new List<ulong>(avatar.GetKnownRegionList()); | ||
165 | // Compared to ScenePresence.CrossToNewRegion(), there's no obvious code to handle a teleport | ||
166 | // failure at this point (unlike a border crossing failure). So perhaps this can never fail | ||
167 | // once we reach here... | ||
168 | avatar.Scene.RemoveCapsHandler(avatar.UUID); | ||
169 | agent.child = false; | ||
170 | m_commsProvider.InterRegion.InformRegionOfChildAgent(reg.RegionHandle, agent); | ||
171 | |||
172 | m_commsProvider.InterRegion.ExpectAvatarCrossing(reg.RegionHandle, avatar.ControllingClient.AgentId, | ||
173 | position, false); | ||
174 | Thread.Sleep(2000); | ||
175 | AgentCircuitData circuitdata = avatar.ControllingClient.RequestClientInfo(); | ||
176 | |||
177 | // TODO Should construct this behind a method | ||
178 | string capsPath = | ||
179 | "http://" + reg.ExternalHostName + ":" + reg.HttpPort | ||
180 | + "/CAPS/" + circuitdata.CapsPath + "0000/"; | ||
181 | |||
182 | m_log.DebugFormat( | ||
183 | "[CAPS]: Sending new CAPS seed url {0} to client {1}", capsPath, avatar.UUID); | ||
184 | |||
185 | |||
186 | /// | ||
187 | /// Hypergrid mod: realHandle instead of reg.RegionHandle | ||
188 | /// | ||
189 | /// | ||
190 | if (eq != null) | ||
191 | { | ||
192 | OSD Item = EventQueueHelper.TeleportFinishEvent(realHandle, 13, reg.ExternalEndPoint, | ||
193 | 4, teleportFlags, capsPath, avatar.UUID); | ||
194 | eq.Enqueue(Item, avatar.UUID); | ||
195 | } | ||
196 | else | ||
197 | { | ||
198 | avatar.ControllingClient.SendRegionTeleport(realHandle, 13, reg.ExternalEndPoint, 4, | ||
199 | teleportFlags, capsPath); | ||
200 | } | ||
201 | /// | ||
202 | /// Hypergrid mod stop | ||
203 | /// | ||
204 | |||
205 | avatar.MakeChildAgent(); | ||
206 | Thread.Sleep(7000); | ||
207 | avatar.CrossAttachmentsIntoNewRegion(reg.RegionHandle, true); | ||
208 | if (KiPrimitive != null) | ||
209 | { | ||
210 | KiPrimitive(avatar.LocalId); | ||
211 | } | ||
212 | |||
213 | avatar.Close(); | ||
214 | |||
215 | uint newRegionX = (uint)(reg.RegionHandle >> 40); | ||
216 | uint newRegionY = (((uint)(reg.RegionHandle)) >> 8); | ||
217 | uint oldRegionX = (uint)(m_regionInfo.RegionHandle >> 40); | ||
218 | uint oldRegionY = (((uint)(m_regionInfo.RegionHandle)) >> 8); | ||
219 | /// | ||
220 | /// Hypergrid mod: extra check for isHyperLink | ||
221 | /// | ||
222 | if ((Util.fast_distance2d((int)(newRegionX - oldRegionX), (int)(newRegionY - oldRegionY)) > 3) || isHyperLink) | ||
223 | { | ||
224 | //SendCloseChildAgentConnections(avatar.UUID, avatar.GetKnownRegionList()); | ||
225 | SendCloseChildAgentConnections(avatar.UUID, childRegions); | ||
226 | CloseConnection(avatar.UUID); | ||
227 | } | ||
228 | // if (teleport success) // seems to be always success here | ||
229 | // the user may change their profile information in other region, | ||
230 | // so the userinfo in UserProfileCache is not reliable any more, delete it | ||
231 | if (avatar.Scene.NeedSceneCacheClear(avatar.UUID)) | ||
232 | m_commsProvider.UserProfileCacheService.RemoveUser(avatar.UUID); | ||
233 | m_log.InfoFormat("[HGSceneCommService]: User {0} is going to another region, profile cache removed", avatar.UUID); | ||
234 | } | ||
235 | else | ||
236 | { | ||
237 | avatar.ControllingClient.SendTeleportFailed("Remote Region appears to be down"); | ||
238 | } | ||
239 | } | ||
240 | else | ||
241 | { | ||
242 | // TP to a place that doesn't exist (anymore) | ||
243 | // Inform the viewer about that | ||
244 | avatar.ControllingClient.SendTeleportFailed("The region you tried to teleport to doesn't exist anymore"); | ||
245 | |||
246 | // and set the map-tile to '(Offline)' | ||
247 | uint regX, regY; | ||
248 | Utils.LongToUInts(regionHandle, out regX, out regY); | ||
249 | |||
250 | MapBlockData block = new MapBlockData(); | ||
251 | block.X = (ushort)(regX / Constants.RegionSize); | ||
252 | block.Y = (ushort)(regY / Constants.RegionSize); | ||
253 | block.Access = 254; // == not there | ||
254 | |||
255 | List<MapBlockData> blocks = new List<MapBlockData>(); | ||
256 | blocks.Add(block); | ||
257 | avatar.ControllingClient.SendMapBlock(blocks, 0); | ||
258 | } | ||
259 | } | ||
260 | } | ||
261 | |||
262 | } | ||
263 | } | ||