mono/mcs/class/System.Runtime.Remoting/System.Runtime.Remoting.Channels.CORBA/CORBAServerChannel.cs

//
// System.Runtime.Remoting.Channels.CORBA.CORBAServerChannel.cs
//
// Author: Dietmar Maurer ([email protected])
//
// 2002 (C) Copyright, Ximian, Inc.
//

using System.Collections;
using System.Runtime.Remoting.Messaging;
using System.Text.RegularExpressions;
using System.Net.Sockets;
using System.Net;
using System.Threading;
using System.IO;

namespace System.Runtime.Remoting.Channels.CORBA
{
	public class CORBAServerChannel : IChannelReceiver, IChannel
	{
		int port = 0;
		string name = "simple";
		string host;
		int priority = 1;
		Thread server_thread = null;
		TcpListener listener;
		CORBAServerTransportSink sink;
		ChannelDataStore channel_data;
		
		void Init (IServerChannelSinkProvider provider) {
			if (provider == null) {
				provider = new CORBAServerFormatterSinkProvider ();
			}
			
			IServerChannelSink next_sink = ChannelServices.CreateServerChannelSinkChain (provider, this);

			host = Dns.GetHostByName(Dns.GetHostName()).HostName;
			
			string [] uris = null;
			
			if (port != 0) {
				uris = new String [1];
				uris [0] = GetChannelUri ();
			}
			
			channel_data = new ChannelDataStore (uris);;

			sink = new CORBAServerTransportSink (next_sink);
			
			listener = new TcpListener (port);
			StartListening (null);
		}
		
		public CORBAServerChannel (int port)
		{
			this.port = port;
			Init (null);
		}

		public CORBAServerChannel (IDictionary properties,
					 IServerChannelSinkProvider serverSinkProvider)
		{
			port = (int)properties ["port"];
			Init (serverSinkProvider);
		}

		public CORBAServerChannel (string name, int port,
					    IServerChannelSinkProvider serverSinkProvider)
		{
			name = name;
			this.port = port;
			Init (serverSinkProvider);
		}
		
		public CORBAServerChannel (string name, int port)
		{
			name = name;
			this.port = port;
			Init (null);
		}
		
		public object ChannelData
		{
			get {
				return channel_data;
			}
		}

		public string ChannelName
		{
			get {
				return name;
			}
		}

		public int ChannelPriority
		{
			get {
				return priority;
			}
		}

		string GetChannelUri ()
		{
			return "corba://" + host + ":" + port;
		}
		
		public string[] GetUrlsForUri (string uri)
		{
			string [] chnl_uris = channel_data.ChannelUris;
			
			if (uri.IndexOf ('/') != 0)
				uri = "/" + uri;

			string [] result = new String [chnl_uris.Length];

			for (int i = 0; i < chnl_uris.Length; i++) {
				result [i] = chnl_uris [i] + uri;
			}
			
			return result;
		}

		public string Parse (string url, out string objectURI)
		{
			int port;
			
			string host = CORBAChannel.ParseCORBAURL (url, out objectURI, out port);

			return GetChannelUri ();
		}

		void WaitForConnections ()
		{
			while (true) {
				TcpClient client = listener.AcceptTcpClient ();

				sink.InternalProcessMessage (client.GetStream ());

				client.Close ();
			}
		}
		
		public void StartListening (object data)
		{
			if (server_thread == null) {
				listener.Start ();
				if (port == 0) {
					port = ((IPEndPoint)listener.LocalEndpoint).Port;
					channel_data.ChannelUris = new String [1];
					channel_data.ChannelUris [0] = GetChannelUri ();
				}

				server_thread = new Thread (new ThreadStart (WaitForConnections));
				server_thread.Start ();
			}
		}

		public void StopListening (object data)
		{
			if (server_thread != null) {
				server_thread.Abort ();
				server_thread = null;
				listener.Stop ();
			}
		}
	}
}