3 instantiations of ChannelHandler
System.ServiceModel (3)
System\ServiceModel\Channels\ServiceChannelFactory.cs (1)
334
duplexChannelBinder.ChannelHandler = new
ChannelHandler
(this.messageVersion, binder, serviceChannel);
System\ServiceModel\Dispatcher\ListenerHandler.cs (1)
557
ChannelHandler handler = new
ChannelHandler
(listenerBinder.MessageVersion, channel.Binder, this.throttle, this, (channel.Throttle != null), this.wrappedTransaction, idleManager);
System\ServiceModel\Dispatcher\TransactedBatchContext.cs (1)
212
ChannelHandler newHandler = new
ChannelHandler
(this.handler, context);
68 references to ChannelHandler
System.ServiceModel (68)
System\ServiceModel\Channels\BufferedReceiveMessageProperty.cs (3)
51
this.messageBuffer = (MessageBuffer)operationContext.IncomingMessageProperties[
ChannelHandler
.MessageBufferPropertyName];
54
operationContext.IncomingMessageProperties[
ChannelHandler
.MessageBufferPropertyName] = dummyMessageBuffer;
62
requestMessage.Properties[
ChannelHandler
.MessageBufferPropertyName] = this.messageBuffer;
System\ServiceModel\Dispatcher\ChannelHandler.cs (30)
40
static AsyncCallback onAsyncReplyComplete = Fx.ThunkCallback(new AsyncCallback(
ChannelHandler
.OnAsyncReplyComplete));
41
static AsyncCallback onAsyncReceiveComplete = Fx.ThunkCallback(new AsyncCallback(
ChannelHandler
.OnAsyncReceiveComplete));
42
static Action<object> onContinueAsyncReceive = new Action<object>(
ChannelHandler
.OnContinueAsyncReceive);
43
static Action<object> onStartSyncMessagePump = new Action<object>(
ChannelHandler
.OnStartSyncMessagePump);
44
static Action<object> onStartAsyncMessagePump = new Action<object>(
ChannelHandler
.OnStartAsyncMessagePump);
45
static Action<object> onStartSingleTransactedBatch = new Action<object>(
ChannelHandler
.OnStartSingleTransactedBatch);
46
static Action<object> openAndEnsurePump = new Action<object>(
ChannelHandler
.OpenAndEnsurePump);
185
internal ChannelHandler(
ChannelHandler
handler, TransactedBatchContext context)
288
internal static void Register(
ChannelHandler
handler)
293
internal static void Register(
ChannelHandler
handler, RequestContext request)
377
return new CompletedAsyncResult(
ChannelHandler
.onAsyncReceiveComplete, this);
380
return this.receiver.BeginTryReceive(TimeSpan.MaxValue,
ChannelHandler
.onAsyncReceiveComplete, this);
617
ActionItem.Schedule(
ChannelHandler
.onStartSyncMessagePump, this);
626
ActionItem.Schedule(
ChannelHandler
.onContinueAsyncReceive, result);
634
ActionItem.Schedule(
ChannelHandler
.onStartAsyncMessagePump, this);
641
ActionItem.Schedule(
ChannelHandler
.onStartSingleTransactedBatch, this);
1032
((
ChannelHandler
)state).AsyncMessagePump();
1037
ChannelHandler
handler = state as
ChannelHandler
;
1056
ChannelHandler
handler = state as
ChannelHandler
;
1064
((
ChannelHandler
)result.AsyncState).AsyncMessagePump(result);
1071
((
ChannelHandler
)result.AsyncState).AsyncMessagePump(result);
1076
((
ChannelHandler
)state).OpenAndEnsurePump();
1263
var result = request.BeginReply(reply,
ChannelHandler
.onAsyncReplyComplete, state);
1266
ChannelHandler
.AsyncReplyComplete(result, state);
1432
ChannelHandler
.AsyncReplyComplete(result, state);
2019
public
ChannelHandler
ChannelHandler;
2023
public RequestInfo(
ChannelHandler
channelHandler)
2077
public
ChannelHandler
ChannelHandler;
System\ServiceModel\Dispatcher\DispatchRuntime.cs (1)
832
serviceChannel.Close(
ChannelHandler
.CloseAfterFaultTimeout);
System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (3)
32
ChannelHandler
channelHandler;
72
internal
ChannelHandler
ChannelHandler
308
ChannelHandler
.Register(this.ChannelHandler);
System\ServiceModel\Dispatcher\ListenerHandler.cs (2)
557
ChannelHandler
handler = new ChannelHandler(listenerBinder.MessageVersion, channel.Binder, this.throttle, this, (channel.Throttle != null), this.wrappedTransaction, idleManager);
576
ChannelHandler
.Register(handler);
System\ServiceModel\Dispatcher\MessageRpc.cs (9)
28
internal readonly
ChannelHandler
channelHandler;
82
ServiceChannel channel, ServiceHostBase host,
ChannelHandler
channelHandler, bool cleanThread,
402
this.Channel.Close(
ChannelHandler
.CloseAfterFaultTimeout);
438
ChannelHandler
.Register(this.channelHandler);
739
public
ChannelHandler
ChannelHandler
831
ChannelHandler
handler;
833
public MessageRpcInvokeNotification(ServiceModelActivity activity,
ChannelHandler
handler)
845
ChannelHandler
.Register(this.handler);
854
ChannelHandler
.Register(this.handler, request);
System\ServiceModel\Dispatcher\ReceiveContextRPCFacet.cs (6)
100
public IAsyncResult BeginComplete(TimeSpan timeout, Transaction transaction,
ChannelHandler
channelHandler, AsyncCallback callback, object state)
189
ChannelHandler
channelHandler;
305
ChannelHandler
channelHandler;
307
public TransactionOutcomeListener(ReceiveContext receiveContext, Transaction transaction,
ChannelHandler
handler)
314
public static void EnsureReceiveContextAbandonOnTransactionRollback(ReceiveContext receiveContext, Transaction transaction,
ChannelHandler
channelHandler)
375
public
ChannelHandler
ChannelHandler
System\ServiceModel\Dispatcher\ServiceThrottle.cs (10)
259
bool PrivateAcquireCall(
ChannelHandler
channel)
282
bool PrivateAcquireDynamic(
ChannelHandler
channel)
287
bool PrivateAcquireInstanceContext(
ChannelHandler
channel)
300
internal bool AcquireCall(
ChannelHandler
channel)
308
internal bool AcquireInstanceContextAndDynamic(
ChannelHandler
channel, bool acquireInstanceContextThrottle)
342
ChannelHandler
channel = (
ChannelHandler
)state;
352
((
ChannelHandler
)state).ThrottleAcquired();
357
ChannelHandler
channel = (
ChannelHandler
)state;
System\ServiceModel\Dispatcher\TransactedBatchContext.cs (4)
176
ChannelHandler
handler;
178
internal SharedTransactedBatchContext(
ChannelHandler
handler, ChannelDispatcher dispatcher, int maxConcurrentBatches)
212
ChannelHandler
newHandler = new ChannelHandler(this.handler, context);
213
ChannelHandler
.Register(newHandler);