1 write to Channel
System.ServiceModel.Primitives (1)
System\ServiceModel\Dispatcher\MessageRpc.cs (1)
72
Channel
= channel;
25 references to Channel
System.ServiceModel.Primitives (25)
System\ServiceModel\Dispatcher\ConcurrencyBehavior.cs (1)
25
return IsConcurrent(_concurrencyMode, _enforceOrderedReceive, rpc.
Channel
.HasSession);
System\ServiceModel\Dispatcher\ErrorBehavior.cs (1)
64
ProvideFault(rpc.Error, rpc.
Channel
.GetProperty<FaultConverter>(), ref rpc.FaultInfo);
System\ServiceModel\Dispatcher\ImmutableDispatchRuntime.cs (13)
108
rpc.Correlation[offset + i] = _messageInspectors[i].AfterReceiveRequest(ref rpc.Request, (IClientChannel)rpc.
Channel
.Proxy, rpc.InstanceContext);
312
if (rpc.
Channel
.IsPending)
314
rpc.
Channel
.IsPending = false;
316
ChannelDispatcher channelDispatcher = rpc.
Channel
.ChannelDispatcher;
322
IChannel proxy = rpc.
Channel
.Proxy as IChannel;
329
channelDispatcher.PendingChannels.Remove(rpc.
Channel
.Binder.Channel);
441
if (!rpc.
Channel
.HasSession)
447
AddMessageProperties(rpc.Reply, rpc.OperationContext, rpc.
Channel
);
492
if (!rpc.
Channel
.IsReplyChannel &&
503
if (replyTo != null && replyTo.IsNone && rpc.
Channel
.IsReplyChannel)
513
rpc.
Channel
.IncrementActivity();
724
rpc.ReplyTimeoutHelper = new TimeoutHelper(rpc.
Channel
.OperationTimeout);
916
rpc.
Channel
.DecrementActivity();
System\ServiceModel\Dispatcher\InstanceBehavior.cs (1)
61
rpc.InstanceContext.Open(rpc.
Channel
.CloseTimeout);
System\ServiceModel\Dispatcher\MessageRpc.cs (6)
220
if ((
Channel
!= null) &&
Channel
.HasSession)
224
Channel
.Abort();
239
if ((
Channel
!= null) &&
Channel
.HasSession)
243
Channel
.Close(ChannelHandler.CloseAfterFaultTimeout);
System\ServiceModel\Dispatcher\TerminatingOperationBehavior.cs (3)
50
if (rpc.Operation.IsTerminating && rpc.
Channel
.HasSession)
52
var timer = new Timer(s_abortChannelTimerCallback, rpc.
Channel
.Binder.Channel, rpc.
Channel
.CloseTimeout, TimeSpan.FromMilliseconds(-1));