sdk/samples/WCFSamples/TechnologySamples/Extensibility/Channels/HttpCookieSession/CS/extensions/LayeredChannel.cs

   1
   2 //  Copyright (c) Microsoft Corporation.  All Rights Reserved.
   3
   4 namespace Microsoft.ServiceModel.Samples
   5 {
   6     using System;
   7     using System.ServiceModel.Channels;
   8
   9     abstract class LayeredChannel<TInnerChannel> : ChannelBase
  10         where TInnerChannel : class, IChannel
  11     {
  12         TInnerChannel innerChannel;
  13         EventHandler onInnerChannelFaulted;
  14
  15         protected LayeredChannel(ChannelManagerBase channelManager, TInnerChannel innerChannel)
  16             : base(channelManager)
  17         {
  18             this.innerChannel = innerChannel;
  19             this.onInnerChannelFaulted = new EventHandler(OnInnerChannelFaulted);
  20             this.innerChannel.Faulted += this.onInnerChannelFaulted;
  21         }
  22
  23         protected TInnerChannel InnerChannel
  24         {
  25             get { return this.innerChannel; }
  26         }
  27
  28         public override T GetProperty<T>()
  29         {
  30             T baseProperty = base.GetProperty<T>();
  31             if (baseProperty != null)
  32             {
  33                 return baseProperty;
  34             }
  35
  36             return this.InnerChannel.GetProperty<T>();
  37         }
  38
  39         protected override void OnClosing()
  40         {
  41             this.innerChannel.Faulted -= this.onInnerChannelFaulted;
  42             base.OnClosing();
  43         }
  44
  45         protected override void OnAbort()
  46         {
  47             this.innerChannel.Abort();
  48         }
  49
  50         protected override void OnClose(TimeSpan timeout)
  51         {
  52             this.innerChannel.Close(timeout);
  53         }
  54
  55         protected override IAsyncResult OnBeginClose(TimeSpan timeout, AsyncCallback callback, object state)
  56         {
  57             return this.innerChannel.BeginClose(timeout, callback, state);
  58         }
  59
  60         protected override void OnEndClose(IAsyncResult result)
  61         {
  62             this.innerChannel.EndClose(result);
  63         }
  64
  65         protected override void OnOpen(TimeSpan timeout)
  66         {
  67             this.innerChannel.Open(timeout);
  68         }
  69
  70         protected override IAsyncResult OnBeginOpen(TimeSpan timeout, AsyncCallback callback, object state)
  71         {
  72             return this.innerChannel.BeginOpen(timeout, callback, state);
  73         }
  74
  75         protected override void OnEndOpen(IAsyncResult result)
  76         {
  77             this.innerChannel.EndOpen(result);
  78         }
  79
  80         void OnInnerChannelFaulted(object sender, EventArgs e)
  81         {
  82             this.Fault();
  83         }
  84     }
  85 }