ScriptServer communication protocol (v1), primitive RPC-like TCP client/server

1 files changed, 106 insertions, 0 deletions

diff --git a/OpenSim/Region/ScriptEngine/Common/TRPC/TCPServer.cs b/OpenSim/Region/ScriptEngine/Common/TRPC/TCPServer.cs
new file mode 100644
index 0000000..3af898a
--- /dev/null
+++ b/OpenSim/Region/ScriptEngine/Common/TRPC/TCPServer.cs
@@ -0,0 +1,106 @@
+using System;

+using System.Collections.Generic;

+using System.Diagnostics;

+using System.Net;

+using System.Net.Sockets;

+using TCPCommon=OpenSim.Region.ScriptEngine.Common.TRPC.TCPCommon;

+

+namespace OpenSim.Region.ScriptEngine.Common.TRPC

+{

+    public class TCPServer: TCPCommon.ServerInterface 

+    {

+        public readonly int LocalPort;

+        public TCPServer(int localPort)

+        {

+            LocalPort = localPort;

+        }

+

+        private Socket server;

+

+        /// <summary>

+        /// Starts listening for new connections

+        /// </summary>

+        public void StartListen()

+        {

+            server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

+            IPEndPoint ipe = new IPEndPoint(IPAddress.Any, LocalPort);

+            server.Bind(ipe);

+            server.Listen(10);

+            server.BeginAccept(new AsyncCallback(AsyncAcceptConnections), server);

+        }

+        /// <summary>

+        /// Stops listening for new connections

+        /// </summary>

+        public void StopListen()

+        {

+            server.Close();

+            server = null;

+        }

+

+        private readonly Dictionary<int, TCPSocket> Clients = new Dictionary<int, TCPSocket>();

+        private int ClientCount = 0;

+

+

+        public event TCPCommon.ClientConnectedDelegate ClientConnected;

+        public event TCPCommon.DataReceivedDelegate DataReceived;

+        public event TCPCommon.DataSentDelegate DataSent;

+        public event TCPCommon.CloseDelegate Close;

+

+        /// <summary>

+        /// Async callback for new connections

+        /// </summary>

+        /// <param name="ar"></param>

+        private void AsyncAcceptConnections(IAsyncResult ar)

+        {

+            int id = ClientCount++;

+            Socket oldserver = (Socket)ar.AsyncState;

+            Socket client = oldserver.EndAccept(ar);

+            TCPSocket S = new TCPSocket(id, client);

+

+            // Add to dictionary

+            Clients.Add(id, S);

+

+            // Add event handlers

+            S.Close += new TCPSocket.CloseDelegate(S_Close);

+            S.DataReceived += new TCPSocket.DataReceivedDelegate(S_DataReceived);

+            S.DataSent += new TCPSocket.DataSentDelegate(S_DataSent);

+

+            // Start it

+            S.Start();

+

+            Debug.WriteLine("Connection received: " + client.RemoteEndPoint.ToString());

+

+            // Fire Connected-event

+            if (ClientConnected != null)

+                ClientConnected(id, client.RemoteEndPoint);

+

+        }

+

+        void S_DataSent(int ID, int length)

+        {

+            if (DataSent != null)

+                DataSent(ID, length);

+        }

+

+        void S_DataReceived(int ID, byte[] data, int offset, int length)

+        {

+            if (DataReceived != null)

+                DataReceived(ID, data, offset, length);

+        }

+

+        void S_Close(int ID)

+        {

+            if (Close != null)

+                Close(ID);

+            Clients.Remove(ID);

+        }

+

+        public void Send(int clientID, byte[] data, int offset, int len)

+        {

+            Clients[clientID].Send(clientID, data, offset, len);

+        }

+

+

+

+    }

+}
\ No newline at end of file