ChannelHandler

FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\ChannelHandler.cs (23)

31private static AsyncCallback s_onAsyncReplyComplete = Fx.ThunkCallback(new AsyncCallback(ChannelHandler.OnAsyncReplyComplete)); 32private static AsyncCallback s_onAsyncReceiveComplete = Fx.ThunkCallback(new AsyncCallback(ChannelHandler.OnAsyncReceiveComplete)); 33private static Action<object> s_onContinueAsyncReceive = new Action<object>(ChannelHandler.OnContinueAsyncReceive); 34private static Action<object> s_onStartSyncMessagePump = new Action<object>(ChannelHandler.OnStartSyncMessagePump); 35private static Action<object> s_onStartAsyncMessagePump = new Action<object>(ChannelHandler.OnStartAsyncMessagePump); 36private static Action<object> s_openAndEnsurePump = new Action<object>(ChannelHandler.OpenAndEnsurePump); 156internal static void Register(ChannelHandler handler) 161internal static void Register(ChannelHandler handler, RequestContext request) 242return _receiver.BeginTryReceive(TimeSpan.MaxValue, ChannelHandler.s_onAsyncReceiveComplete, this); 402ActionItem.Schedule(ChannelHandler.s_onStartSyncMessagePump, this); 409ActionItem.Schedule(ChannelHandler.s_onContinueAsyncReceive, result); 734((ChannelHandler)state).AsyncMessagePump(); 739ChannelHandler handler = state as ChannelHandler; 752((ChannelHandler)result.AsyncState).AsyncMessagePump(result); 759((ChannelHandler)result.AsyncState).AsyncMessagePump(result); 764((ChannelHandler)state).OpenAndEnsurePump(); 920var result = request.BeginReply(reply, ChannelHandler.s_onAsyncReplyComplete, state); 923ChannelHandler.AsyncReplyComplete(result, state); 1083ChannelHandler.AsyncReplyComplete(result, state); 1249public ChannelHandler ChannelHandler; 1251public RequestInfo(ChannelHandler channelHandler) 1292public ChannelHandler ChannelHandler;

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

392serviceChannel.Close(ChannelHandler.CloseAfterFaultTimeout);

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

29private ChannelHandler _channelHandler; 69internal ChannelHandler ChannelHandler 298ChannelHandler.Register(this.ChannelHandler);

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

288ChannelHandler handler = new ChannelHandler(_listenerBinder.MessageVersion, channel.Binder, this, idleManager); 307ChannelHandler.Register(handler);

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

22internal readonly ChannelHandler channelHandler; 66ServiceChannel channel, ChannelHandler channelHandler, bool cleanThread, 253this.Channel.Close(ChannelHandler.CloseAfterFaultTimeout); 289ChannelHandler.Register(this.channelHandler); 524public ChannelHandler ChannelHandler 614private ChannelHandler _handler; 616public MessageRpcInvokeNotification(ServiceModelActivity activity, ChannelHandler handler) 628ChannelHandler.Register(_handler); 637ChannelHandler.Register(_handler, request);