Home
last modified time | relevance | path

Searched refs:dequeuedCallback (Results 1 – 11 of 11) sorted by relevance

/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel/System/ServiceModel/Channels/
H A DSingletonChannelAcceptor.cs91 public void Enqueue(QueueItemType item, Action dequeuedCallback) in Enqueue() argument
93 Enqueue(item, dequeuedCallback, true); in Enqueue()
116 public void Enqueue(Exception exception, Action dequeuedCallback) in Enqueue() argument
118 Enqueue(exception, dequeuedCallback, true); in Enqueue()
146 return channel.EnqueueWithoutDispatch(item, dequeuedCallback); in EnqueueWithoutDispatch()
150 InvokeDequeuedCallback(dequeuedCallback, false); in EnqueueWithoutDispatch()
166 InvokeDequeuedCallback(dequeuedCallback, false); in EnqueueWithoutDispatch()
219 if (dequeuedCallback != null) in InvokeDequeuedCallback()
223 dequeuedCallback(); in InvokeDequeuedCallback()
240 Action dequeuedCallback = (Action)state; in OnInvokeDequeuedCallback()
[all …]
H A DInputQueueChannelAcceptor.cs53 public void EnqueueAndDispatch(TChannel channel, Action dequeuedCallback) in EnqueueAndDispatch() argument
55 this.channelQueue.EnqueueAndDispatch(channel, dequeuedCallback); in EnqueueAndDispatch()
58 public bool EnqueueWithoutDispatch(TChannel channel, Action dequeuedCallback) in EnqueueWithoutDispatch() argument
60 return this.channelQueue.EnqueueWithoutDispatch(channel, dequeuedCallback); in EnqueueWithoutDispatch()
63 public virtual bool EnqueueWithoutDispatch(Exception exception, Action dequeuedCallback) in EnqueueWithoutDispatch() argument
65 return this.channelQueue.EnqueueWithoutDispatch(exception, dequeuedCallback); in EnqueueWithoutDispatch()
68 …public void EnqueueAndDispatch(TChannel channel, Action dequeuedCallback, bool canDispatchOnThisTh… in EnqueueAndDispatch() argument
70 … this.channelQueue.EnqueueAndDispatch(channel, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
73 …public virtual void EnqueueAndDispatch(Exception exception, Action dequeuedCallback, bool canDispa… in EnqueueAndDispatch() argument
75 … this.channelQueue.EnqueueAndDispatch(exception, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
H A DInputQueueChannel.cs44 …public void EnqueueAndDispatch(TDisposable item, Action dequeuedCallback, bool canDispatchOnThisTh… in EnqueueAndDispatch() argument
49 inputQueue.EnqueueAndDispatch(item, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
52 …public void EnqueueAndDispatch(Exception exception, Action dequeuedCallback, bool canDispatchOnThi… in EnqueueAndDispatch() argument
55 inputQueue.EnqueueAndDispatch(exception, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
58 public void EnqueueAndDispatch(TDisposable item, Action dequeuedCallback) in EnqueueAndDispatch() argument
63 inputQueue.EnqueueAndDispatch(item, dequeuedCallback); in EnqueueAndDispatch()
66 public bool EnqueueWithoutDispatch(Exception exception, Action dequeuedCallback) in EnqueueWithoutDispatch() argument
69 return inputQueue.EnqueueWithoutDispatch(exception, dequeuedCallback); in EnqueueWithoutDispatch()
72 public bool EnqueueWithoutDispatch(TDisposable item, Action dequeuedCallback) in EnqueueWithoutDispatch() argument
77 return inputQueue.EnqueueWithoutDispatch(item, dequeuedCallback); in EnqueueWithoutDispatch()
H A DHttpPipeline.cs243 Action dequeuedCallback, in BeginProcessInboundRequest() argument
248 …return new EnqueueMessageAsyncResult(replyChannelAcceptor, dequeuedCallback, this, callback, state… in BeginProcessInboundRequest()
397 Action dequeuedCallback; field in System.ServiceModel.Channels.HttpPipeline.NormalHttpPipeline
508 this.dequeuedCallback = dequeuedCallback; in BeginProcessInboundRequest()
591 …his.isShortCutResponse && this.wasProcessInboundRequestSuccessful && this.dequeuedCallback != null) in OnClose()
593 this.dequeuedCallback.Invoke(); in OnClose()
682 …ult = new EnqueueMessageAsyncResult(this.replyChannelAcceptor, this.dequeuedCallback, this, onEnqu… in CreateMessageAndEnqueue()
872 Action dequeuedCallback; field in System.ServiceModel.Channels.HttpPipeline.EnqueueMessageAsyncResult
876 Action dequeuedCallback, in EnqueueMessageAsyncResult() argument
884 this.dequeuedCallback = dequeuedCallback; in EnqueueMessageAsyncResult()
[all …]
H A DChannelDemuxer.cs1146 … singletonListener.EnqueueAndDispatch(message, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
1152 … singletonListener.EnqueueAndDispatch(exception, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
1208 … singletonListener.EnqueueAndDispatch(message, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
1214 … singletonListener.EnqueueAndDispatch(exception, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
1481 … replyListener.EnqueueAndDispatch(request, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
1493 … inputListener.EnqueueAndDispatch(exception, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
1500 … replyListener.EnqueueAndDispatch(exception, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
1609 …public void EnqueueAndDispatch(TQueuedItem item, Action dequeuedCallback, bool canDispatchOnThisTh… in EnqueueAndDispatch() argument
1611 … this.SingletonAcceptor.EnqueueAndDispatch(item, dequeuedCallback, canDispatchOnThisThread); in EnqueueAndDispatch()
1614 …public void EnqueueAndDispatch(Exception exception, Action dequeuedCallback, bool canDispatchOnThi… in EnqueueAndDispatch() argument
[all …]
H A DInitialServerConnectionReader.cs75 Action dequeuedCallback = this.connectionDequeuedCallback; in GetConnectionDequeuedCallback()
77 return dequeuedCallback; in GetConnectionDequeuedCallback()
H A DHttpChannelListener.cs807 …ttpPipeline, HttpResponseMessage httpResponseMessage, string subProtocol, Action dequeuedCallback); in CreateWebSocketChannelAndEnqueue() argument
920 …ine pipeline, HttpResponseMessage httpResponseMessage, string subProtocol, Action dequeuedCallback) in CreateWebSocketChannelAndEnqueue() argument
949 this.Acceptor.EnqueueAndDispatch((TChannel)(object)channel, dequeuedCallback, true); in CreateWebSocketChannelAndEnqueue()
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel.Internals/System/Runtime/
H A DInputQueue.cs546 if (dequeuedCallback != null) in InvokeDequeuedCallback()
548 dequeuedCallback(); in InvokeDequeuedCallback()
554 if (dequeuedCallback != null) in InvokeDequeuedCallbackLater()
574 Action dequeuedCallback = (Action)state; in OnInvokeDequeuedCallback()
575 dequeuedCallback(); in OnInvokeDequeuedCallback()
748 Action dequeuedCallback; field
752 public Item(T value, Action dequeuedCallback) in Item()
753 : this(value, null, dequeuedCallback) in Item()
758 : this(null, exception, dequeuedCallback) in Item()
766 this.dequeuedCallback = dequeuedCallback; in Item()
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel.Channels/System/ServiceModel/Channels/
H A DUdpDuplexChannel.cs185 …internal override void FinishEnqueueMessage(Message message, Action dequeuedCallback, bool canDisp… in FinishEnqueueMessage() argument
194 this.EnqueueAndDispatch(message, dequeuedCallback, canDispatchOnThisThread); in FinishEnqueueMessage()
H A DUdpReplyChannel.cs150 …internal override void FinishEnqueueMessage(Message message, Action dequeuedCallback, bool canDisp… in FinishEnqueueMessage() argument
153 this.EnqueueAndDispatch(udpRequestContext, dequeuedCallback, canDispatchOnThisThread); in FinishEnqueueMessage()
H A DUdpChannelBase.cs294 …internal abstract void FinishEnqueueMessage(Message message, Action dequeuedCallback, bool canDisp… in FinishEnqueueMessage() argument