More refactoring of the Grid, User and Messaging servers.

author: MW 2009-02-25 18:33:15 +0000
committer: MW 2009-02-25 18:33:15 +0000
commit: 4db232763f578048c3339e6a60fe801cc3853b3d (patch)
tree: c43b1442bcf1893fb83894873ddfdacdee5a5130 /OpenSim/Grid/UserServer/UserServerEventDispatchModule.cs
parent: * Fix my own unit test (diff)
download: opensim-SC-4db232763f578048c3339e6a60fe801cc3853b3d.zip
opensim-SC-4db232763f578048c3339e6a60fe801cc3853b3d.tar.gz
opensim-SC-4db232763f578048c3339e6a60fe801cc3853b3d.tar.bz2
opensim-SC-4db232763f578048c3339e6a60fe801cc3853b3d.tar.xz
1 files changed, 141 insertions, 0 deletions
diff --git a/OpenSim/Grid/UserServer/UserServerEventDispatchModule.cs b/OpenSim/Grid/UserServer/UserServerEventDispatchModule.cs
new file mode 100644
index 0000000..e23a7d1
--- /dev/null
+++ b/OpenSim/Grid/UserServer/UserServerEventDispatchModule.cs
@@ -0,0 +1,141 @@
+/*
+ * 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.Generic;
+using System.IO;
+using System.Reflection;
+using log4net;
+using log4net.Config;
+using OpenMetaverse;
+using OpenSim.Data;
+using OpenSim.Framework;
+using OpenSim.Framework.Communications;
+using OpenSim.Framework.Communications.Cache;
+using OpenSim.Framework.Console;
+using OpenSim.Framework.Servers;
+using OpenSim.Framework.Statistics;
+using OpenSim.Grid.Communications.OGS1;
+using OpenSim.Grid.Framework;
+using OpenSim.Grid.UserServer.Modules;
+namespace OpenSim.Grid.UserServer
+{
+    //Do we actually need these event dispatchers? 
+    //shouldn't the other modules just directly register event handlers to each other?
+    public class UserServerEventDispatchModule
+    {
+        protected UserManager m_userManager;
+        protected MessageServersConnector m_messagesService;
+        protected UserLoginService m_loginService;
+        public UserServerEventDispatchModule(UserManager userManager, MessageServersConnector messagesService, UserLoginService loginService)
+        {
+            m_userManager = userManager;
+            m_messagesService = messagesService;
+            m_loginService = loginService;
+        }
+        public void Initialise(IUGAIMCore core)
+        {
+        }
+        public void PostInitialise()
+        {
+            m_loginService.OnUserLoggedInAtLocation += NotifyMessageServersUserLoggedInToLocation;
+            m_userManager.OnLogOffUser += NotifyMessageServersUserLoggOff;
+            m_messagesService.OnAgentLocation += HandleAgentLocation;
+            m_messagesService.OnAgentLeaving += HandleAgentLeaving;
+            m_messagesService.OnRegionStartup += HandleRegionStartup;
+            m_messagesService.OnRegionShutdown += HandleRegionShutdown;
+        }
+        public void RegisterHandlers(BaseHttpServer httpServer)
+        {
+        }
+        public void Close()
+        {
+            m_loginService.OnUserLoggedInAtLocation -= NotifyMessageServersUserLoggedInToLocation;
+        }
+        #region Event Handlers
+        public void NotifyMessageServersUserLoggOff(UUID agentID)
+        {
+            m_messagesService.TellMessageServersAboutUserLogoff(agentID);
+        }
+        public void NotifyMessageServersUserLoggedInToLocation(UUID agentID, UUID sessionID, UUID RegionID,
+                                                               ulong regionhandle, float positionX, float positionY,
+                                                               float positionZ, string firstname, string lastname)
+        {
+            m_messagesService.TellMessageServersAboutUser(agentID, sessionID, RegionID, regionhandle, positionX,
+                                                          positionY, positionZ, firstname, lastname);
+        }
+        public void HandleAgentLocation(UUID agentID, UUID regionID, ulong regionHandle)
+        {
+            m_userManager.HandleAgentLocation(agentID, regionID, regionHandle);
+        }
+        public void HandleAgentLeaving(UUID agentID, UUID regionID, ulong regionHandle)
+        {
+            m_userManager.HandleAgentLeaving(agentID, regionID, regionHandle);
+        }
+        public void HandleRegionStartup(UUID regionID)
+        {
+            // This might seem strange, that we send this back to the
+            // server it came from. But there is method to the madness.
+            // There can be multiple user servers on the same database,
+            // and each can have multiple messaging servers. So, we send
+            // it to all known user servers, who send it to all known
+            // message servers. That way, we should be able to finally
+            // update presence to all regions and thereby all friends
+            //
+            m_userManager.HandleRegionStartup(regionID);
+            m_messagesService.TellMessageServersAboutRegionShutdown(regionID);
+        }
+        public void HandleRegionShutdown(UUID regionID)
+        {
+            // This might seem strange, that we send this back to the
+            // server it came from. But there is method to the madness.
+            // There can be multiple user servers on the same database,
+            // and each can have multiple messaging servers. So, we send
+            // it to all known user servers, who send it to all known
+            // message servers. That way, we should be able to finally
+            // update presence to all regions and thereby all friends
+            //
+            m_userManager.HandleRegionShutdown(regionID);
+            m_messagesService.TellMessageServersAboutRegionShutdown(regionID);
+        }
+        #endregion
+    }
+}
author	MW	2009-02-25 18:33:15 +0000
committer	MW	2009-02-25 18:33:15 +0000
commit	4db232763f578048c3339e6a60fe801cc3853b3d (patch)
tree	c43b1442bcf1893fb83894873ddfdacdee5a5130 /OpenSim/Grid/UserServer/UserServerEventDispatchModule.cs
parent	* Fix my own unit test (diff)
download	opensim-SC-4db232763f578048c3339e6a60fe801cc3853b3d.zip opensim-SC-4db232763f578048c3339e6a60fe801cc3853b3d.tar.gz opensim-SC-4db232763f578048c3339e6a60fe801cc3853b3d.tar.bz2 opensim-SC-4db232763f578048c3339e6a60fe801cc3853b3d.tar.xz

diff --git a/OpenSim/Grid/UserServer/UserServerEventDispatchModule.cs b/OpenSim/Grid/UserServer/UserServerEventDispatchModule.cs new file mode 100644 index 0000000..e23a7d1 --- /dev/null +++ b/OpenSim/Grid/UserServer/UserServerEventDispatchModule.cs
@@ -0,0 +1,141 @@
	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.Generic;
	30	using System.IO;
	31	using System.Reflection;
	32	using log4net;
	33	using log4net.Config;
	34	using OpenMetaverse;
	35	using OpenSim.Data;
	36	using OpenSim.Framework;
	37	using OpenSim.Framework.Communications;
	38	using OpenSim.Framework.Communications.Cache;
	39	using OpenSim.Framework.Console;
	40	using OpenSim.Framework.Servers;
	41	using OpenSim.Framework.Statistics;
	42	using OpenSim.Grid.Communications.OGS1;
	43	using OpenSim.Grid.Framework;
	44	using OpenSim.Grid.UserServer.Modules;
	45
	46	namespace OpenSim.Grid.UserServer
	47	{
	48	//Do we actually need these event dispatchers?
	49	//shouldn't the other modules just directly register event handlers to each other?
	50	public class UserServerEventDispatchModule
	51	{
	52	protected UserManager m_userManager;
	53	protected MessageServersConnector m_messagesService;
	54	protected UserLoginService m_loginService;
	55
	56	public UserServerEventDispatchModule(UserManager userManager, MessageServersConnector messagesService, UserLoginService loginService)
	57	{
	58	m_userManager = userManager;
	59	m_messagesService = messagesService;
	60	m_loginService = loginService;
	61	}
	62
	63	public void Initialise(IUGAIMCore core)
	64	{
	65	}
	66
	67	public void PostInitialise()
	68	{
	69	m_loginService.OnUserLoggedInAtLocation += NotifyMessageServersUserLoggedInToLocation;
	70	m_userManager.OnLogOffUser += NotifyMessageServersUserLoggOff;
	71
	72	m_messagesService.OnAgentLocation += HandleAgentLocation;
	73	m_messagesService.OnAgentLeaving += HandleAgentLeaving;
	74	m_messagesService.OnRegionStartup += HandleRegionStartup;
	75	m_messagesService.OnRegionShutdown += HandleRegionShutdown;
	76	}
	77
	78	public void RegisterHandlers(BaseHttpServer httpServer)
	79	{
	80
	81	}
	82
	83	public void Close()
	84	{
	85	m_loginService.OnUserLoggedInAtLocation -= NotifyMessageServersUserLoggedInToLocation;
	86	}
	87
	88	#region Event Handlers
	89	public void NotifyMessageServersUserLoggOff(UUID agentID)
	90	{
	91	m_messagesService.TellMessageServersAboutUserLogoff(agentID);
	92	}
	93
	94	public void NotifyMessageServersUserLoggedInToLocation(UUID agentID, UUID sessionID, UUID RegionID,
	95	ulong regionhandle, float positionX, float positionY,
	96	float positionZ, string firstname, string lastname)
	97	{
	98	m_messagesService.TellMessageServersAboutUser(agentID, sessionID, RegionID, regionhandle, positionX,
	99	positionY, positionZ, firstname, lastname);
	100	}
	101
	102	public void HandleAgentLocation(UUID agentID, UUID regionID, ulong regionHandle)
	103	{
	104	m_userManager.HandleAgentLocation(agentID, regionID, regionHandle);
	105	}
	106
	107	public void HandleAgentLeaving(UUID agentID, UUID regionID, ulong regionHandle)
	108	{
	109	m_userManager.HandleAgentLeaving(agentID, regionID, regionHandle);
	110	}
	111
	112	public void HandleRegionStartup(UUID regionID)
	113	{
	114	// This might seem strange, that we send this back to the
	115	// server it came from. But there is method to the madness.
	116	// There can be multiple user servers on the same database,
	117	// and each can have multiple messaging servers. So, we send
	118	// it to all known user servers, who send it to all known
	119	// message servers. That way, we should be able to finally
	120	// update presence to all regions and thereby all friends
	121	//
	122	m_userManager.HandleRegionStartup(regionID);
	123	m_messagesService.TellMessageServersAboutRegionShutdown(regionID);
	124	}
	125
	126	public void HandleRegionShutdown(UUID regionID)
	127	{
	128	// This might seem strange, that we send this back to the
	129	// server it came from. But there is method to the madness.
	130	// There can be multiple user servers on the same database,
	131	// and each can have multiple messaging servers. So, we send
	132	// it to all known user servers, who send it to all known
	133	// message servers. That way, we should be able to finally
	134	// update presence to all regions and thereby all friends
	135	//
	136	m_userManager.HandleRegionShutdown(regionID);
	137	m_messagesService.TellMessageServersAboutRegionShutdown(regionID);
	138	}
	139	#endregion
	140	}
	141	}