1 files changed, 186 insertions, 0 deletions
diff --git a/OpenSim/Grid/MessagingServer.Modules/InterMessageUserServerModule.cs b/OpenSim/Grid/MessagingServer.Modules/InterMessageUserServerModule.cs
new file mode 100644
index 0000000..ea7649a
--- /dev/null
+++ b/OpenSim/Grid/MessagingServer.Modules/InterMessageUserServerModule.cs
@@ -0,0 +1,186 @@
+/*
+ * 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.Net;
+using System.Reflection;
+using System.Threading;
+using System.Timers;
+using log4net;
+using Nwc.XmlRpc;
+using OpenMetaverse;
+using OpenSim.Data;
+using OpenSim.Framework;
+using OpenSim.Grid.Framework;
+using Timer = System.Timers.Timer;
+namespace OpenSim.Grid.MessagingServer.Modules
+{
+    public class InterMessageUserServerModule : IInterServiceUserService
+    {
+        private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+        private MessageServerConfig m_cfg;
+        private IGridServiceCore m_messageCore;
+        private Timer reconnectTimer = new Timer(300000); // 5 mins
+        public InterMessageUserServerModule(MessageServerConfig config, IGridServiceCore messageCore)
+        {
+            m_cfg = config;
+            m_messageCore = messageCore;
+            reconnectTimer.Elapsed += registerWithUserServer;
+            reconnectTimer.Start();
+        }
+        public void Initialise()
+        {
+            m_messageCore.RegisterInterface<IInterServiceUserService>(this);
+        }
+        public void PostInitialise()
+        {
+        }
+        public void RegisterHandlers()
+        {
+            //have these in separate method as some servers restart the http server and reregister all the handlers.
+           
+        }
+        public void registerWithUserServer(object sender, ElapsedEventArgs e)
+        {
+            registerWithUserServer();
+        }
+        public bool registerWithUserServer()
+        {
+            Hashtable UserParams = new Hashtable();
+            // Login / Authentication
+            if (m_cfg.HttpSSL)
+            {
+                UserParams["uri"] = "https://" + m_cfg.MessageServerIP + ":" + m_cfg.HttpPort;
+            }
+            else
+            {
+                UserParams["uri"] = "http://" + m_cfg.MessageServerIP + ":" + m_cfg.HttpPort;
+            }
+            UserParams["recvkey"] = m_cfg.UserRecvKey;
+            UserParams["sendkey"] = m_cfg.UserRecvKey;
+            // Package into an XMLRPC Request
+            ArrayList SendParams = new ArrayList();
+            SendParams.Add(UserParams);
+            bool success = true;
+            string[] servers = m_cfg.UserServerURL.Split(' ');
+            foreach (string srv in servers)
+            {
+                // Send Request
+                try
+                {
+                    XmlRpcRequest UserReq = new XmlRpcRequest("register_messageserver", SendParams);
+                    XmlRpcResponse UserResp = UserReq.Send(srv, 16000);
+                    // Process Response
+                    Hashtable GridRespData = (Hashtable)UserResp.Value;
+                    // if we got a response, we were successful
+                    if (!GridRespData.ContainsKey("responsestring"))
+                        success = false;
+                    else
+                        m_log.InfoFormat("[SERVER] Registered with {0}", srv);
+                }
+                catch
+                {
+                    m_log.ErrorFormat("Unable to connect to server {0}. Server not running?", srv);
+                    success = false;
+                }
+            }
+            return success;
+        }
+        public bool deregisterWithUserServer()
+        {
+            Hashtable request = new Hashtable();
+            return SendToUserServer(request, "deregister_messageserver");
+        }
+        public bool SendToUserServer(Hashtable request, string method)
+        {
+            // Login / Authentication
+            if (m_cfg.HttpSSL)
+            {
+                request["uri"] = "https://" + m_cfg.MessageServerIP + ":" + m_cfg.HttpPort;
+            }
+            else
+            {
+                request["uri"] = "http://" + m_cfg.MessageServerIP + ":" + m_cfg.HttpPort;
+            }
+            request["recvkey"] = m_cfg.UserRecvKey;
+            request["sendkey"] = m_cfg.UserRecvKey;
+            // Package into an XMLRPC Request
+            ArrayList SendParams = new ArrayList();
+            SendParams.Add(request);
+            bool success = true;
+            string[] servers = m_cfg.UserServerURL.Split(' ');
+            // Send Request
+            foreach (string srv in servers)
+            {
+                try
+                {
+                    XmlRpcRequest UserReq = new XmlRpcRequest(method, SendParams);
+                    XmlRpcResponse UserResp = UserReq.Send(m_cfg.UserServerURL, 16000);
+                    // Process Response
+                    Hashtable UserRespData = (Hashtable)UserResp.Value;
+                    // if we got a response, we were successful
+                    if (!UserRespData.ContainsKey("responsestring"))
+                        success = false;
+                }
+                catch
+                {
+                    m_log.ErrorFormat("Unable to connect to server {0}. Server not running?", srv);
+                    success = false;
+                }
+            }
+            return success;
+        }
+    }
+}

diff --git a/OpenSim/Grid/MessagingServer.Modules/InterMessageUserServerModule.cs b/OpenSim/Grid/MessagingServer.Modules/InterMessageUserServerModule.cs new file mode 100644 index 0000000..ea7649a --- /dev/null +++ b/OpenSim/Grid/MessagingServer.Modules/InterMessageUserServerModule.cs
@@ -0,0 +1,186 @@
	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
	28	using System;
	29	using System.Collections;
	30	using System.Collections.Generic;
	31	using System.Net;
	32	using System.Reflection;
	33	using System.Threading;
	34	using System.Timers;
	35	using log4net;
	36	using Nwc.XmlRpc;
	37	using OpenMetaverse;
	38	using OpenSim.Data;
	39	using OpenSim.Framework;
	40	using OpenSim.Grid.Framework;
	41	using Timer = System.Timers.Timer;
	42
	43	namespace OpenSim.Grid.MessagingServer.Modules
	44	{
	45	public class InterMessageUserServerModule : IInterServiceUserService
	46	{
	47	private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
	48
	49	private MessageServerConfig m_cfg;
	50
	51	private IGridServiceCore m_messageCore;
	52
	53	private Timer reconnectTimer = new Timer(300000); // 5 mins
	54
	55	public InterMessageUserServerModule(MessageServerConfig config, IGridServiceCore messageCore)
	56	{
	57	m_cfg = config;
	58	m_messageCore = messageCore;
	59
	60	reconnectTimer.Elapsed += registerWithUserServer;
	61	reconnectTimer.Start();
	62	}
	63
	64	public void Initialise()
	65	{
	66	m_messageCore.RegisterInterface<IInterServiceUserService>(this);
	67	}
	68
	69	public void PostInitialise()
	70	{
	71
	72	}
	73
	74	public void RegisterHandlers()
	75	{
	76	//have these in separate method as some servers restart the http server and reregister all the handlers.
	77
	78	}
	79
	80	public void registerWithUserServer(object sender, ElapsedEventArgs e)
	81	{
	82	registerWithUserServer();
	83	}
	84
	85	public bool registerWithUserServer()
	86	{
	87	Hashtable UserParams = new Hashtable();
	88	// Login / Authentication
	89
	90	if (m_cfg.HttpSSL)
	91	{
	92	UserParams["uri"] = "https://" + m_cfg.MessageServerIP + ":" + m_cfg.HttpPort;
	93	}
	94	else
	95	{
	96	UserParams["uri"] = "http://" + m_cfg.MessageServerIP + ":" + m_cfg.HttpPort;
	97	}
	98
	99	UserParams["recvkey"] = m_cfg.UserRecvKey;
	100	UserParams["sendkey"] = m_cfg.UserRecvKey;
	101
	102	// Package into an XMLRPC Request
	103	ArrayList SendParams = new ArrayList();
	104	SendParams.Add(UserParams);
	105
	106	bool success = true;
	107	string[] servers = m_cfg.UserServerURL.Split(' ');
	108
	109	foreach (string srv in servers)
	110	{
	111	// Send Request
	112	try
	113	{
	114	XmlRpcRequest UserReq = new XmlRpcRequest("register_messageserver", SendParams);
	115	XmlRpcResponse UserResp = UserReq.Send(srv, 16000);
	116
	117	// Process Response
	118	Hashtable GridRespData = (Hashtable)UserResp.Value;
	119	// if we got a response, we were successful
	120	if (!GridRespData.ContainsKey("responsestring"))
	121	success = false;
	122	else
	123	m_log.InfoFormat("[SERVER] Registered with {0}", srv);
	124	}
	125	catch
	126	{
	127	m_log.ErrorFormat("Unable to connect to server {0}. Server not running?", srv);
	128	success = false;
	129	}
	130	}
	131	return success;
	132	}
	133
	134	public bool deregisterWithUserServer()
	135	{
	136	Hashtable request = new Hashtable();
	137
	138	return SendToUserServer(request, "deregister_messageserver");
	139	}
	140
	141	public bool SendToUserServer(Hashtable request, string method)
	142	{
	143	// Login / Authentication
	144
	145	if (m_cfg.HttpSSL)
	146	{
	147	request["uri"] = "https://" + m_cfg.MessageServerIP + ":" + m_cfg.HttpPort;
	148	}
	149	else
	150	{
	151	request["uri"] = "http://" + m_cfg.MessageServerIP + ":" + m_cfg.HttpPort;
	152	}
	153
	154	request["recvkey"] = m_cfg.UserRecvKey;
	155	request["sendkey"] = m_cfg.UserRecvKey;
	156
	157	// Package into an XMLRPC Request
	158	ArrayList SendParams = new ArrayList();
	159	SendParams.Add(request);
	160
	161	bool success = true;
	162	string[] servers = m_cfg.UserServerURL.Split(' ');
	163
	164	// Send Request
	165	foreach (string srv in servers)
	166	{
	167	try
	168	{
	169	XmlRpcRequest UserReq = new XmlRpcRequest(method, SendParams);
	170	XmlRpcResponse UserResp = UserReq.Send(m_cfg.UserServerURL, 16000);
	171	// Process Response
	172	Hashtable UserRespData = (Hashtable)UserResp.Value;
	173	// if we got a response, we were successful
	174	if (!UserRespData.ContainsKey("responsestring"))
	175	success = false;
	176	}
	177	catch
	178	{
	179	m_log.ErrorFormat("Unable to connect to server {0}. Server not running?", srv);
	180	success = false;
	181	}
	182	}
	183	return success;
	184	}
	185	}
	186	}