aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Region/ScriptEngine/Common/TRPC/TCPSocket.cs
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--OpenSim/Region/ScriptEngine/Common/TRPC/TCPSocket.cs111
1 files changed, 0 insertions, 111 deletions
diff --git a/OpenSim/Region/ScriptEngine/Common/TRPC/TCPSocket.cs b/OpenSim/Region/ScriptEngine/Common/TRPC/TCPSocket.cs
deleted file mode 100644
index 693ec6f..0000000
--- a/OpenSim/Region/ScriptEngine/Common/TRPC/TCPSocket.cs
+++ /dev/null
@@ -1,111 +0,0 @@
1/*
2 * Copyright (c) Contributors, http://opensimulator.org/
3 * See CONTRIBUTORS.TXT for a full list of copyright holders.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met:
7 * * Redistributions of source code must retain the above copyright
8 * notice, this list of conditions and the following disclaimer.
9 * * Redistributions in binary form must reproduce the above copyright
10 * notice, this list of conditions and the following disclaimer in the
11 * documentation and/or other materials provided with the distribution.
12 * * Neither the name of the OpenSim Project nor the
13 * names of its contributors may be used to endorse or promote products
14 * derived from this software without specific prior written permission.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
17 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
19 * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
20 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
21 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
22 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
23 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
25 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 */
27
28using System;
29using System.Net.Sockets;
30
31namespace OpenSim.Region.ScriptEngine.Common.TRPC
32{
33 public class TCPSocket
34 {
35 public readonly Socket Client;
36 public readonly int ID;
37
38 public delegate void DataReceivedDelegate(int ID, byte[] data, int offset, int length);
39 public delegate void DataSentDelegate(int ID, int length);
40 public delegate void CloseDelegate(int ID);
41 public event DataReceivedDelegate DataReceived;
42 public event DataSentDelegate DataSent;
43 public event CloseDelegate Close;
44
45 private byte[] RecvQueue = new byte[4096];
46 private int RecvQueueSize = 4096;
47
48 public TCPSocket(int id, Socket client)
49 {
50 ID = id;
51 Client = client;
52 }
53
54 public void Start()
55 {
56 // Start listening
57 BeginReceive();
58 }
59
60 private void BeginReceive()
61 {
62 Client.BeginReceive(RecvQueue, 0, RecvQueueSize, SocketFlags.None, new AsyncCallback(asyncDataReceived), Client);
63 }
64
65 /// <summary>
66 /// Callback for successful receive (or connection close)
67 /// </summary>
68 /// <param name="ar"></param>
69 private void asyncDataReceived(IAsyncResult ar)
70 {
71 Socket client = (Socket)ar.AsyncState;
72 int recv = client.EndReceive(ar);
73
74 // Is connection closed?
75 if (recv == 0)
76 {
77 client.Close();
78 Close(ID);
79 return;
80 }
81
82 // Call receive event
83 DataReceived(ID, RecvQueue, 0, recv);
84
85 // Start new receive
86 BeginReceive();
87 }
88
89 public void Send(int clientID, byte[] data, int offset, int len)
90 {
91 Client.BeginSend(data, offset, len, SocketFlags.None, new AsyncCallback(asyncDataSent), Client);
92 }
93
94 /// <summary>
95 /// Callback for successful send
96 /// </summary>
97 /// <param name="ar"></param>
98 void asyncDataSent(IAsyncResult ar)
99 {
100 Socket client = (Socket)ar.AsyncState;
101 int sent = client.EndSend(ar);
102 DataSent(ID, sent);
103 }
104
105 public void Disconnect()
106 {
107 Client.Close();
108 Close(ID);
109 }
110 }
111}