1 files changed, 109 insertions, 0 deletions
diff --git a/OpenSim/Region/ScriptEngine/Common/TRPC/TCPClient.cs b/OpenSim/Region/ScriptEngine/Common/TRPC/TCPClient.cs
new file mode 100644
index 0000000..3230614
--- /dev/null
+++ b/OpenSim/Region/ScriptEngine/Common/TRPC/TCPClient.cs
@@ -0,0 +1,109 @@
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Net;
+using System.Net.Sockets;
+using System.Text;
+namespace OpenSim.Region.ScriptEngine.Common.TRPC
+{
+    public class TCPClient: TCPCommon.ClientInterface
+    {
+        public TCPClient()
+        {
+        }
+        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;
+        public event TCPCommon.ConnectErrorDelegate ConnectError;
+        /// <summary>
+        /// Creates client connection
+        /// </summary>
+        public void Connect(string RemoteHost, int RemotePort)
+        {
+            Socket newsock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
+            IPEndPoint ipe = new IPEndPoint(IPAddress.Parse(RemoteHost), RemotePort);
+            newsock.BeginConnect(ipe, new AsyncCallback(asyncConnected), newsock);
+        }
+        public void Disconnect(int ID)
+        {
+            Clients[ID].Disconnect();
+        }
+        void asyncConnected(IAsyncResult iar)
+        {
+            Socket client = (Socket)iar.AsyncState;
+            try
+            {
+                client.EndConnect(iar);
+                int id = ClientCount++;
+                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 established: " + client.RemoteEndPoint.ToString());
+                // Fire Connected-event
+                if (ClientConnected != null)
+                    ClientConnected(id, client.RemoteEndPoint);
+            }
+            catch (SocketException sex)
+            {
+                if (ConnectError != null)
+                    ConnectError(sex.Message);
+            }
+        }
+        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/TCPClient.cs b/OpenSim/Region/ScriptEngine/Common/TRPC/TCPClient.cs new file mode 100644 index 0000000..3230614 --- /dev/null +++ b/OpenSim/Region/ScriptEngine/Common/TRPC/TCPClient.cs
@@ -0,0 +1,109 @@
	1	using System;
	2	using System.Collections.Generic;
	3	using System.Diagnostics;
	4	using System.Net;
	5	using System.Net.Sockets;
	6	using System.Text;
	7
	8	namespace OpenSim.Region.ScriptEngine.Common.TRPC
	9	{
	10	public class TCPClient: TCPCommon.ClientInterface
	11	{
	12
	13	public TCPClient()
	14	{
	15	}
	16	private readonly Dictionary<int, TCPSocket> Clients = new Dictionary<int, TCPSocket>();
	17	private int ClientCount = 0;
	18
	19
	20	public event TCPCommon.ClientConnectedDelegate ClientConnected;
	21	public event TCPCommon.DataReceivedDelegate DataReceived;
	22	public event TCPCommon.DataSentDelegate DataSent;
	23	public event TCPCommon.CloseDelegate Close;
	24	public event TCPCommon.ConnectErrorDelegate ConnectError;
	25
	26
	27	/// <summary>
	28	/// Creates client connection
	29	/// </summary>
	30	public void Connect(string RemoteHost, int RemotePort)
	31	{
	32	Socket newsock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
	33	IPEndPoint ipe = new IPEndPoint(IPAddress.Parse(RemoteHost), RemotePort);
	34	newsock.BeginConnect(ipe, new AsyncCallback(asyncConnected), newsock);
	35
	36
	37	}
	38
	39	public void Disconnect(int ID)
	40	{
	41	Clients[ID].Disconnect();
	42	}
	43
	44	void asyncConnected(IAsyncResult iar)
	45	{
	46	Socket client = (Socket)iar.AsyncState;
	47	try
	48	{
	49	client.EndConnect(iar);
	50
	51
	52	int id = ClientCount++;
	53	TCPSocket S = new TCPSocket(id, client);
	54
	55	// Add to dictionary
	56	Clients.Add(id, S);
	57
	58	// Add event handlers
	59	S.Close += new TCPSocket.CloseDelegate(S_Close);
	60	S.DataReceived += new TCPSocket.DataReceivedDelegate(S_DataReceived);
	61	S.DataSent += new TCPSocket.DataSentDelegate(S_DataSent);
	62
	63	// Start it
	64	S.Start();
	65
	66	Debug.WriteLine("Connection established: " + client.RemoteEndPoint.ToString());
	67
	68	// Fire Connected-event
	69	if (ClientConnected != null)
	70	ClientConnected(id, client.RemoteEndPoint);
	71
	72	}
	73	catch (SocketException sex)
	74	{
	75	if (ConnectError != null)
	76	ConnectError(sex.Message);
	77	}
	78	}
	79
	80
	81
	82
	83	void S_DataSent(int ID, int length)
	84	{
	85	if (DataSent != null)
	86	DataSent(ID, length);
	87	}
	88
	89	void S_DataReceived(int ID, byte[] data, int offset, int length)
	90	{
	91	if (DataReceived != null)
	92	DataReceived(ID, data, offset, length);
	93	}
	94
	95	void S_Close(int ID)
	96	{
	97	if (Close != null)
	98	Close(ID);
	99	Clients.Remove(ID);
	100	}
	101
	102	public void Send(int clientID, byte[] data, int offset, int len)
	103	{
	104	Clients[clientID].Send(clientID, data, offset, len);
	105	}
	106
	107
	108	}
	109	} \ No newline at end of file