1 files changed, 150 insertions, 0 deletions
diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLPacketServer.cs b/OpenSim/Region/ClientStack/LindenUDP/LLPacketServer.cs
new file mode 100644
index 0000000..48afa84
--- /dev/null
+++ b/OpenSim/Region/ClientStack/LindenUDP/LLPacketServer.cs
@@ -0,0 +1,150 @@
+/*
+ * 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.Net;
+using System.Net.Sockets;
+using libsecondlife;
+using libsecondlife.Packets;
+using OpenSim.Framework;
+using OpenSim.Framework.Communications.Cache;
+using OpenSim.Region.ClientStack.LindenUDP;
+namespace OpenSim.Region.ClientStack.LindenUDP
+{
+    public class LLPacketServer
+    {
+        //private static readonly log4net.ILog m_log 
+        //    = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
+        private LLClientStackNetworkHandler m_networkHandler;
+        private IScene m_scene;
+        //private readonly ClientManager m_clientManager = new ClientManager();
+        //public ClientManager ClientManager
+        //{
+        //    get { return m_clientManager; }
+        //}
+        public LLPacketServer(LLClientStackNetworkHandler networkHandler)
+        {
+            m_networkHandler = networkHandler;
+            m_networkHandler.RegisterPacketServer(this);
+        }
+        public IScene LocalScene
+        {
+            set { m_scene = value; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        /// <param name="circuitCode"></param>
+        /// <param name="packet"></param>
+        public virtual void InPacket(uint circuitCode, Packet packet)
+        {
+            m_scene.ClientManager.InPacket(circuitCode, packet);
+        }
+        protected virtual IClientAPI CreateNewClient(EndPoint remoteEP, UseCircuitCodePacket initialcirpack,
+                                                     ClientManager clientManager, IScene scene, AssetCache assetCache,
+                                                     LLPacketServer packServer, AgentCircuitManager authenSessions,
+                                                     LLUUID agentId, LLUUID sessionId, uint circuitCode, EndPoint proxyEP)
+        {
+            return
+                new LLClientView(remoteEP, scene, assetCache, packServer, authenSessions, agentId, sessionId, circuitCode, proxyEP);
+        }
+        public virtual bool AddNewClient(EndPoint epSender, UseCircuitCodePacket useCircuit, AssetCache assetCache,
+                                         AgentCircuitManager authenticateSessionsClass, EndPoint proxyEP)
+        {
+            IClientAPI newuser;
+            if (m_scene.ClientManager.TryGetClient(useCircuit.CircuitCode.Code, out newuser))
+            {
+                return false;
+            }
+            else
+            {
+                newuser = CreateNewClient(epSender, useCircuit, m_scene.ClientManager, m_scene, assetCache, this,
+                                          authenticateSessionsClass, useCircuit.CircuitCode.ID,
+                                          useCircuit.CircuitCode.SessionID, useCircuit.CircuitCode.Code, proxyEP);
+                m_scene.ClientManager.Add(useCircuit.CircuitCode.Code, newuser);
+                newuser.OnViewerEffect += m_scene.ClientManager.ViewerEffectHandler;
+                newuser.OnLogout += LogoutHandler;
+                newuser.OnConnectionClosed += CloseClient;
+                return true;
+            }
+        }
+        public void LogoutHandler(IClientAPI client)
+        {
+            client.SendLogoutPacket();
+            CloseClient(client);
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        /// <param name="buffer"></param>
+        /// <param name="size"></param>
+        /// <param name="flags"></param>
+        /// <param name="circuitcode"></param>
+        public virtual void SendPacketTo(byte[] buffer, int size, SocketFlags flags, uint circuitcode)
+        {
+            m_networkHandler.SendPacketTo(buffer, size, flags, circuitcode);
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        /// <param name="circuitcode"></param>
+        public virtual void CloseCircuit(uint circuitcode)
+        {
+            m_networkHandler.RemoveClientCircuit(circuitcode);
+            //m_scene.ClientManager.CloseAllAgents(circuitcode);
+        }
+        /// <summary>
+        /// Completely close down the given client.
+        /// </summary>
+        /// <param name="client"></param>
+        public virtual void CloseClient(IClientAPI client)
+        {
+            //m_log.Info("PacketServer:CloseClient()");
+         
+            CloseCircuit(client.CircuitCode);
+            m_scene.ClientManager.Remove(client.CircuitCode);                
+            client.Close(false);
+        }
+    }
+}
+\ No newline at end of file

diff --git a/OpenSim/Region/ClientStack/LindenUDP/LLPacketServer.cs b/OpenSim/Region/ClientStack/LindenUDP/LLPacketServer.cs new file mode 100644 index 0000000..48afa84 --- /dev/null +++ b/OpenSim/Region/ClientStack/LindenUDP/LLPacketServer.cs
@@ -0,0 +1,150 @@
	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.Net;
	29	using System.Net.Sockets;
	30	using libsecondlife;
	31	using libsecondlife.Packets;
	32	using OpenSim.Framework;
	33	using OpenSim.Framework.Communications.Cache;
	34	using OpenSim.Region.ClientStack.LindenUDP;
	35
	36	namespace OpenSim.Region.ClientStack.LindenUDP
	37	{
	38	public class LLPacketServer
	39	{
	40	//private static readonly log4net.ILog m_log
	41	// = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
	42
	43	private LLClientStackNetworkHandler m_networkHandler;
	44	private IScene m_scene;
	45
	46	//private readonly ClientManager m_clientManager = new ClientManager();
	47	//public ClientManager ClientManager
	48	//{
	49	// get { return m_clientManager; }
	50	//}
	51
	52	public LLPacketServer(LLClientStackNetworkHandler networkHandler)
	53	{
	54	m_networkHandler = networkHandler;
	55	m_networkHandler.RegisterPacketServer(this);
	56	}
	57
	58	public IScene LocalScene
	59	{
	60	set { m_scene = value; }
	61	}
	62
	63	/// <summary>
	64	///
	65	/// </summary>
	66	/// <param name="circuitCode"></param>
	67	/// <param name="packet"></param>
	68	public virtual void InPacket(uint circuitCode, Packet packet)
	69	{
	70	m_scene.ClientManager.InPacket(circuitCode, packet);
	71	}
	72
	73	protected virtual IClientAPI CreateNewClient(EndPoint remoteEP, UseCircuitCodePacket initialcirpack,
	74	ClientManager clientManager, IScene scene, AssetCache assetCache,
	75	LLPacketServer packServer, AgentCircuitManager authenSessions,
	76	LLUUID agentId, LLUUID sessionId, uint circuitCode, EndPoint proxyEP)
	77	{
	78	return
	79	new LLClientView(remoteEP, scene, assetCache, packServer, authenSessions, agentId, sessionId, circuitCode, proxyEP);
	80	}
	81
	82	public virtual bool AddNewClient(EndPoint epSender, UseCircuitCodePacket useCircuit, AssetCache assetCache,
	83	AgentCircuitManager authenticateSessionsClass, EndPoint proxyEP)
	84	{
	85	IClientAPI newuser;
	86
	87	if (m_scene.ClientManager.TryGetClient(useCircuit.CircuitCode.Code, out newuser))
	88	{
	89	return false;
	90	}
	91	else
	92	{
	93	newuser = CreateNewClient(epSender, useCircuit, m_scene.ClientManager, m_scene, assetCache, this,
	94	authenticateSessionsClass, useCircuit.CircuitCode.ID,
	95	useCircuit.CircuitCode.SessionID, useCircuit.CircuitCode.Code, proxyEP);
	96
	97	m_scene.ClientManager.Add(useCircuit.CircuitCode.Code, newuser);
	98
	99	newuser.OnViewerEffect += m_scene.ClientManager.ViewerEffectHandler;
	100	newuser.OnLogout += LogoutHandler;
	101	newuser.OnConnectionClosed += CloseClient;
	102
	103	return true;
	104	}
	105	}
	106
	107	public void LogoutHandler(IClientAPI client)
	108	{
	109	client.SendLogoutPacket();
	110
	111	CloseClient(client);
	112	}
	113
	114	/// <summary>
	115	///
	116	/// </summary>
	117	/// <param name="buffer"></param>
	118	/// <param name="size"></param>
	119	/// <param name="flags"></param>
	120	/// <param name="circuitcode"></param>
	121	public virtual void SendPacketTo(byte[] buffer, int size, SocketFlags flags, uint circuitcode)
	122	{
	123	m_networkHandler.SendPacketTo(buffer, size, flags, circuitcode);
	124	}
	125
	126	/// <summary>
	127	///
	128	/// </summary>
	129	/// <param name="circuitcode"></param>
	130	public virtual void CloseCircuit(uint circuitcode)
	131	{
	132	m_networkHandler.RemoveClientCircuit(circuitcode);
	133
	134	//m_scene.ClientManager.CloseAllAgents(circuitcode);
	135	}
	136
	137	/// <summary>
	138	/// Completely close down the given client.
	139	/// </summary>
	140	/// <param name="client"></param>
	141	public virtual void CloseClient(IClientAPI client)
	142	{
	143	//m_log.Info("PacketServer:CloseClient()");
	144
	145	CloseCircuit(client.CircuitCode);
	146	m_scene.ClientManager.Remove(client.CircuitCode);
	147	client.Close(false);
	148	}
	149	}
	150	} \ No newline at end of file