sdk/samples/WCFSamples/TechnologySamples/Extensibility/Instancing/Durable/CS/extensions/DurableInstanceContextRequestSessionChannel.cs

   1 using System;
   2 using System.Collections.Generic;
   3 using System.Text;
   4 using System.ServiceModel;
   5 using System.ServiceModel.Channels;
   6
   7 namespace Microsoft.ServiceModel.Samples
   8 {
   9     class DurableInstanceContextRequestSessionChannel : DurableInstanceContextChannelBase,
  10         IRequestSessionChannel
  11     {
  12         IRequestSessionChannel innerRequestSessionChannel;
  13
  14         // Indicates whether the current message is the first
  15         // message in a session or not.
  16         bool isFirstMessage;
  17
  18         // Lock should be acquired on this object before changing the
  19         // state of this channel.
  20         object stateLock;
  21
  22         public DurableInstanceContextRequestSessionChannel(ChannelManagerBase channelManager,
  23             ContextType contextType,
  24             IRequestSessionChannel innerChannel,
  25             string contextStoreLocation)
  26             : base(channelManager, innerChannel)
  27         {
  28             this.contextType = contextType;
  29             this.innerRequestSessionChannel = innerChannel;
  30             this.contextStoreLocation = contextStoreLocation;
  31             this.endpointAddress = innerChannel.RemoteAddress;
  32             this.stateLock = new object();
  33             this.isFirstMessage = true;
  34         }
  35
  36         public IOutputSession Session
  37         {
  38             get
  39             {
  40                 return innerRequestSessionChannel.Session;
  41             }
  42         }
  43
  44         public IAsyncResult BeginRequest(Message message, TimeSpan timeout,
  45             AsyncCallback callback, object state)
  46         {
  47             lock (stateLock)
  48             {
  49                 // Apply the context if the message is the first message.
  50                 if (isFirstMessage)
  51                 {
  52                     ApplyContext(message);
  53                     isFirstMessage = false;
  54                 }
  55             }
  56
  57             return innerRequestSessionChannel.BeginRequest(message, timeout,
  58                 callback, state);
  59         }
  60
  61         public IAsyncResult BeginRequest(Message message,
  62             AsyncCallback callback, object state)
  63         {
  64             return BeginRequest(message, DefaultSendTimeout, callback, state);
  65         }
  66
  67         public Message EndRequest(IAsyncResult result)
  68         {
  69             return innerRequestSessionChannel.EndRequest(result);
  70         }
  71
  72         public EndpointAddress RemoteAddress
  73         {
  74             get
  75             {
  76                 return innerRequestSessionChannel.RemoteAddress;
  77             }
  78         }
  79
  80         public Message Request(Message message, TimeSpan timeout)
  81         {
  82             lock (stateLock)
  83             {
  84                 // Apply the context if the message is the first message.
  85                 if (isFirstMessage)
  86                 {
  87                     ApplyContext(message);
  88                     isFirstMessage = false;
  89                 }
  90             }
  91
  92             return innerRequestSessionChannel.Request(message, timeout);
  93         }
  94
  95         public Message Request(Message message)
  96         {
  97             return Request(message, DefaultSendTimeout);
  98         }
  99
 100         public Uri Via
 101         {
 102             get
 103             {
 104                 return innerRequestSessionChannel.Via;
 105             }
 106         }
 107     }
 108 }