ChannelHandler

System\ServiceModel\Channels\BufferedReceiveMessageProperty.cs (3)

51this.messageBuffer = (MessageBuffer)operationContext.IncomingMessageProperties[ChannelHandler.MessageBufferPropertyName]; 54operationContext.IncomingMessageProperties[ChannelHandler.MessageBufferPropertyName] = dummyMessageBuffer; 62requestMessage.Properties[ChannelHandler.MessageBufferPropertyName] = this.messageBuffer;

System\ServiceModel\Dispatcher\ChannelHandler.cs (30)

40static AsyncCallback onAsyncReplyComplete = Fx.ThunkCallback(new AsyncCallback(ChannelHandler.OnAsyncReplyComplete)); 41static AsyncCallback onAsyncReceiveComplete = Fx.ThunkCallback(new AsyncCallback(ChannelHandler.OnAsyncReceiveComplete)); 42static Action<object> onContinueAsyncReceive = new Action<object>(ChannelHandler.OnContinueAsyncReceive); 43static Action<object> onStartSyncMessagePump = new Action<object>(ChannelHandler.OnStartSyncMessagePump); 44static Action<object> onStartAsyncMessagePump = new Action<object>(ChannelHandler.OnStartAsyncMessagePump); 45static Action<object> onStartSingleTransactedBatch = new Action<object>(ChannelHandler.OnStartSingleTransactedBatch); 46static Action<object> openAndEnsurePump = new Action<object>(ChannelHandler.OpenAndEnsurePump); 185internal ChannelHandler(ChannelHandler handler, TransactedBatchContext context) 288internal static void Register(ChannelHandler handler) 293internal static void Register(ChannelHandler handler, RequestContext request) 377return new CompletedAsyncResult(ChannelHandler.onAsyncReceiveComplete, this); 380return this.receiver.BeginTryReceive(TimeSpan.MaxValue, ChannelHandler.onAsyncReceiveComplete, this); 617ActionItem.Schedule(ChannelHandler.onStartSyncMessagePump, this); 626ActionItem.Schedule(ChannelHandler.onContinueAsyncReceive, result); 634ActionItem.Schedule(ChannelHandler.onStartAsyncMessagePump, this); 641ActionItem.Schedule(ChannelHandler.onStartSingleTransactedBatch, this); 1032((ChannelHandler)state).AsyncMessagePump(); 1037ChannelHandler handler = state as ChannelHandler; 1056ChannelHandler handler = state as ChannelHandler; 1064((ChannelHandler)result.AsyncState).AsyncMessagePump(result); 1071((ChannelHandler)result.AsyncState).AsyncMessagePump(result); 1076((ChannelHandler)state).OpenAndEnsurePump(); 1263var result = request.BeginReply(reply, ChannelHandler.onAsyncReplyComplete, state); 1266ChannelHandler.AsyncReplyComplete(result, state); 1432ChannelHandler.AsyncReplyComplete(result, state); 2019public ChannelHandler ChannelHandler; 2023public RequestInfo(ChannelHandler channelHandler) 2077public ChannelHandler ChannelHandler;

System\ServiceModel\Dispatcher\DispatchRuntime.cs (1)

832serviceChannel.Close(ChannelHandler.CloseAfterFaultTimeout);

System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (3)

32ChannelHandler channelHandler; 72internal ChannelHandler ChannelHandler 308ChannelHandler.Register(this.ChannelHandler);

System\ServiceModel\Dispatcher\ListenerHandler.cs (2)

557ChannelHandler handler = new ChannelHandler(listenerBinder.MessageVersion, channel.Binder, this.throttle, this, (channel.Throttle != null), this.wrappedTransaction, idleManager); 576ChannelHandler.Register(handler);

System\ServiceModel\Dispatcher\MessageRpc.cs (9)

28internal readonly ChannelHandler channelHandler; 82ServiceChannel channel, ServiceHostBase host, ChannelHandler channelHandler, bool cleanThread, 402this.Channel.Close(ChannelHandler.CloseAfterFaultTimeout); 438ChannelHandler.Register(this.channelHandler); 739public ChannelHandler ChannelHandler 831ChannelHandler handler; 833public MessageRpcInvokeNotification(ServiceModelActivity activity, ChannelHandler handler) 845ChannelHandler.Register(this.handler); 854ChannelHandler.Register(this.handler, request);

System\ServiceModel\Dispatcher\ReceiveContextRPCFacet.cs (6)

100public IAsyncResult BeginComplete(TimeSpan timeout, Transaction transaction, ChannelHandler channelHandler, AsyncCallback callback, object state) 189ChannelHandler channelHandler; 305ChannelHandler channelHandler; 307public TransactionOutcomeListener(ReceiveContext receiveContext, Transaction transaction, ChannelHandler handler) 314public static void EnsureReceiveContextAbandonOnTransactionRollback(ReceiveContext receiveContext, Transaction transaction, ChannelHandler channelHandler) 375public ChannelHandler ChannelHandler

System\ServiceModel\Dispatcher\ServiceThrottle.cs (10)

259bool PrivateAcquireCall(ChannelHandler channel) 282bool PrivateAcquireDynamic(ChannelHandler channel) 287bool PrivateAcquireInstanceContext(ChannelHandler channel) 300internal bool AcquireCall(ChannelHandler channel) 308internal bool AcquireInstanceContextAndDynamic(ChannelHandler channel, bool acquireInstanceContextThrottle) 342ChannelHandler channel = (ChannelHandler)state; 352((ChannelHandler)state).ThrottleAcquired(); 357ChannelHandler channel = (ChannelHandler)state;

System\ServiceModel\Dispatcher\TransactedBatchContext.cs (4)

176ChannelHandler handler; 178internal SharedTransactedBatchContext(ChannelHandler handler, ChannelDispatcher dispatcher, int maxConcurrentBatches) 212ChannelHandler newHandler = new ChannelHandler(this.handler, context); 213ChannelHandler.Register(newHandler);