2 // System.Runtime.Remoting.Channels.Tcp.TcpServerChannel.cs
4 // Author: Rodrigo Moya (rodrigo@ximian.com)
5 // Lluis Sanchez Gual (lluis@ideary.com)
7 // 2002 (C) Copyright, Ximian, Inc.
11 // Permission is hereby granted, free of charge, to any person obtaining
12 // a copy of this software and associated documentation files (the
13 // "Software"), to deal in the Software without restriction, including
14 // without limitation the rights to use, copy, modify, merge, publish,
15 // distribute, sublicense, and/or sell copies of the Software, and to
16 // permit persons to whom the Software is furnished to do so, subject to
17 // the following conditions:
19 // The above copyright notice and this permission notice shall be
20 // included in all copies or substantial portions of the Software.
22 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
23 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
24 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
25 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
26 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
27 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
28 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
31 using System.Collections;
32 using System.Runtime.Remoting.Messaging;
33 using System.Text.RegularExpressions;
34 using System.Net.Sockets;
36 using System.Threading;
38 using System.Runtime.Remoting.Channels;
40 namespace System.Runtime.Remoting.Channels.Tcp
42 public class TcpServerChannel : IChannelReceiver, IChannel
48 bool supressChannelData = false;
49 bool useIpAddress = true;
51 IPAddress bindAddress = IPAddress.Any;
52 Thread server_thread = null;
54 TcpServerTransportSink sink;
55 ChannelDataStore channel_data;
57 RemotingThreadPool threadPool;
60 private volatile bool stopped = false;
63 void Init (IServerChannelSinkProvider serverSinkProvider)
65 if (serverSinkProvider == null)
67 serverSinkProvider = new BinaryServerFormatterSinkProvider ();
73 if (!bindAddress.Equals(IPAddress.Any)) host = bindAddress.ToString ();
75 IPHostEntry he = Dns.Resolve (Dns.GetHostName());
76 if (he.AddressList.Length == 0) throw new RemotingException ("IP address could not be determined for this host");
77 host = he.AddressList [0].ToString ();
81 host = Dns.GetHostByName(Dns.GetHostName()).HostName;
84 // Gets channel data from the chain of channel providers
86 channel_data = new ChannelDataStore (null);
87 IServerChannelSinkProvider provider = serverSinkProvider;
88 while (provider != null)
90 provider.GetChannelData(channel_data);
91 provider = provider.Next;
94 // Creates the sink chain that will process all incoming messages
96 IServerChannelSink next_sink = ChannelServices.CreateServerChannelSinkChain (serverSinkProvider, this);
97 sink = new TcpServerTransportSink (next_sink);
100 public TcpServerChannel (int port)
106 public TcpServerChannel (IDictionary properties,
107 IServerChannelSinkProvider serverSinkProvider)
109 foreach(DictionaryEntry property in properties)
111 switch((string)property.Key)
114 name = property.Value.ToString();
117 port = Convert.ToInt32(property.Value);
120 priority = Convert.ToInt32(property.Value);
123 bindAddress = IPAddress.Parse((string)property.Value);
125 case "rejectRemoteRequests":
126 if(Convert.ToBoolean(properties["rejectRemoteRequests"]))
127 bindAddress = IPAddress.Loopback;
129 case "supressChannelData":
130 supressChannelData = Convert.ToBoolean (property.Value);
133 useIpAddress = Convert.ToBoolean (property.Value);
136 host = property.Value as string;
140 Init (serverSinkProvider);
143 public TcpServerChannel (string name, int port,
144 IServerChannelSinkProvider serverSinkProvider)
148 Init (serverSinkProvider);
151 public TcpServerChannel (string name, int port)
158 public object ChannelData
161 if (supressChannelData) return null;
162 else return channel_data;
166 public string ChannelName
173 public int ChannelPriority
180 public string GetChannelUri ()
182 return "tcp://" + host + ":" + port;
185 public string[] GetUrlsForUri (string uri)
187 if (!uri.StartsWith ("/")) uri = "/" + uri;
189 string [] chnl_uris = channel_data.ChannelUris;
190 string [] result = new String [chnl_uris.Length];
192 for (int i = 0; i < chnl_uris.Length; i++)
193 result [i] = chnl_uris [i] + uri;
198 public string Parse (string url, out string objectURI)
200 return TcpChannel.ParseChannelUrl (url, out objectURI);
203 void WaitForConnections ()
213 Socket socket = listener.AcceptSocket ();
214 ClientConnection reader = new ClientConnection (this, socket, sink);
216 if (!threadPool.RunThread (new ThreadStart (reader.ProcessMessages)))
218 } catch (Exception e)
221 Console.WriteLine("Exception caught in TcpServerChannel.WaitForConnections during start process message: {0} {1}", e.GetType(), e.Message);
229 Console.WriteLine("Exception caught in TcpServerChannel.WaitForConnections, stop channel's thread : {0} {1}", e.GetType(), e.Message);
234 public void StartListening (object data)
239 listener = new TcpListener (bindAddress, port);
240 if (server_thread == null)
242 threadPool = RemotingThreadPool.GetSharedPool ();
246 port = ((IPEndPoint)listener.LocalEndpoint).Port;
248 string[] uris = new String [1];
249 uris = new String [1];
250 uris [0] = GetChannelUri ();
251 channel_data.ChannelUris = uris;
253 server_thread = new Thread (new ThreadStart (WaitForConnections));
254 server_thread.IsBackground = true;
255 server_thread.Start ();
259 public void StopListening (object data)
264 if (server_thread == null) return;
267 server_thread.Abort ();
269 server_thread.Interrupt ();
273 server_thread.Join ();
274 server_thread = null;
278 class ClientConnection
283 TcpServerTransportSink _sink;
286 byte[] _buffer = new byte[TcpMessageIO.DefaultStreamBufferSize];
288 public ClientConnection (TcpServerChannel serverChannel, Socket socket, TcpServerTransportSink sink)
297 get { return _stream; }
302 get { return _buffer; }
305 public void ProcessMessages()
307 byte[] buffer = new byte[256];
308 NetworkStream ns = new NetworkStream (_socket);
309 _stream = new BufferedStream (ns);
316 MessageStatus type = TcpMessageIO.ReceiveMessageStatus (_stream, buffer);
320 case MessageStatus.MethodMessage:
321 _sink.InternalProcessMessage (this);
324 case MessageStatus.Unknown:
325 case MessageStatus.CancelSignal:
335 Console.WriteLine ("The exception was caught during TcpServerChannel.ProcessMessages: {0}, {1}", ex.GetType(), ex.Message);
353 public IPAddress ClientAddress
356 IPEndPoint ep = _socket.RemoteEndPoint as IPEndPoint;
357 if (ep != null) return ep.Address;