Some work on restructuring the namespaces / project names. Note this doesn't compile yet as not all the code has been changed to use the new namespaces. Am committing it now for feedback on the namespaces.

author: MW 2007-06-27 15:28:52 +0000
committer: MW 2007-06-27 15:28:52 +0000
commit: 646bbbc84b8010e0dacbeed5342cdb045f46cc49 (patch)
tree: 770b34d19855363c3c113ab9a0af9a56d821d887 /OpenSim/Region/ClientStack/UDPServer.cs
download: opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.zip
opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.gz
opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.bz2
opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.xz
1 files changed, 208 insertions, 0 deletions
diff --git a/OpenSim/Region/ClientStack/UDPServer.cs b/OpenSim/Region/ClientStack/UDPServer.cs
new file mode 100644
index 0000000..f2a02d9
--- /dev/null
+++ b/OpenSim/Region/ClientStack/UDPServer.cs
@@ -0,0 +1,208 @@
+/*
+* Copyright (c) Contributors, http://www.openmetaverse.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.Text;
+using System.IO;
+using System.Threading;
+using System.Net;
+using System.Net.Sockets;
+using System.Timers;
+using System.Reflection;
+using System.Collections;
+using System.Collections.Generic;
+using libsecondlife;
+using libsecondlife.Packets;
+using OpenSim.Terrain;
+using OpenSim.Framework.Interfaces;
+using OpenSim.Framework.Types;
+using OpenSim.Assets;
+using OpenSim.Caches;
+using OpenSim.Framework.Console;
+using OpenSim.Framework;
+using Nwc.XmlRpc;
+using OpenSim.Servers;
+using OpenSim.GenericConfig;
+namespace OpenSim
+{
+    public class UDPServer : ClientStackNetworkHandler
+    {
+        protected Dictionary<EndPoint, uint> clientCircuits = new Dictionary<EndPoint, uint>();
+        public Socket Server;
+        protected IPEndPoint ServerIncoming;
+        protected byte[] RecvBuffer = new byte[4096];
+        protected byte[] ZeroBuffer = new byte[8192];
+        protected IPEndPoint ipeSender;
+        protected EndPoint epSender;
+        protected AsyncCallback ReceivedData;
+        protected PacketServer _packetServer;
+        protected int listenPort;
+        protected IWorld m_localWorld;
+        protected AssetCache m_assetCache;
+        protected InventoryCache m_inventoryCache;
+        protected LogBase m_log;
+        protected AuthenticateSessionsBase m_authenticateSessionsClass;
+        public PacketServer PacketServer
+        {
+            get
+            {
+                return _packetServer;
+            }
+            set
+            {
+                _packetServer = value;
+            }
+        }
+        public IWorld LocalWorld
+        {
+            set
+            {
+                this.m_localWorld = value;
+                this._packetServer.LocalWorld = this.m_localWorld;
+            }
+        }
+        public UDPServer()
+        {
+        }
+        public UDPServer(int port, AssetCache assetCache, InventoryCache inventoryCache, LogBase console, AuthenticateSessionsBase authenticateClass)
+        {
+            listenPort = port;
+            this.m_assetCache = assetCache;
+            this.m_inventoryCache = inventoryCache;
+            this.m_log = console;
+            this.m_authenticateSessionsClass = authenticateClass;
+            this.CreatePacketServer();
+        }
+        protected virtual void CreatePacketServer()
+        {
+            PacketServer packetServer = new PacketServer(this, (uint) listenPort);
+        }
+        protected virtual void OnReceivedData(IAsyncResult result)
+        {
+            ipeSender = new IPEndPoint(IPAddress.Any, 0);
+            epSender = (EndPoint)ipeSender;
+            Packet packet = null;
+            int numBytes = Server.EndReceiveFrom(result, ref epSender);
+            int packetEnd = numBytes - 1;
+            packet = Packet.BuildPacket(RecvBuffer, ref packetEnd, ZeroBuffer);
+            // do we already have a circuit for this endpoint
+            if (this.clientCircuits.ContainsKey(epSender))
+            {
+                //if so then send packet to the packetserver
+                this._packetServer.ClientInPacket(this.clientCircuits[epSender], packet);
+            }
+            else if (packet.Type == PacketType.UseCircuitCode)
+            {
+                // new client
+                this.AddNewClient(packet);
+            }
+            else
+            { // invalid client
+                m_log.Warn("UDPServer.cs:OnReceivedData() - WARNING: Got a packet from an invalid client - " + epSender.ToString());
+            }
+            Server.BeginReceiveFrom(RecvBuffer, 0, RecvBuffer.Length, SocketFlags.None, ref epSender, ReceivedData, null);
+        }
+        protected virtual void AddNewClient(Packet packet)
+        {
+            UseCircuitCodePacket useCircuit = (UseCircuitCodePacket)packet;
+            this.clientCircuits.Add(epSender, useCircuit.CircuitCode.Code);
+            this.PacketServer.AddNewClient(epSender, useCircuit, m_assetCache, m_inventoryCache, m_authenticateSessionsClass); 
+        }
+        public void ServerListener()
+        {
+            m_log.Status("UDPServer.cs:ServerListener() - Opening UDP socket on " + listenPort);
+            ServerIncoming = new IPEndPoint(IPAddress.Any, listenPort);
+            Server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
+            Server.Bind(ServerIncoming);
+ 
+            m_log.Verbose("UDPServer.cs:ServerListener() - UDP socket bound, getting ready to listen");
+            ipeSender = new IPEndPoint(IPAddress.Any, 0);
+            epSender = (EndPoint)ipeSender;
+            ReceivedData = new AsyncCallback(this.OnReceivedData);
+            Server.BeginReceiveFrom(RecvBuffer, 0, RecvBuffer.Length, SocketFlags.None, ref epSender, ReceivedData, null);
+            m_log.Verbose("UDPServer.cs:ServerListener() - Listening...");
+        }
+        public virtual void RegisterPacketServer(PacketServer server)
+        {
+            this._packetServer = server;
+        }
+        public virtual void SendPacketTo(byte[] buffer, int size, SocketFlags flags, uint circuitcode)//EndPoint packetSender)
+        {
+            // find the endpoint for this circuit
+            EndPoint sendto = null;
+            foreach (KeyValuePair<EndPoint, uint> p in this.clientCircuits)
+            {
+                if (p.Value == circuitcode)
+                {
+                    sendto = p.Key;
+                    break;
+                }
+            }
+            if (sendto != null)
+            {
+                //we found the endpoint so send the packet to it
+                this.Server.SendTo(buffer, size, flags, sendto);
+            }
+        }
+        public virtual void RemoveClientCircuit(uint circuitcode)
+        {
+            foreach (KeyValuePair<EndPoint, uint> p in this.clientCircuits)
+            {
+                if (p.Value == circuitcode)
+                {
+                    this.clientCircuits.Remove(p.Key);
+                    break;
+                }
+            }
+        }
+      
+    }
+}
+\ No newline at end of file
author	MW	2007-06-27 15:28:52 +0000
committer	MW	2007-06-27 15:28:52 +0000
commit	646bbbc84b8010e0dacbeed5342cdb045f46cc49 (patch)
tree	770b34d19855363c3c113ab9a0af9a56d821d887 /OpenSim/Region/ClientStack/UDPServer.cs
download	opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.zip opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.gz opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.bz2 opensim-SC-646bbbc84b8010e0dacbeed5342cdb045f46cc49.tar.xz

diff --git a/OpenSim/Region/ClientStack/UDPServer.cs b/OpenSim/Region/ClientStack/UDPServer.cs new file mode 100644 index 0000000..f2a02d9 --- /dev/null +++ b/OpenSim/Region/ClientStack/UDPServer.cs
@@ -0,0 +1,208 @@
	1	/*
	2	* Copyright (c) Contributors, http://www.openmetaverse.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.Text;
	30	using System.IO;
	31	using System.Threading;
	32	using System.Net;
	33	using System.Net.Sockets;
	34	using System.Timers;
	35	using System.Reflection;
	36	using System.Collections;
	37	using System.Collections.Generic;
	38	using libsecondlife;
	39	using libsecondlife.Packets;
	40	using OpenSim.Terrain;
	41	using OpenSim.Framework.Interfaces;
	42	using OpenSim.Framework.Types;
	43	using OpenSim.Assets;
	44	using OpenSim.Caches;
	45	using OpenSim.Framework.Console;
	46	using OpenSim.Framework;
	47	using Nwc.XmlRpc;
	48	using OpenSim.Servers;
	49	using OpenSim.GenericConfig;
	50
	51	namespace OpenSim
	52	{
	53
	54	public class UDPServer : ClientStackNetworkHandler
	55	{
	56	protected Dictionary<EndPoint, uint> clientCircuits = new Dictionary<EndPoint, uint>();
	57	public Socket Server;
	58	protected IPEndPoint ServerIncoming;
	59	protected byte[] RecvBuffer = new byte[4096];
	60	protected byte[] ZeroBuffer = new byte[8192];
	61	protected IPEndPoint ipeSender;
	62	protected EndPoint epSender;
	63	protected AsyncCallback ReceivedData;
	64	protected PacketServer _packetServer;
	65
	66	protected int listenPort;
	67	protected IWorld m_localWorld;
	68	protected AssetCache m_assetCache;
	69	protected InventoryCache m_inventoryCache;
	70	protected LogBase m_log;
	71	protected AuthenticateSessionsBase m_authenticateSessionsClass;
	72
	73	public PacketServer PacketServer
	74	{
	75	get
	76	{
	77	return _packetServer;
	78	}
	79	set
	80	{
	81	_packetServer = value;
	82	}
	83	}
	84
	85	public IWorld LocalWorld
	86	{
	87	set
	88	{
	89	this.m_localWorld = value;
	90	this._packetServer.LocalWorld = this.m_localWorld;
	91	}
	92	}
	93
	94	public UDPServer()
	95	{
	96	}
	97
	98	public UDPServer(int port, AssetCache assetCache, InventoryCache inventoryCache, LogBase console, AuthenticateSessionsBase authenticateClass)
	99	{
	100	listenPort = port;
	101	this.m_assetCache = assetCache;
	102	this.m_inventoryCache = inventoryCache;
	103	this.m_log = console;
	104	this.m_authenticateSessionsClass = authenticateClass;
	105	this.CreatePacketServer();
	106
	107	}
	108
	109	protected virtual void CreatePacketServer()
	110	{
	111	PacketServer packetServer = new PacketServer(this, (uint) listenPort);
	112	}
	113
	114	protected virtual void OnReceivedData(IAsyncResult result)
	115	{
	116	ipeSender = new IPEndPoint(IPAddress.Any, 0);
	117	epSender = (EndPoint)ipeSender;
	118	Packet packet = null;
	119	int numBytes = Server.EndReceiveFrom(result, ref epSender);
	120	int packetEnd = numBytes - 1;
	121
	122	packet = Packet.BuildPacket(RecvBuffer, ref packetEnd, ZeroBuffer);
	123
	124	// do we already have a circuit for this endpoint
	125	if (this.clientCircuits.ContainsKey(epSender))
	126	{
	127	//if so then send packet to the packetserver
	128	this._packetServer.ClientInPacket(this.clientCircuits[epSender], packet);
	129	}
	130	else if (packet.Type == PacketType.UseCircuitCode)
	131	{
	132	// new client
	133	this.AddNewClient(packet);
	134	}
	135	else
	136	{ // invalid client
	137	m_log.Warn("UDPServer.cs:OnReceivedData() - WARNING: Got a packet from an invalid client - " + epSender.ToString());
	138	}
	139
	140	Server.BeginReceiveFrom(RecvBuffer, 0, RecvBuffer.Length, SocketFlags.None, ref epSender, ReceivedData, null);
	141	}
	142
	143	protected virtual void AddNewClient(Packet packet)
	144	{
	145	UseCircuitCodePacket useCircuit = (UseCircuitCodePacket)packet;
	146	this.clientCircuits.Add(epSender, useCircuit.CircuitCode.Code);
	147
	148	this.PacketServer.AddNewClient(epSender, useCircuit, m_assetCache, m_inventoryCache, m_authenticateSessionsClass);
	149	}
	150
	151	public void ServerListener()
	152	{
	153	m_log.Status("UDPServer.cs:ServerListener() - Opening UDP socket on " + listenPort);
	154
	155	ServerIncoming = new IPEndPoint(IPAddress.Any, listenPort);
	156	Server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
	157	Server.Bind(ServerIncoming);
	158
	159	m_log.Verbose("UDPServer.cs:ServerListener() - UDP socket bound, getting ready to listen");
	160
	161	ipeSender = new IPEndPoint(IPAddress.Any, 0);
	162	epSender = (EndPoint)ipeSender;
	163	ReceivedData = new AsyncCallback(this.OnReceivedData);
	164	Server.BeginReceiveFrom(RecvBuffer, 0, RecvBuffer.Length, SocketFlags.None, ref epSender, ReceivedData, null);
	165
	166	m_log.Verbose("UDPServer.cs:ServerListener() - Listening...");
	167
	168	}
	169
	170	public virtual void RegisterPacketServer(PacketServer server)
	171	{
	172	this._packetServer = server;
	173	}
	174
	175	public virtual void SendPacketTo(byte[] buffer, int size, SocketFlags flags, uint circuitcode)//EndPoint packetSender)
	176	{
	177	// find the endpoint for this circuit
	178	EndPoint sendto = null;
	179	foreach (KeyValuePair<EndPoint, uint> p in this.clientCircuits)
	180	{
	181	if (p.Value == circuitcode)
	182	{
	183	sendto = p.Key;
	184	break;
	185	}
	186	}
	187	if (sendto != null)
	188	{
	189	//we found the endpoint so send the packet to it
	190	this.Server.SendTo(buffer, size, flags, sendto);
	191	}
	192	}
	193
	194	public virtual void RemoveClientCircuit(uint circuitcode)
	195	{
	196	foreach (KeyValuePair<EndPoint, uint> p in this.clientCircuits)
	197	{
	198	if (p.Value == circuitcode)
	199	{
	200	this.clientCircuits.Remove(p.Key);
	201	break;
	202	}
	203	}
	204	}
	205
	206
	207	}
	208	} \ No newline at end of file