started to refactor startup code and to move udp server code out to its own class (currently not being used though) so that a single instance can handle multiple regions (each will need to be listening on a separate udp port)

1 files changed, 164 insertions, 0 deletions

diff --git a/OpenSim.RegionServer/UDPServer.cs b/OpenSim.RegionServer/UDPServer.cs
new file mode 100644
index 0000000..e70ae78
--- /dev/null
+++ b/OpenSim.RegionServer/UDPServer.cs
@@ -0,0 +1,164 @@
+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.world;

+using OpenSim.Terrain;

+using OpenSim.Framework.Interfaces;

+using OpenSim.Framework.Types;

+using OpenSim.UserServer;

+using OpenSim.Assets;

+using OpenSim.CAPS;

+using OpenSim.Framework.Console;

+using Nwc.XmlRpc;

+using OpenSim.Servers;

+using OpenSim.GenericConfig;

+

+namespace OpenSim

+{

+    public class UDPServer : OpenSimNetworkHandler

+    {

+        private Dictionary<EndPoint, uint> clientCircuits = new Dictionary<EndPoint, uint>();

+        public Socket Server;

+        private IPEndPoint ServerIncoming;

+        private byte[] RecvBuffer = new byte[4096];

+        private byte[] ZeroBuffer = new byte[8192];

+        private IPEndPoint ipeSender;

+        private EndPoint epSender;

+        private AsyncCallback ReceivedData;

+        private PacketServer _packetServer;

+       

+        private int listenPort;

+        private Grid m_gridServers;

+        private World m_localWorld;

+        private AssetCache m_assetCache;

+        private InventoryCache m_inventoryCache;

+        private RegionInfo m_regionData;

+        private bool m_sandbox = false;

+        private bool user_accounts = false;

+        private ConsoleBase m_console;

+

+        public UDPServer(int port, Grid gridServers, World localWorld, AssetCache assetCache, InventoryCache inventoryCache, RegionInfo _regionData, bool sandbox, bool accounts, ConsoleBase console)

+        {

+            listenPort = port;

+            this.m_gridServers = gridServers;

+            this.m_localWorld = localWorld;

+            this.m_assetCache = assetCache;

+            this.m_inventoryCache = inventoryCache;

+            this.m_regionData = _regionData;

+            this.m_sandbox = sandbox;

+            this.user_accounts = accounts;

+            this.m_console = console;

+            PacketServer packetServer = new PacketServer(this);

+            this._packetServer.LocalWorld = m_localWorld;

+            this._packetServer.RegisterClientPacketHandlers();

+        }

+

+        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

+                Console.Error.WriteLine("Main.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);

+            bool isChildAgent = false;

+

+            SimClient newuser = new SimClient(epSender, useCircuit, m_localWorld, _packetServer.ClientThreads, m_assetCache, m_gridServers.GridServer, this, m_inventoryCache, m_sandbox, isChildAgent, this.m_regionData);

+            if ((this.m_gridServers.UserServer != null) && (user_accounts))

+            {

+                newuser.UserServer = this.m_gridServers.UserServer;

+            }

+            //OpenSimRoot.Instance.ClientThreads.Add(epSender, newuser);

+            this._packetServer.ClientThreads.Add(useCircuit.CircuitCode.Code, newuser);

+        }

+

+        private void ServerListener()

+        {

+            m_console.WriteLine("Main.cs:MainServerListener() - Opening UDP socket on " + listenPort);

+

+            ServerIncoming = new IPEndPoint(IPAddress.Any, listenPort);

+            Server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);

+            Server.Bind(ServerIncoming);

+

+            m_console.WriteLine("Main.cs:MainServerListener() - 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_console.WriteLine("Main.cs:MainServerListener() - Listening...");

+

+        }

+

+        public 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