diff options
This is a beefy commit containing the communication modules that implement SendChildAgentUpdate. This commit has only the modules, but not their usage. It should be harmless.
Diffstat (limited to 'OpenSim/Region/Environment/Modules/Communications/REST')
-rw-r--r-- | OpenSim/Region/Environment/Modules/Communications/REST/HGInterregionComms.cs | 86 | ||||
-rw-r--r-- | OpenSim/Region/Environment/Modules/Communications/REST/RESTInterregionComms.cs | 296 |
2 files changed, 382 insertions, 0 deletions
diff --git a/OpenSim/Region/Environment/Modules/Communications/REST/HGInterregionComms.cs b/OpenSim/Region/Environment/Modules/Communications/REST/HGInterregionComms.cs new file mode 100644 index 0000000..e570f99 --- /dev/null +++ b/OpenSim/Region/Environment/Modules/Communications/REST/HGInterregionComms.cs | |||
@@ -0,0 +1,86 @@ | |||
1 | /* | ||
2 | * Copyright (c) Contributors, http://opensimulator.org/ | ||
3 | * See CONTRIBUTORS.TXT for a full list of copyright holders. | ||
4 | * | ||
5 | * Redistribution and use in source and binary forms, with or without | ||
6 | * modification, are permitted provided that the following conditions are met: | ||
7 | * * Redistributions of source code must retain the above copyright | ||
8 | * notice, this list of conditions and the following disclaimer. | ||
9 | * * Redistributions in binary form must reproduce the above copyright | ||
10 | * notice, this list of conditions and the following disclaimer in the | ||
11 | * documentation and/or other materials provided with the distribution. | ||
12 | * * Neither the name of the OpenSim Project nor the | ||
13 | * names of its contributors may be used to endorse or promote products | ||
14 | * derived from this software without specific prior written permission. | ||
15 | * | ||
16 | * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY | ||
17 | * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | ||
18 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE | ||
19 | * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY | ||
20 | * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES | ||
21 | * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | ||
22 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND | ||
23 | * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | ||
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. | ||
26 | */ | ||
27 | using System; | ||
28 | using System.Collections; | ||
29 | using System.Collections.Generic; | ||
30 | using System.Reflection; | ||
31 | using log4net; | ||
32 | using Nini.Config; | ||
33 | using OpenSim.Framework; | ||
34 | using OpenSim.Framework.Communications; | ||
35 | using OpenSim.Framework.Communications.Cache; | ||
36 | using OpenSim.Region.Environment.Interfaces; | ||
37 | using OpenSim.Region.Interfaces; | ||
38 | using OpenSim.Region.Environment.Scenes; | ||
39 | using OpenSim.Region.Environment.Scenes.Hypergrid; | ||
40 | |||
41 | namespace OpenSim.Region.Environment.Modules.Communications.REST | ||
42 | { | ||
43 | public class HGInterregionComms : RESTInterregionComms | ||
44 | { | ||
45 | private static bool initialized = false; | ||
46 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | ||
47 | |||
48 | #region IRegionModule | ||
49 | |||
50 | public override void Initialise(Scene scene, IConfigSource config) | ||
51 | { | ||
52 | if (!initialized) | ||
53 | { | ||
54 | initialized = true; | ||
55 | IConfig startupConfig = config.Configs["Communications"]; | ||
56 | if ((startupConfig != null) && (startupConfig.GetString("InterregionComms", "LocalComms") == "HGRESTComms")) | ||
57 | { | ||
58 | m_enabled = true; | ||
59 | InitOnce(scene); | ||
60 | } | ||
61 | } | ||
62 | |||
63 | if (!m_enabled) | ||
64 | return; | ||
65 | |||
66 | InitEach(scene); | ||
67 | } | ||
68 | |||
69 | public override string Name | ||
70 | { | ||
71 | get { return "HGInterregionCommsModule"; } | ||
72 | } | ||
73 | |||
74 | #endregion /* IRegionModule */ | ||
75 | |||
76 | #region Misc | ||
77 | |||
78 | protected override ulong GetRegionHandle(RegionInfo region) | ||
79 | { | ||
80 | return ((HGSceneCommunicationService)(m_aScene.SceneGridService)).m_hg.FindRegionHandle(region.RegionHandle); | ||
81 | } | ||
82 | |||
83 | #endregion /* Misc */ | ||
84 | |||
85 | } | ||
86 | } | ||
diff --git a/OpenSim/Region/Environment/Modules/Communications/REST/RESTInterregionComms.cs b/OpenSim/Region/Environment/Modules/Communications/REST/RESTInterregionComms.cs new file mode 100644 index 0000000..7ff38c9 --- /dev/null +++ b/OpenSim/Region/Environment/Modules/Communications/REST/RESTInterregionComms.cs | |||
@@ -0,0 +1,296 @@ | |||
1 | /* | ||
2 | * Copyright (c) Contributors, http://opensimulator.org/ | ||
3 | * See CONTRIBUTORS.TXT for a full list of copyright holders. | ||
4 | * | ||
5 | * Redistribution and use in source and binary forms, with or without | ||
6 | * modification, are permitted provided that the following conditions are met: | ||
7 | * * Redistributions of source code must retain the above copyright | ||
8 | * notice, this list of conditions and the following disclaimer. | ||
9 | * * Redistributions in binary form must reproduce the above copyright | ||
10 | * notice, this list of conditions and the following disclaimer in the | ||
11 | * documentation and/or other materials provided with the distribution. | ||
12 | * * Neither the name of the OpenSim Project nor the | ||
13 | * names of its contributors may be used to endorse or promote products | ||
14 | * derived from this software without specific prior written permission. | ||
15 | * | ||
16 | * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY | ||
17 | * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | ||
18 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE | ||
19 | * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY | ||
20 | * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES | ||
21 | * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | ||
22 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND | ||
23 | * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | ||
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. | ||
26 | */ | ||
27 | using System; | ||
28 | using System.Collections; | ||
29 | using System.Collections.Generic; | ||
30 | using System.IO; | ||
31 | using System.Net; | ||
32 | using System.Net.Sockets; | ||
33 | using System.Reflection; | ||
34 | using System.Threading; | ||
35 | using System.Xml; | ||
36 | using OpenMetaverse; | ||
37 | using OpenMetaverse.StructuredData; | ||
38 | using log4net; | ||
39 | using Nini.Config; | ||
40 | using Nwc.XmlRpc; | ||
41 | using OpenSim.Framework; | ||
42 | using OpenSim.Framework.Communications; | ||
43 | using OpenSim.Framework.Communications.Cache; | ||
44 | using OpenSim.Region.Environment.Interfaces; | ||
45 | using OpenSim.Region.Interfaces; | ||
46 | using OpenSim.Region.Environment.Scenes; | ||
47 | using OpenSim.Region.Environment.Modules.Communications.Local; | ||
48 | |||
49 | namespace OpenSim.Region.Environment.Modules.Communications.REST | ||
50 | { | ||
51 | public class RESTInterregionComms : IRegionModule, IInterregionCommsOut | ||
52 | { | ||
53 | private static bool initialized = false; | ||
54 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | ||
55 | |||
56 | protected bool m_enabled = false; | ||
57 | protected Scene m_aScene; | ||
58 | // RESTInterregionComms does not care about local regions; it delegates that to the Local module | ||
59 | protected LocalInterregionComms m_localBackend; | ||
60 | |||
61 | protected CommunicationsManager m_commsManager; | ||
62 | |||
63 | #region IRegionModule | ||
64 | |||
65 | public virtual void Initialise(Scene scene, IConfigSource config) | ||
66 | { | ||
67 | if (!initialized) | ||
68 | { | ||
69 | initialized = true; | ||
70 | IConfig startupConfig = config.Configs["Communications"]; | ||
71 | if ((startupConfig != null) && (startupConfig.GetString("InterregionComms", "LocalComms") == "RESTComms")) | ||
72 | { | ||
73 | m_enabled = true; | ||
74 | InitOnce(scene); | ||
75 | } | ||
76 | } | ||
77 | |||
78 | if (!m_enabled) | ||
79 | return; | ||
80 | |||
81 | InitEach(scene); | ||
82 | |||
83 | } | ||
84 | |||
85 | public virtual void PostInitialise() | ||
86 | { | ||
87 | if (m_enabled) | ||
88 | AddHTTPHandlers(); | ||
89 | } | ||
90 | |||
91 | public virtual void Close() | ||
92 | { | ||
93 | } | ||
94 | |||
95 | public virtual string Name | ||
96 | { | ||
97 | get { return "RESTInterregionCommsModule"; } | ||
98 | } | ||
99 | |||
100 | public virtual bool IsSharedModule | ||
101 | { | ||
102 | get { return true; } | ||
103 | } | ||
104 | |||
105 | protected virtual void InitEach(Scene scene) | ||
106 | { | ||
107 | m_localBackend.Init(scene); | ||
108 | scene.RegisterModuleInterface<IInterregionCommsOut>(this); | ||
109 | } | ||
110 | |||
111 | protected virtual void InitOnce(Scene scene) | ||
112 | { | ||
113 | m_localBackend = new LocalInterregionComms(); | ||
114 | m_commsManager = scene.CommsManager; | ||
115 | m_aScene = scene; | ||
116 | } | ||
117 | |||
118 | protected virtual void AddHTTPHandlers() | ||
119 | { | ||
120 | m_aScene.AddHTTPHandler("/ChildAgentUpdate/", ChildAgentUpdateHandler); | ||
121 | } | ||
122 | |||
123 | #endregion /* IRegionModule */ | ||
124 | |||
125 | #region IInterregionComms | ||
126 | |||
127 | public bool SendChildAgentUpdate(ulong regionHandle, AgentData cAgentData) | ||
128 | { | ||
129 | // Try local first | ||
130 | if (m_localBackend.SendChildAgentUpdate(regionHandle, cAgentData)) | ||
131 | return true; | ||
132 | |||
133 | // else do the remote thing | ||
134 | RegionInfo regInfo = m_commsManager.GridService.RequestNeighbourInfo(regionHandle); | ||
135 | if (regInfo != null) | ||
136 | { | ||
137 | return DoChildAgentUpdateCall(regInfo, cAgentData); | ||
138 | } | ||
139 | |||
140 | return false; | ||
141 | |||
142 | } | ||
143 | |||
144 | protected bool DoChildAgentUpdateCall(RegionInfo region, AgentData cAgentData) | ||
145 | { | ||
146 | string uri = "http://" + region.ExternalEndPoint.Address + ":" + region.HttpPort + "/ChildAgentUpdate/"; | ||
147 | //Console.WriteLine(" >>> DoChildAgentUpdateCall <<< " + uri); | ||
148 | |||
149 | WebRequest ChildUpdateRequest = WebRequest.Create(uri); | ||
150 | ChildUpdateRequest.Method = "PUT"; | ||
151 | ChildUpdateRequest.ContentType = "application/json"; | ||
152 | ChildUpdateRequest.Timeout = 10000; | ||
153 | |||
154 | // Fill it in | ||
155 | OSDMap args = null; | ||
156 | try | ||
157 | { | ||
158 | args = cAgentData.PackUpdateMessage(); | ||
159 | } | ||
160 | catch (Exception e) | ||
161 | { | ||
162 | m_log.Debug("[REST COMMS]: PackUpdateMessage failed with exception: " + e.Message); | ||
163 | } | ||
164 | // Add the regionhandle of the destination region | ||
165 | ulong regionHandle = GetRegionHandle(region); | ||
166 | args["destination_handle"] = OSD.FromString(regionHandle.ToString()); | ||
167 | |||
168 | string strBuffer = ""; | ||
169 | byte[] buffer = new byte[1]; | ||
170 | try | ||
171 | { | ||
172 | strBuffer = OSDParser.SerializeJsonString(args); | ||
173 | System.Text.UTF8Encoding str = new System.Text.UTF8Encoding(); | ||
174 | buffer = str.GetBytes(strBuffer); | ||
175 | |||
176 | } | ||
177 | catch (Exception e) | ||
178 | { | ||
179 | m_log.WarnFormat("[OSG2]: Exception thrown on serialization of ChildUpdate: {0}", e.Message); | ||
180 | // ignore. buffer will be empty, caller should check. | ||
181 | } | ||
182 | |||
183 | Stream os = null; | ||
184 | try | ||
185 | { // send the Post | ||
186 | ChildUpdateRequest.ContentLength = buffer.Length; //Count bytes to send | ||
187 | os = ChildUpdateRequest.GetRequestStream(); | ||
188 | os.Write(buffer, 0, strBuffer.Length); //Send it | ||
189 | os.Close(); | ||
190 | //m_log.InfoFormat("[REST COMMS]: Posted ChildAgentUpdate request to remote sim {0}", uri); | ||
191 | } | ||
192 | catch (WebException ex) | ||
193 | { | ||
194 | //m_log.InfoFormat("[REST COMMS]: Bad send on ChildAgentUpdate {0}", ex.Message); | ||
195 | |||
196 | return false; | ||
197 | } | ||
198 | |||
199 | // Let's wait for the response | ||
200 | //m_log.Info("[REST COMMS]: Waiting for a reply after ChildAgentUpdate"); | ||
201 | string reply = null; | ||
202 | try | ||
203 | { | ||
204 | WebResponse webResponse = ChildUpdateRequest.GetResponse(); | ||
205 | if (webResponse == null) | ||
206 | { | ||
207 | m_log.Info("[REST COMMS]: Null reply on ChilAgentUpdate post"); | ||
208 | } | ||
209 | |||
210 | StreamReader sr = new StreamReader(webResponse.GetResponseStream()); | ||
211 | reply = sr.ReadToEnd().Trim(); | ||
212 | sr.Close(); | ||
213 | //m_log.InfoFormat("[REST COMMS]: ChilAgentUpdate reply was {0} ", reply); | ||
214 | |||
215 | } | ||
216 | catch (WebException ex) | ||
217 | { | ||
218 | m_log.InfoFormat("[REST COMMS]: exception on reply of ChilAgentUpdate {0}", ex.Message); | ||
219 | // ignore, really | ||
220 | } | ||
221 | |||
222 | return true; | ||
223 | |||
224 | } | ||
225 | |||
226 | #endregion /* IInterregionComms */ | ||
227 | |||
228 | #region Called from remote instances on this instance | ||
229 | |||
230 | public Hashtable ChildAgentUpdateHandler(Hashtable request) | ||
231 | { | ||
232 | //m_log.Debug("[CONNECTION DEBUGGING]: ChildDataUpdateHandler Called"); | ||
233 | |||
234 | Hashtable responsedata = new Hashtable(); | ||
235 | responsedata["content_type"] = "text/html"; | ||
236 | |||
237 | OSDMap args = null; | ||
238 | try | ||
239 | { | ||
240 | OSD buffer; | ||
241 | // We should pay attention to the content-type, but let's assume we know it's Json | ||
242 | buffer = OSDParser.DeserializeJson((string)request["body"]); | ||
243 | if (buffer.Type == OSDType.Map) | ||
244 | args = (OSDMap)buffer; | ||
245 | else | ||
246 | { | ||
247 | // uh? | ||
248 | m_log.Debug("[REST COMMS]: Got OSD of type " + buffer.Type.ToString()); | ||
249 | } | ||
250 | } | ||
251 | catch (Exception ex) | ||
252 | { | ||
253 | m_log.InfoFormat("[REST COMMS]: exception on parse of ChildAgentUpdate message {0}", ex.Message); | ||
254 | responsedata["int_response_code"] = 400; | ||
255 | responsedata["str_response_string"] = "false"; | ||
256 | |||
257 | return responsedata; | ||
258 | } | ||
259 | |||
260 | // retrieve the regionhandle | ||
261 | ulong regionhandle = 0; | ||
262 | if (args["destination_handle"] != null) | ||
263 | UInt64.TryParse(args["destination_handle"].AsString(), out regionhandle); | ||
264 | |||
265 | AgentData agent = new AgentData(); | ||
266 | try | ||
267 | { | ||
268 | agent.UnpackUpdateMessage(args); | ||
269 | } | ||
270 | catch (Exception ex) | ||
271 | { | ||
272 | m_log.InfoFormat("[REST COMMS]: exception on unpacking ChildAgentUpdate message {0}", ex.Message); | ||
273 | } | ||
274 | //agent.Dump(); | ||
275 | |||
276 | bool result = m_localBackend.SendChildAgentUpdate(regionhandle, agent); | ||
277 | |||
278 | |||
279 | responsedata["int_response_code"] = 200; | ||
280 | responsedata["str_response_string"] = result.ToString(); | ||
281 | return responsedata; | ||
282 | } | ||
283 | |||
284 | #endregion | ||
285 | |||
286 | #region Misc | ||
287 | |||
288 | protected virtual ulong GetRegionHandle(RegionInfo region) | ||
289 | { | ||
290 | return region.RegionHandle; | ||
291 | } | ||
292 | |||
293 | #endregion /* Misc */ | ||
294 | |||
295 | } | ||
296 | } | ||