From b41acfb4cfe51c22ada1a234c60d64ef80fde330 Mon Sep 17 00:00:00 2001 From: Tedd Hansen Date: Fri, 12 Sep 2008 18:42:02 +0000 Subject: Cut of remote server as AppDomains and even WCF can do it better (better means less code in this case) --- .../Region/ScriptEngine/Common/TRPC/TCPClient.cs | 141 --------------------- 1 file changed, 141 deletions(-) delete mode 100644 OpenSim/Region/ScriptEngine/Common/TRPC/TCPClient.cs (limited to 'OpenSim/Region/ScriptEngine/Common/TRPC/TCPClient.cs') diff --git a/OpenSim/Region/ScriptEngine/Common/TRPC/TCPClient.cs b/OpenSim/Region/ScriptEngine/Common/TRPC/TCPClient.cs deleted file mode 100644 index 624c3bb..0000000 --- a/OpenSim/Region/ScriptEngine/Common/TRPC/TCPClient.cs +++ /dev/null @@ -1,141 +0,0 @@ -/* - * Copyright (c) Contributors, http://opensimulator.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.Collections.Generic; -using System.Diagnostics; -using System.Net; -using System.Net.Sockets; - -namespace OpenSim.Region.ScriptEngine.Common.TRPC -{ - public class TCPClient : TCPCommon.ClientInterface - { - public TCPClient() - { - } - - private readonly Dictionary Clients = new Dictionary(); - 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; - - /// - /// Creates client connection - /// - 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); - newsock.Connect(ipe); - } - - public int ConnectAndReturnID(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); - newsock.Connect(ipe); - return ProcessConnection(newsock); - } - - public void Disconnect(int ID) - { - Clients[ID].Disconnect(); - } - -// TODO: unused -// void asyncConnected(IAsyncResult iar) -// { -// Socket client = (Socket)iar.AsyncState; -// client.EndConnect(iar); -// ProcessConnection(client); -// } - - private int ProcessConnection(Socket client) - { - try - { - 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); - - return id; - } - catch (SocketException sex) - { - if (ConnectError != null) - ConnectError(sex.Message); - } - return -1; - } - - 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); - } - } -} -- cgit v1.1