//
// HttpServerChannel.cs
//
// Author:
// Michael Hutchinson <mhutchinson@novell.com>
//
// Copyright (C) 2008 Novell, Inc (http://www.novell.com)
//
// Permission is hereby granted, free of charge, to any person obtaining
// a copy of this software and associated documentation files (the
// "Software"), to deal in the Software without restriction, including
// without limitation the rights to use, copy, modify, merge, publish,
// distribute, sublicense, and/or sell copies of the Software, and to
// permit persons to whom the Software is furnished to do so, subject to
// the following conditions:
//
// The above copyright notice and this permission notice shall be
// included in all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
//
using System.Net;
using System.Collections;
using System.Globalization;
using System.Threading;
using System.Runtime.Remoting.MetadataServices;
using System.Runtime.Remoting.Messaging;
namespace System.Runtime.Remoting.Channels.Http{
public class HttpServerChannel : BaseChannelWithProperties,
IChannel, IChannelReceiver, IChannelReceiverHook
{
string name = "http server";
int priority = 1;
string machineName = null;
IPAddress bindAddress = IPAddress.Any;
int port = -1; // querying GetChannelUri () on .NET indicates this is the default value
bool suppressChannelData = false;
bool useIPAddress = true;
#if !NET_2_0
bool exclusiveAddressUse = true;
#endif
bool wantsToListen = true;
HttpServerTransportSink sink;
ChannelDataStore channelData;
RemotingHttpListener listener;
#region Constructors
public HttpServerChannel ()
{
//DONT START SERVER, EVEN THOUGH ALL OTHER CONSTRUCTORS DO
BuildSink (null);
}
public HttpServerChannel (int port)
{
this.port = port;
BuildSink (null);
}
[MonoTODO ("Handle the listen property")]
public HttpServerChannel (IDictionary properties, IServerChannelSinkProvider sinkProvider)
{
if (properties != null) {
foreach (DictionaryEntry property in properties) {
switch ((string)property.Key) {
case "name":
//NOTE: matching MS behaviour: throws InvalidCastException, allows null
this.name = (string)property.Value;
break;
case "priority":
this.priority = Convert.ToInt32 (property.Value);
break;
case "port":
this.port = Convert.ToInt32 (property.Value);
break;
case "suppressChannelData":
this.suppressChannelData = Convert.ToBoolean (property.Value);
break;
case "bindTo":
bindAddress = IPAddress.Parse ((string)property.Value);
break;
case "useIpAddress":
this.useIPAddress = Convert.ToBoolean (property.Value);
break;
case "machineName":
this.machineName = (string)property.Value;
break;
case "listen":
this.wantsToListen = Convert.ToBoolean (property.Value);
break;
#if !NET_2_0
case "exclusiveAddressUse":
this.exclusiveAddressUse = Convert.ToBoolean (property.Value);
break;
#endif
}
}
}
BuildSink (sinkProvider);
}
public HttpServerChannel (string name, int port)
: this (name, port, null)
{
}
public HttpServerChannel (string name, int port, IServerChannelSinkProvider sinkProvider)
{
this.name = name;
this.port = port;
BuildSink (sinkProvider);
}
void BuildSink (IServerChannelSinkProvider sinkProvider)
{
//resolve names (modified from TcpChannel)
if (machineName == null) {
if (useIPAddress) {
if (!bindAddress.Equals (IPAddress.Any)) {
machineName = bindAddress.ToString ();
} else {
IPHostEntry hostEntry = Dns.Resolve (Dns.GetHostName ());
if (hostEntry.AddressList.Length == 0)
throw new RemotingException ("IP address could not be determined for this host");
// We DON'T want to take the resolved address from the hostEntry, since the socket
// should still bind to IPAddress.Any, so that we get the loopback too
machineName = hostEntry.AddressList[0].ToString ();
}
} else {
IPHostEntry hostEntry = Dns.GetHostByName (Dns.GetHostName ());
bindAddress = hostEntry.AddressList[0];
machineName = hostEntry.HostName;
}
}
if (sinkProvider == null) {
//build a default chain that can handle wsdl, soap, binary
sinkProvider = new SdlChannelSinkProvider (); //for wsdl
sinkProvider.Next = new SoapServerFormatterSinkProvider ();
sinkProvider.Next.Next = new BinaryServerFormatterSinkProvider ();
}
//MS compat: channelData is null when port < 0
if (port >= 0) {
channelData = new ChannelDataStore (null);
IServerChannelSinkProvider provider = sinkProvider;
while (provider != null) {
provider.GetChannelData (channelData);
provider = provider.Next;
}
}
//create the sink chain and add an HTTP sink
IServerChannelSink nextSink = ChannelServices.CreateServerChannelSinkChain (sinkProvider, this);
sink = new HttpServerTransportSink (nextSink);
// BaseChannelWithProperties wants this to be set with the chain
base.SinksWithProperties = nextSink;
StartListening (null);
}
#endregion
#region IChannel
public string ChannelName
{
get { return name; }
}
public int ChannelPriority
{
get { return priority; }
}
public string Parse (string url, out string objectURI)
{
return HttpChannel.ParseInternal (url, out objectURI);
}
#endregion
public string GetChannelUri ()
{
return "http://" + machineName + ":" + port;
}
#region IChannelReceiver (: IChannel)
public object ChannelData
{
get
{
return suppressChannelData ? null
: channelData;
}
}
//from TcpServerChannel
public virtual string[] GetUrlsForUri (string objectUri)
{
if (!objectUri.StartsWith ("/"))
objectUri = "/" + objectUri;
if (channelData == null || channelData.ChannelUris == null || channelData.ChannelUris.Length < 1) {
return new string[] { GetChannelUri () + objectUri };
}
string[] channelUris = channelData.ChannelUris;
string[] result = new string[channelUris.Length];
for (int i = 0; i < channelUris.Length; i++)
result[i] = channelUris[i] + objectUri;
return result;
}
public void StartListening (object data)
{
if (listener != null)
return;
if (port < 0)
return;
try {
listener = new RemotingHttpListener (bindAddress, port, sink);
} catch (Exception) {
if (listener != null) {
listener.Dispose ();
listener = null;
}
throw;
}
if (port == 0)
port = listener.AssignedPort;
channelData.ChannelUris = new string [] { GetChannelUri () };
wantsToListen = false;
}
public void StopListening (object data)
{
if (listener != null) {
listener.Dispose ();
listener = null;
}
}
#endregion
#region BaseChannelWithProperties overrides
public override object this[object key]
{
get { return base[key]; }
set { base[key] = value; }
}
public override ICollection Keys
{
get { return new object[0]; }
}
#endregion
#region IChannelReceiverHook
public void AddHookChannelUri (string channelUri)
{
string [] newUris = new string[1] { channelUri };
if (channelData == null)
channelData = new ChannelDataStore (newUris);
else
channelData.ChannelUris = newUris;
wantsToListen = false;
}
public string ChannelScheme
{
get { return "http"; }
}
public IServerChannelSink ChannelSinkChain
{
get { return (IServerChannelSink)base.SinksWithProperties; }
}
public bool WantsToListen
{
get { return wantsToListen; }
set {
throw new NotImplementedException ("Behaviour not yet determined");
}
}
#endregion
}
}
|