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.

author: diva 2008-12-29 21:40:20 +0000
committer: diva 2008-12-29 21:40:20 +0000
commit: e12d2ec9dc398f8d5b8847e4eaa9702a5f769411 (patch)
tree: c01b8609a99a3b2d3d2a00d4b65a27e2d1b1b406 /OpenSim/Region/Environment/Modules/Communications/REST/RESTInterregionComms.cs
parent: Minor change in HGSceneCommunicationService, making one field public readonly... (diff)
download: opensim-SC-e12d2ec9dc398f8d5b8847e4eaa9702a5f769411.zip
opensim-SC-e12d2ec9dc398f8d5b8847e4eaa9702a5f769411.tar.gz
opensim-SC-e12d2ec9dc398f8d5b8847e4eaa9702a5f769411.tar.bz2
opensim-SC-e12d2ec9dc398f8d5b8847e4eaa9702a5f769411.tar.xz
1 files changed, 296 insertions, 0 deletions
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 @@
+/*
+ * Copyright (c) Contributors, http://opensimulator.org/
+ * See CONTRIBUTORS.TXT for a full list of copyright holders.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *     * Redistributions of source code must retain the above copyright
+ *       notice, this list of conditions and the following disclaimer.
+ *     * Redistributions in binary form must reproduce the above copyright
+ *       notice, this list of conditions and the following disclaimer in the
+ *       documentation and/or other materials provided with the distribution.
+ *     * Neither the name of the OpenSim Project nor the
+ *       names of its contributors may be used to endorse or promote products
+ *       derived from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
+ * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
+ * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.IO;
+using System.Net;
+using System.Net.Sockets;
+using System.Reflection;
+using System.Threading;
+using System.Xml;
+using OpenMetaverse;
+using OpenMetaverse.StructuredData;
+using log4net;
+using Nini.Config;
+using Nwc.XmlRpc;
+using OpenSim.Framework;
+using OpenSim.Framework.Communications;
+using OpenSim.Framework.Communications.Cache;
+using OpenSim.Region.Environment.Interfaces;
+using OpenSim.Region.Interfaces;
+using OpenSim.Region.Environment.Scenes;
+using OpenSim.Region.Environment.Modules.Communications.Local;
+namespace OpenSim.Region.Environment.Modules.Communications.REST
+{
+    public class RESTInterregionComms : IRegionModule, IInterregionCommsOut
+    {
+        private static bool initialized = false;
+        private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+        protected bool m_enabled = false;
+        protected Scene m_aScene;
+        // RESTInterregionComms does not care about local regions; it delegates that to the Local module
+        protected LocalInterregionComms m_localBackend;
+        protected CommunicationsManager m_commsManager;
+        #region IRegionModule
+        public virtual void Initialise(Scene scene, IConfigSource config)
+        {
+            if (!initialized)
+            {
+                initialized = true;
+                IConfig startupConfig = config.Configs["Communications"];
+                if ((startupConfig != null) && (startupConfig.GetString("InterregionComms", "LocalComms") == "RESTComms"))
+                {
+                    m_enabled = true;
+                    InitOnce(scene);
+                }
+            }
+            if (!m_enabled)
+                return;
+            InitEach(scene);
+        }
+        public virtual void PostInitialise()
+        {
+            if (m_enabled)
+                AddHTTPHandlers();
+        }
+        public virtual void Close()
+        {
+        }
+        public virtual string Name
+        {
+            get { return "RESTInterregionCommsModule"; }
+        }
+        public virtual bool IsSharedModule
+        {
+            get { return true; }
+        }
+        protected virtual void InitEach(Scene scene)
+        {
+            m_localBackend.Init(scene);
+            scene.RegisterModuleInterface<IInterregionCommsOut>(this);
+        }
+        protected virtual void InitOnce(Scene scene)
+        {
+            m_localBackend = new LocalInterregionComms();
+            m_commsManager = scene.CommsManager;
+            m_aScene = scene;
+        }
+        protected virtual void AddHTTPHandlers()
+        {
+            m_aScene.AddHTTPHandler("/ChildAgentUpdate/", ChildAgentUpdateHandler);
+        }
+        #endregion /* IRegionModule */
+        #region IInterregionComms
+        public bool SendChildAgentUpdate(ulong regionHandle, AgentData cAgentData)
+        {
+            // Try local first
+            if (m_localBackend.SendChildAgentUpdate(regionHandle, cAgentData))
+                return true;
+            // else do the remote thing
+            RegionInfo regInfo = m_commsManager.GridService.RequestNeighbourInfo(regionHandle);
+            if (regInfo != null)
+            {
+                return DoChildAgentUpdateCall(regInfo, cAgentData);
+            }
+            return false;
+        }
+        protected bool DoChildAgentUpdateCall(RegionInfo region, AgentData cAgentData)
+        {
+            string uri = "http://" + region.ExternalEndPoint.Address + ":" + region.HttpPort + "/ChildAgentUpdate/";
+            //Console.WriteLine("   >>> DoChildAgentUpdateCall <<< " + uri);
+            WebRequest ChildUpdateRequest = WebRequest.Create(uri);
+            ChildUpdateRequest.Method = "PUT";
+            ChildUpdateRequest.ContentType = "application/json";
+            ChildUpdateRequest.Timeout = 10000;
+            // Fill it in
+            OSDMap args = null;
+            try
+            {
+                args = cAgentData.PackUpdateMessage();
+            }
+            catch (Exception e)
+            {
+                m_log.Debug("[REST COMMS]: PackUpdateMessage failed with exception: " + e.Message);
+            }
+            // Add the regionhandle of the destination region
+            ulong regionHandle = GetRegionHandle(region);
+            args["destination_handle"] = OSD.FromString(regionHandle.ToString());
+            string strBuffer = "";
+            byte[] buffer = new byte[1];
+            try
+            {
+                strBuffer = OSDParser.SerializeJsonString(args);
+                System.Text.UTF8Encoding str = new System.Text.UTF8Encoding();
+                buffer = str.GetBytes(strBuffer);
+            }
+            catch (Exception e)
+            {
+                m_log.WarnFormat("[OSG2]: Exception thrown on serialization of ChildUpdate: {0}", e.Message);
+                // ignore. buffer will be empty, caller should check.
+            }
+            Stream os = null;
+            try
+            { // send the Post
+                ChildUpdateRequest.ContentLength = buffer.Length;   //Count bytes to send
+                os = ChildUpdateRequest.GetRequestStream();
+                os.Write(buffer, 0, strBuffer.Length);         //Send it
+                os.Close();
+                //m_log.InfoFormat("[REST COMMS]: Posted ChildAgentUpdate request to remote sim {0}", uri);
+            }
+            catch (WebException ex)
+            {
+                //m_log.InfoFormat("[REST COMMS]: Bad send on ChildAgentUpdate {0}", ex.Message);
+                return false;
+            }
+            // Let's wait for the response
+            //m_log.Info("[REST COMMS]: Waiting for a reply after ChildAgentUpdate");
+            string reply = null;
+            try
+            {
+                WebResponse webResponse = ChildUpdateRequest.GetResponse();
+                if (webResponse == null)
+                {
+                    m_log.Info("[REST COMMS]: Null reply on ChilAgentUpdate post");
+                }
+                StreamReader sr = new StreamReader(webResponse.GetResponseStream());
+                reply = sr.ReadToEnd().Trim();
+                sr.Close();
+                //m_log.InfoFormat("[REST COMMS]: ChilAgentUpdate reply was {0} ", reply);
+            }
+            catch (WebException ex)
+            {
+                m_log.InfoFormat("[REST COMMS]: exception on reply of ChilAgentUpdate {0}", ex.Message);
+                // ignore, really
+            }
+            return true;
+        }
+        #endregion /* IInterregionComms */
+        #region Called from remote instances on this instance
+        public Hashtable ChildAgentUpdateHandler(Hashtable request)
+        {
+            //m_log.Debug("[CONNECTION DEBUGGING]: ChildDataUpdateHandler Called");
+            Hashtable responsedata = new Hashtable();
+            responsedata["content_type"] = "text/html";
+            OSDMap args = null;
+            try
+            {
+                OSD buffer;
+                // We should pay attention to the content-type, but let's assume we know it's Json
+                buffer = OSDParser.DeserializeJson((string)request["body"]);
+                if (buffer.Type == OSDType.Map)
+                    args = (OSDMap)buffer;
+                else
+                {
+                    // uh?
+                    m_log.Debug("[REST COMMS]: Got OSD of type " + buffer.Type.ToString());
+                }
+            }
+            catch (Exception ex)
+            {
+                m_log.InfoFormat("[REST COMMS]: exception on parse of ChildAgentUpdate message {0}", ex.Message);
+                responsedata["int_response_code"] = 400;
+                responsedata["str_response_string"] = "false";
+                return responsedata;
+            }
+            // retrieve the regionhandle
+            ulong regionhandle = 0;
+            if (args["destination_handle"] != null)
+                UInt64.TryParse(args["destination_handle"].AsString(), out regionhandle);
+            AgentData agent = new AgentData();
+            try
+            {
+                agent.UnpackUpdateMessage(args);
+            }
+            catch (Exception ex)
+            {
+                m_log.InfoFormat("[REST COMMS]: exception on unpacking ChildAgentUpdate message {0}", ex.Message);
+            }
+            //agent.Dump();
+            bool result = m_localBackend.SendChildAgentUpdate(regionhandle, agent);
+            responsedata["int_response_code"] = 200;
+            responsedata["str_response_string"] = result.ToString();
+            return responsedata;
+        }
+        #endregion 
+        #region Misc
+        protected virtual ulong GetRegionHandle(RegionInfo region)
+        {
+            return region.RegionHandle;
+        }
+        #endregion /* Misc */
+    }
+}
author	diva	2008-12-29 21:40:20 +0000
committer	diva	2008-12-29 21:40:20 +0000
commit	e12d2ec9dc398f8d5b8847e4eaa9702a5f769411 (patch)
tree	c01b8609a99a3b2d3d2a00d4b65a27e2d1b1b406 /OpenSim/Region/Environment/Modules/Communications/REST/RESTInterregionComms.cs
parent	Minor change in HGSceneCommunicationService, making one field public readonly... (diff)
download	opensim-SC-e12d2ec9dc398f8d5b8847e4eaa9702a5f769411.zip opensim-SC-e12d2ec9dc398f8d5b8847e4eaa9702a5f769411.tar.gz opensim-SC-e12d2ec9dc398f8d5b8847e4eaa9702a5f769411.tar.bz2 opensim-SC-e12d2ec9dc398f8d5b8847e4eaa9702a5f769411.tar.xz

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	}