From 5d7e120d56873d91141695ddf7aebd88e4619dce Mon Sep 17 00:00:00 2001 From: Jeff Ames Date: Sat, 12 Jan 2008 01:35:25 +0000 Subject: Set svn:eol-style. --- .../Region/ScriptEngine/Common/TRPC/TCPSocket.cs | 170 ++++++++++----------- 1 file changed, 85 insertions(+), 85 deletions(-) (limited to 'OpenSim/Region/ScriptEngine/Common/TRPC/TCPSocket.cs') diff --git a/OpenSim/Region/ScriptEngine/Common/TRPC/TCPSocket.cs b/OpenSim/Region/ScriptEngine/Common/TRPC/TCPSocket.cs index 1079846..ce50a27 100644 --- a/OpenSim/Region/ScriptEngine/Common/TRPC/TCPSocket.cs +++ b/OpenSim/Region/ScriptEngine/Common/TRPC/TCPSocket.cs @@ -1,86 +1,86 @@ -using System; -using System.Net.Sockets; - -namespace OpenSim.Region.ScriptEngine.Common.TRPC -{ - public class TCPSocket - { - - public readonly Socket Client; - public readonly int ID; - - public delegate void DataReceivedDelegate(int ID, byte[] data, int offset, int length); - public delegate void DataSentDelegate(int ID, int length); - public delegate void CloseDelegate(int ID); - public event DataReceivedDelegate DataReceived; - public event DataSentDelegate DataSent; - public event CloseDelegate Close; - - private byte[] RecvQueue = new byte[4096]; - private int RecvQueueSize = 4096; - - public TCPSocket(int id, Socket client) - { - ID = id; - Client = client; - } - public void Start() - { - // Start listening - BeginReceive(); - } - - private void BeginReceive() - { - Client.BeginReceive(RecvQueue, 0, RecvQueueSize, SocketFlags.None, new AsyncCallback(asyncDataReceived), Client); - } - - /// - /// Callback for successful receive (or connection close) - /// - /// - private void asyncDataReceived(IAsyncResult ar) - { - Socket client = (Socket)ar.AsyncState; - int recv = client.EndReceive(ar); - - // Is connection closed? - if (recv == 0) - { - client.Close(); - Close(ID); - return; - } - - // Call receive event - DataReceived(ID, RecvQueue, 0, recv); - - // Start new receive - BeginReceive(); - - } - - - public void Send(int clientID, byte[] data, int offset, int len) - { - Client.BeginSend(data, offset, len, SocketFlags.None, new AsyncCallback(asyncDataSent), Client); - } - - /// - /// Callback for successful send - /// - /// - void asyncDataSent(IAsyncResult ar) - { - Socket client = (Socket)ar.AsyncState; - int sent = client.EndSend(ar); - DataSent(ID, sent); - } - - public void Disconnect() - { - Client.Close(); - Close(ID); - } - } +using System; +using System.Net.Sockets; + +namespace OpenSim.Region.ScriptEngine.Common.TRPC +{ + public class TCPSocket + { + + public readonly Socket Client; + public readonly int ID; + + public delegate void DataReceivedDelegate(int ID, byte[] data, int offset, int length); + public delegate void DataSentDelegate(int ID, int length); + public delegate void CloseDelegate(int ID); + public event DataReceivedDelegate DataReceived; + public event DataSentDelegate DataSent; + public event CloseDelegate Close; + + private byte[] RecvQueue = new byte[4096]; + private int RecvQueueSize = 4096; + + public TCPSocket(int id, Socket client) + { + ID = id; + Client = client; + } + public void Start() + { + // Start listening + BeginReceive(); + } + + private void BeginReceive() + { + Client.BeginReceive(RecvQueue, 0, RecvQueueSize, SocketFlags.None, new AsyncCallback(asyncDataReceived), Client); + } + + /// + /// Callback for successful receive (or connection close) + /// + /// + private void asyncDataReceived(IAsyncResult ar) + { + Socket client = (Socket)ar.AsyncState; + int recv = client.EndReceive(ar); + + // Is connection closed? + if (recv == 0) + { + client.Close(); + Close(ID); + return; + } + + // Call receive event + DataReceived(ID, RecvQueue, 0, recv); + + // Start new receive + BeginReceive(); + + } + + + public void Send(int clientID, byte[] data, int offset, int len) + { + Client.BeginSend(data, offset, len, SocketFlags.None, new AsyncCallback(asyncDataSent), Client); + } + + /// + /// Callback for successful send + /// + /// + void asyncDataSent(IAsyncResult ar) + { + Socket client = (Socket)ar.AsyncState; + int sent = client.EndSend(ar); + DataSent(ID, sent); + } + + public void Disconnect() + { + Client.Close(); + Close(ID); + } + } } \ No newline at end of file -- cgit v1.1