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

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 @@
	1	using System;
	2	using System.Collections.Generic;
	3	using System.Diagnostics;
	4	using System.Net;
	5	using System.Net.Sockets;
	6	using TCPCommon=OpenSim.Region.ScriptEngine.Common.TRPC.TCPCommon;
	7
	8	namespace OpenSim.Region.ScriptEngine.Common.TRPC
	9	{
	10	public class TCPServer: TCPCommon.ServerInterface
	11	{
	12	public readonly int LocalPort;
	13	public TCPServer(int localPort)
	14	{
	15	LocalPort = localPort;
	16	}
	17
	18	private Socket server;
	19
	20	/// <summary>
	21	/// Starts listening for new connections
	22	/// </summary>
	23	public void StartListen()
	24	{
	25	server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
	26	IPEndPoint ipe = new IPEndPoint(IPAddress.Any, LocalPort);
	27	server.Bind(ipe);
	28	server.Listen(10);
	29	server.BeginAccept(new AsyncCallback(AsyncAcceptConnections), server);
	30	}
	31	/// <summary>
	32	/// Stops listening for new connections
	33	/// </summary>
	34	public void StopListen()
	35	{
	36	server.Close();
	37	server = null;
	38	}
	39
	40	private readonly Dictionary<int, TCPSocket> Clients = new Dictionary<int, TCPSocket>();
	41	private int ClientCount = 0;
	42
	43
	44	public event TCPCommon.ClientConnectedDelegate ClientConnected;
	45	public event TCPCommon.DataReceivedDelegate DataReceived;
	46	public event TCPCommon.DataSentDelegate DataSent;
	47	public event TCPCommon.CloseDelegate Close;
	48
	49	/// <summary>
	50	/// Async callback for new connections
	51	/// </summary>
	52	/// <param name="ar"></param>
	53	private void AsyncAcceptConnections(IAsyncResult ar)
	54	{
	55	int id = ClientCount++;
	56	Socket oldserver = (Socket)ar.AsyncState;
	57	Socket client = oldserver.EndAccept(ar);
	58	TCPSocket S = new TCPSocket(id, client);
	59
	60	// Add to dictionary
	61	Clients.Add(id, S);
	62
	63	// Add event handlers
	64	S.Close += new TCPSocket.CloseDelegate(S_Close);
	65	S.DataReceived += new TCPSocket.DataReceivedDelegate(S_DataReceived);
	66	S.DataSent += new TCPSocket.DataSentDelegate(S_DataSent);
	67
	68	// Start it
	69	S.Start();
	70
	71	Debug.WriteLine("Connection received: " + client.RemoteEndPoint.ToString());
	72
	73	// Fire Connected-event
	74	if (ClientConnected != null)
	75	ClientConnected(id, client.RemoteEndPoint);
	76
	77	}
	78
	79	void S_DataSent(int ID, int length)
	80	{
	81	if (DataSent != null)
	82	DataSent(ID, length);
	83	}
	84
	85	void S_DataReceived(int ID, byte[] data, int offset, int length)
	86	{
	87	if (DataReceived != null)
	88	DataReceived(ID, data, offset, length);
	89	}
	90
	91	void S_Close(int ID)
	92	{
	93	if (Close != null)
	94	Close(ID);
	95	Clients.Remove(ID);
	96	}
	97
	98	public void Send(int clientID, byte[] data, int offset, int len)
	99	{
	100	Clients[clientID].Send(clientID, data, offset, len);
	101	}
	102
	103
	104
	105	}
	106	} \ No newline at end of file