class/System.ServiceModel/System.ServiceModel/ServiceRuntimeChannel.cs

   1 //
   2 // ServiceRuntimeChannel.cs
   3 //
   4 // Author:
   5 //      Atsushi Enomoto <atsushi@ximian.com>
   6 //
   7 // Copyright (C) 2007 Novell, Inc.  http://www.novell.com
   8 //
   9 // Permission is hereby granted, free of charge, to any person obtaining
  10 // a copy of this software and associated documentation files (the
  11 // "Software"), to deal in the Software without restriction, including
  12 // without limitation the rights to use, copy, modify, merge, publish,
  13 // distribute, sublicense, and/or sell copies of the Software, and to
  14 // permit persons to whom the Software is furnished to do so, subject to
  15 // the following conditions:
  16 //
  17 // The above copyright notice and this permission notice shall be
  18 // included in all copies or substantial portions of the Software.
  19 //
  20 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  21 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  22 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  23 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  24 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  25 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  26 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  27 //
  28 using System;
  29 using System.Collections.Generic;
  30 using System.Reflection;
  31 using System.ServiceModel.Channels;
  32 using System.ServiceModel.Description;
  33 using System.ServiceModel.Dispatcher;
  34 using System.ServiceModel.MonoInternal;
  35
  36 namespace System.ServiceModel.MonoInternal
  37 {
  38         // FIXME: this is a (similar) workaround for bug 571907.
  39         public class DuplexServiceRuntimeChannel : ServiceRuntimeChannel, IDuplexContextChannel
  40         {
  41                 public DuplexServiceRuntimeChannel (IChannel channel, DispatchRuntime runtime)
  42                         : base (channel, runtime)
  43                 {
  44                         // setup callback ClientRuntimeChannel.
  45                         var crt = runtime.CallbackClientRuntime;
  46                         var cd = ContractDescriptionGenerator.GetCallbackContract (runtime.Type, crt.CallbackClientType);
  47                         client = new ClientRuntimeChannel (crt, cd, this.DefaultOpenTimeout, this.DefaultCloseTimeout, channel, null,
  48                                                            runtime.ChannelDispatcher.MessageVersion, this.RemoteAddress, null);
  49                 }
  50
  51                 ClientRuntimeChannel client;
  52
  53                 public override bool AllowOutputBatching {
  54                         get { return client.AllowOutputBatching; }
  55                         set { client.AllowOutputBatching = value; }
  56                 }
  57
  58                 public virtual TimeSpan OperationTimeout {
  59                         get { return client.OperationTimeout; }
  60                         set { client.OperationTimeout = value; }
  61                 }
  62
  63                 public bool AutomaticInputSessionShutdown {
  64                         get { throw new NotImplementedException (); }
  65                         set { throw new NotImplementedException (); }
  66                 }
  67
  68                 public InstanceContext CallbackInstance { get; set; }
  69
  70                 Action<TimeSpan> session_shutdown_delegate;
  71
  72                 public void CloseOutputSession (TimeSpan timeout)
  73                 {
  74                         throw new NotImplementedException ();
  75                 }
  76
  77                 public IAsyncResult BeginCloseOutputSession (TimeSpan timeout, AsyncCallback callback, object state)
  78                 {
  79                         if (session_shutdown_delegate == null)
  80                                 session_shutdown_delegate = new Action<TimeSpan> (CloseOutputSession);
  81                         return session_shutdown_delegate.BeginInvoke (timeout, callback, state);
  82                 }
  83
  84                 public void EndCloseOutputSession (IAsyncResult result)
  85                 {
  86                         session_shutdown_delegate.EndInvoke (result);
  87                 }
  88
  89                 // proxy base implementation.
  90
  91                 public IAsyncResult BeginProcess (MethodBase method, string operationName, object [] parameters, AsyncCallback callback, object asyncState)
  92                 {
  93                         return client.BeginProcess (method, operationName, parameters, callback, asyncState);
  94                 }
  95
  96                 public object EndProcess (MethodBase method, string operationName, object [] parameters, IAsyncResult result)
  97                 {
  98                         return client.EndProcess (method, operationName, parameters, result);
  99                 }
 100
 101                 public object Process (MethodBase method, string operationName, object [] parameters)
 102                 {
 103                         return client.Process (method, operationName, parameters);
 104                 }
 105         }
 106
 107         // FIXME: this is a (similar) workaround for bug 571907.
 108         public class ServiceRuntimeChannel : CommunicationObject, IServiceChannel
 109         {
 110                 IExtensionCollection<IContextChannel> extensions;
 111                 readonly IChannel channel;
 112                 readonly DispatchRuntime runtime;
 113
 114                 public ServiceRuntimeChannel (IChannel channel, DispatchRuntime runtime)
 115                 {
 116                         this.channel = channel;
 117                         this.runtime = runtime;
 118                 }
 119
 120                 #region IContextChannel
 121
 122                 [MonoTODO]
 123                 public virtual bool AllowOutputBatching { get; set; }
 124
 125                 public IInputSession InputSession {
 126                         get {
 127                                 var ch = channel as ISessionChannel<IInputSession>;
 128                                 if (ch != null)
 129                                         return ch.Session;
 130                                 var dch = channel as ISessionChannel<IDuplexSession>;
 131                                 return dch != null ? dch.Session : null;
 132                         }
 133                 }
 134
 135                 public EndpointAddress LocalAddress {
 136                         get {
 137                                 if (channel is IReplyChannel)
 138                                         return ((IReplyChannel) channel).LocalAddress;
 139                                 if (channel is IInputChannel)
 140                                         return ((IInputChannel) channel).LocalAddress;
 141                                 return null;
 142                         }
 143                 }
 144
 145                 [MonoTODO]
 146                 public virtual TimeSpan OperationTimeout { get; set; }
 147
 148                 public IOutputSession OutputSession {
 149                         get {
 150                                 var dch = channel as ISessionChannel<IDuplexSession>;
 151                                 return dch != null ? dch.Session : null;
 152                         }
 153                 }
 154
 155                 public EndpointAddress RemoteAddress {
 156                         get {
 157                                 if (channel is IDuplexChannel)
 158                                         return ((IDuplexChannel) channel).RemoteAddress;
 159                                 return null;
 160                         }
 161                 }
 162
 163                 public string SessionId {
 164                         get { return InputSession != null ? InputSession.Id : null; }
 165                 }
 166
 167                 #endregion
 168
 169                 // CommunicationObject
 170                 protected internal override TimeSpan DefaultOpenTimeout {
 171                         get { return runtime.ChannelDispatcher.DefaultOpenTimeout; }
 172                 }
 173
 174                 protected internal override TimeSpan DefaultCloseTimeout {
 175                         get { return runtime.ChannelDispatcher.DefaultCloseTimeout; }
 176                 }
 177
 178                 protected override void OnAbort ()
 179                 {
 180                         channel.Abort ();
 181                 }
 182
 183                 protected override IAsyncResult OnBeginClose (
 184                         TimeSpan timeout, AsyncCallback callback, object state)
 185                 {
 186                         return channel.BeginClose (timeout, callback, state);
 187                 }
 188
 189                 protected override void OnEndClose (IAsyncResult result)
 190                 {
 191                         channel.EndClose (result);
 192                 }
 193
 194                 protected override void OnClose (TimeSpan timeout)
 195                 {
 196                         channel.Close (timeout);
 197                 }
 198
 199                 protected override IAsyncResult OnBeginOpen (
 200                         TimeSpan timeout, AsyncCallback callback, object state)
 201                 {
 202                         return channel.BeginOpen (timeout, callback, state);
 203                 }
 204
 205                 protected override void OnEndOpen (IAsyncResult result)
 206                 {
 207                         channel.EndOpen (result);
 208                 }
 209
 210                 protected override void OnOpen (TimeSpan timeout)
 211                 {
 212                         channel.Open (timeout);
 213                 }
 214
 215                 // IChannel
 216                 public T GetProperty<T> () where T : class
 217                 {
 218                         return channel.GetProperty<T> ();
 219                 }
 220
 221                 // IExtensibleObject<IContextChannel>
 222                 public IExtensionCollection<IContextChannel> Extensions {
 223                         get {
 224                                 if (extensions == null)
 225                                         extensions = new ExtensionCollection<IContextChannel> (this);
 226                                 return extensions;
 227                         }
 228                 }
 229
 230                 public Uri ListenUri {
 231                         get { return runtime.ChannelDispatcher.Listener.Uri; }
 232                 }
 233
 234                 #region IDisposable Members
 235
 236                 public void Dispose ()
 237                 {
 238                         Close ();
 239                 }
 240
 241                 #endregion
 242         }
 243 }