System\ServiceModel\Channels\ChannelDemuxer.cs (43)
130internal static void AbortMessage(RequestContext request)
1298class ReplyChannelDemuxer : DatagramChannelDemuxer<IReplyChannel, RequestContext>
1305protected override void AbortItem(RequestContext request)
1326SingletonChannelListener<IReplyChannel, ReplyChannel, RequestContext> listener = new SingletonChannelListener<IReplyChannel, ReplyChannel, RequestContext>(filter, this);
1344SingletonChannelListener<IReplyChannel, ReplyChannel, RequestContext> replyListener = listener as SingletonChannelListener<IReplyChannel, ReplyChannel, RequestContext>;
1360RequestContext item = (RequestContext)result.AsyncState;
1398protected override void EndpointNotFound(RequestContext request)
1449protected override RequestContext EndReceive(IAsyncResult result)
1454protected override void EnqueueAndDispatch(IChannelListener listener, RequestContext request, Action dequeuedCallback, bool canDispatchOnThisThread)
1478SingletonChannelListener<IReplyChannel, ReplyChannel, RequestContext> replyListener = listener as SingletonChannelListener<IReplyChannel, ReplyChannel, RequestContext>;
1497SingletonChannelListener<IReplyChannel, ReplyChannel, RequestContext> replyListener = listener as SingletonChannelListener<IReplyChannel, ReplyChannel, RequestContext>;
1507protected override Message GetMessage(RequestContext request)
2951class ReplySessionChannelDemuxer : SessionChannelDemuxer<IReplySessionChannel, RequestContext>
2958protected override void AbortItem(RequestContext request)
2974protected override IReplySessionChannel CreateChannel(ChannelManagerBase channelManager, IReplySessionChannel innerChannel, RequestContext firstRequest)
3023protected override void EndpointNotFound(IReplySessionChannel channel, RequestContext request)
3075protected override RequestContext EndReceive(IReplySessionChannel channel, IAsyncResult result)
3080protected override Message GetMessage(RequestContext request)
3088public RequestContext request;
3090public ChannelAndRequestAsyncState(IChannel channel, RequestContext request)
3100public ReplySessionChannelWrapper(ChannelManagerBase channelManager, IReplySessionChannel innerChannel, RequestContext firstRequest)
3321class ReplyChannelWrapper : ChannelWrapper<IReplyChannel, RequestContext>, IReplyChannel
3323public ReplyChannelWrapper(ChannelManagerBase channelManager, IReplyChannel innerChannel, RequestContext firstRequest)
3349RequestContext request = this.GetFirstItem();
3372public RequestContext ReceiveRequest()
3374RequestContext request = this.GetFirstItem();
3380public RequestContext ReceiveRequest(TimeSpan timeout)
3382RequestContext request = this.GetFirstItem();
3390RequestContext request = this.GetFirstItem();
3398RequestContext request = this.GetFirstItem();
3404public RequestContext EndReceiveRequest(IAsyncResult result)
3411public bool TryReceiveRequest(TimeSpan timeout, out RequestContext request)
3421RequestContext request = this.GetFirstItem();
3427public bool EndTryReceiveRequest(IAsyncResult result, out RequestContext request)
3730RequestContext requestContext;
3732public ReplyChannelDemuxFailureAsyncResult(IChannelDemuxFailureHandler demuxFailureHandler, RequestContext requestContext, AsyncCallback callback, object state)
3805public ReplySessionDemuxFailureAsyncResult(IChannelDemuxFailureHandler demuxFailureHandler, RequestContext requestContext, IReplySessionChannel channel, AsyncCallback callback, object state)
3959IAsyncResult BeginHandleDemuxFailure(Message message, RequestContext faultContext, AsyncCallback callback, object state);
System\ServiceModel\Channels\ChannelReliableSession.cs (9)
28RequestContext replyFaultContext;
246public void OnLocalFault(Exception e, WsrmFault fault, RequestContext context)
253public void OnLocalFault(Exception e, Message faultMessage, RequestContext context)
391public bool ProcessInfo(WsrmMessageInfo info, RequestContext context)
396public bool ProcessInfo(WsrmMessageInfo info, RequestContext context, bool throwException)
508public bool VerifyDuplexProtocolElements(WsrmMessageInfo info, RequestContext context)
513public bool VerifyDuplexProtocolElements(WsrmMessageInfo info, RequestContext context, bool throwException)
588public bool VerifySimplexProtocolElements(WsrmMessageInfo info, RequestContext context)
593public bool VerifySimplexProtocolElements(WsrmMessageInfo info, RequestContext context, bool throwException)
System\ServiceModel\Channels\ReliableChannelListener.cs (14)
1322: ReliableListenerOverDatagram<TChannel, TReliableChannel, IReplyChannel, RequestContext>
1337protected override void DisposeItem(RequestContext item)
1343protected override void EndTryReceiveItem(IReplyChannel channel, IAsyncResult result, out RequestContext item)
1348protected override Message GetMessage(RequestContext item)
1353protected override void SendReply(Message reply, IReplyChannel channel, RequestContext item)
1614: ReliableListenerOverSession<TChannel, TReliableChannel, IReplySessionChannel, IInputSession, RequestContext>
1629protected override void DisposeItem(RequestContext item)
1635protected override void EndTryReceiveItem(IReplySessionChannel channel, IAsyncResult result, out RequestContext item)
1640protected override Message GetMessage(RequestContext item)
1645protected override void SendReply(Message reply, IReplySessionChannel channel, RequestContext item)
1802protected override void ProcessSequencedItem(ReliableInputSessionChannelOverReply reliableChannel, RequestContext context, WsrmMessageInfo info)
1828protected override void ProcessSequencedItem(ReliableReplySessionChannel reliableChannel, RequestContext context, WsrmMessageInfo info)
1855protected override void ProcessSequencedItem(IReplySessionChannel channel, RequestContext context, ReliableInputSessionChannelOverReply reliableChannel, WsrmMessageInfo info, bool newChannel)
1894protected override void ProcessSequencedItem(IReplySessionChannel channel, RequestContext context, ReliableReplySessionChannel reliableChannel, WsrmMessageInfo info, bool newChannel)
System\ServiceModel\Channels\ReliableReplySessionChannel.cs (22)
28DeliveryStrategy<RequestContext> deliveryStrategy;
58this.deliveryStrategy = new OrderedDeliveryStrategy<RequestContext>(this, this.listener.MaxTransferWindowSize, true);
60this.deliveryStrategy = new UnorderedDeliveryStrategy<RequestContext>(this, this.listener.MaxTransferWindowSize);
376RequestContext context;
686void ProcessAckRequested(RequestContext context)
702void ProcessShutdown11(RequestContext context, WsrmMessageInfo info)
875public void ProcessDemuxedRequest(RequestContext context, WsrmMessageInfo info)
891void ProcessRequest(RequestContext context, WsrmMessageInfo info)
1031void ProcessSequencedMessage(RequestContext context, string action, WsrmSequencedMessageInfo info)
1174void ProcessTerminateSequenceFeb2005(RequestContext context, WsrmMessageInfo info)
1348List<RequestContext> innerContexts = new List<RequestContext>();
1355public ReliableRequestContext(RequestContext context, Int64 requestSequenceNumber, ReliableReplySessionChannel channel, bool outcome)
1365public bool CheckForReplyOrAddInnerContext(RequestContext innerContext)
1597public void SendReply(RequestContext context, MaskingMode maskingMode)
1603void SendReply(RequestContext context, MaskingMode maskingMode, ref TimeoutHelper timeoutHelper)
1669RequestContext thisInnerContext = this.context.innerContexts[this.currentContext];
1727RequestContext thisInnerContext = this.context.innerContexts[this.currentContext];
1749RequestContext requestContext;
1794internal void Reply(RequestContext context, WsrmMessageInfo info, TimeSpan timeout, MaskingMode maskingMode)
1858internal bool TransferRequestContext(RequestContext requestContext, WsrmMessageInfo info)
1860RequestContext oldContext = null;
System\ServiceModel\Channels\SecurityChannelListener.cs (25)
1218public RequestContext ReceiveRequest()
1223public RequestContext ReceiveRequest(TimeSpan timeout)
1238public RequestContext EndReceiveRequest(IAsyncResult result)
1253public bool EndTryReceiveRequest(IAsyncResult result, out RequestContext requestContext)
1264internal RequestContext ProcessReceivedRequest(RequestContext requestContext, TimeSpan timeout)
1279void SendFaultIfRequired(Exception e, RequestContext innerContext, TimeSpan timeout)
1318public bool TryReceiveRequest(TimeSpan timeout, out RequestContext requestContext)
1327RequestContext innerContext;
1396readonly RequestContext innerContext;
1400public SecurityRequestContext(Message requestMessage, RequestContext innerContext,
1455sealed class RequestContextSendAsyncResult : ApplySecurityAndSendAsyncResult<RequestContext>
1457public RequestContextSendAsyncResult(Message message, SecurityProtocol protocol, RequestContext context, TimeSpan timeout,
1464protected override IAsyncResult BeginSendCore(RequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state)
1475protected override void EndSendCore(RequestContext context, IAsyncResult result)
1784sealed class ReceiveRequestAndVerifySecurityAsyncResult : ReceiveItemAndVerifySecurityAsyncResult<RequestContext, IReplyChannel>
1818protected override void AbortInnerItem(RequestContext innerItem)
1823protected override void CloseInnerItem(RequestContext innerItem, TimeSpan timeout)
1833protected override bool EndTryReceiveItem(IAsyncResult result, out RequestContext innerItem)
1838protected override RequestContext ProcessInnerItem(RequestContext innerItem, TimeSpan timeout)
1843protected override Message CreateFaultMessage(MessageFault fault, RequestContext innerItem)
1852protected override IAsyncResult BeginSendFault(RequestContext innerItem, Message faultMessage, TimeSpan timeout, AsyncCallback callback, object state)
1857protected override void EndSendFault(RequestContext innerItem, IAsyncResult result)
1862public static bool End(IAsyncResult result, out RequestContext requestContext)
System\ServiceModel\Dispatcher\ChannelHandler.cs (34)
61RequestContext replied;
62RequestContext requestWaitingForThrottle;
293internal static void Register(ChannelHandler handler, RequestContext request)
334RequestContext request;
383bool DispatchAndReleasePump(RequestContext request, bool cleanThread, OperationContext currentOperationContext)
514RequestContext GetSessionOpenNotificationRequestContext()
524bool EndTryReceive(IAsyncResult result, out RequestContext requestContext)
548void EnsureChannelAndEndpoint(RequestContext request)
792bool HandleError(Exception e, RequestContext request, ServiceChannel channel)
808bool HandleErrorContinuation(Exception e, RequestContext request, ServiceChannel channel, ref ErrorHandlerFaultInfo faultInfo, bool replied)
894void HandleReceiveComplete(RequestContext context)
940bool HandleRequest(RequestContext request, OperationContext currentOperationContext)
1018bool HandleRequestAsReply(RequestContext request)
1131bool TryReceive(TimeSpan timeout, out RequestContext requestContext)
1155void ReplyAddressFilterDidNotMatch(RequestContext request)
1164void ReplyContractFilterDidNotMatch(RequestContext request)
1186void ReplyChannelTerminated(RequestContext request)
1196void ReplyFailure(RequestContext request, FaultCode code, string reason)
1202void ReplyFailure(RequestContext request, FaultCode code, string reason, string action)
1208void ReplyFailure(RequestContext request, Message fault, string action, string reason, FaultCode code)
1219void ProvideFaultAndReplyFailure(RequestContext request, Exception exception, ref ErrorHandlerFaultInfo faultInfo, out bool replied, out bool replySentAsync)
1309bool PrepareReply(RequestContext request, Message reply)
1463RequestContext request;
1531RequestContext request;
1625RequestContext request;
1712bool TryTransactionalReceive(Transaction tx, out RequestContext request)
1777RequestContext request = this.requestWaitingForThrottle;
1814bool TryRetrievingInstanceContext(RequestContext request)
1849bool TryRetrievingInstanceContextCore(RequestContext request)
1931RequestContext request = this.requestWaitingForThrottle;
1950bool TryAcquireThrottle(RequestContext request, bool acquireInstanceContextThrottle)
1978bool TryAcquireCallThrottle(RequestContext request)
2018public RequestContext RequestContext;
2079public RequestContext Request;
System\ServiceModel\Security\SecuritySessionServerSettings.cs (51)
1011RequestContext requestContext;
1149RequestContext initialRequestContext;
1328protected abstract void OnCloseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout);
1330protected abstract void OnCloseResponseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout);
1388bool CheckIncomingToken(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout)
1450public void StartReceiving(RequestContext initialRequestContext)
1460public RequestContext ReceiveRequest()
1465public RequestContext ReceiveRequest(TimeSpan timeout)
1467RequestContext requestContext;
1488public RequestContext EndReceiveRequest(IAsyncResult result)
1490RequestContext requestContext;
1506public bool EndTryReceiveRequest(IAsyncResult result, out RequestContext requestContext)
1511public bool TryReceiveRequest(TimeSpan timeout, out RequestContext requestContext)
1537RequestContext innerRequestContext;
1643RequestContext requestContext;
1688void SendFaultIfRequired(Exception e, Message unverifiedMessage, RequestContext requestContext, TimeSpan timeout)
1739Message ProcessRequestContext(RequestContext requestContext, TimeSpan timeout, out SecurityProtocolCorrelationState correlationState, out bool isSecurityProcessingFailure)
1886void SendRenewFault(RequestContext requestContext, SecurityProtocolCorrelationState correlationState, TimeSpan timeout)
1998protected void SendCloseResponse(RequestContext requestContext, Message closeResponse, TimeSpan timeout)
2020internal IAsyncResult BeginSendCloseResponse(RequestContext requestContext, Message closeResponse, TimeSpan timeout, AsyncCallback callback, object state)
2154protected void SendMessage(RequestContext requestContext, Message message, TimeSpan timeout)
2168internal IAsyncResult BeginSendMessage(RequestContext requestContext, Message response, TimeSpan timeout, AsyncCallback callback, object state)
2183RequestContext requestContext;
2186public SendMessageAsyncResult(ServerSecuritySessionChannel sessionChannel, RequestContext requestContext, Message message, TimeSpan timeout, AsyncCallback callback,
2551RequestContext innerRequestContext;
2786public static bool EndAsRequestContext(IAsyncResult result, out RequestContext requestContext)
2839RequestContext closeRequestContext;
2912bool ShouldSendCloseResponseOnClose(out RequestContext pendingCloseRequestContext, out Message pendingCloseResponse)
2940RequestContext pendingCloseRequestContext;
3008RequestContext pendingCloseRequestContext;
3050protected override void OnCloseResponseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout)
3058protected override void OnCloseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout)
3072bool SendCloseResponseOnCloseReceivedIfRequired(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout)
3136RequestContext closeRequestContext;
3139public CloseAsyncResult(ServerSecuritySimplexSessionChannel sessionChannel, bool sendCloseResponse, RequestContext closeRequestContext, Message closeResponse, TimeSpan timeout, AsyncCallback callback, object state)
3531RequestContext requestContext;
3535public SecuritySessionRequestContext(RequestContext requestContext, Message requestMessage, SecurityProtocolCorrelationState correlationState, ServerSecuritySessionChannel channel)
3586RequestContext closeRequestContext;
3838protected override void OnCloseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout)
3889protected override void OnCloseResponseMessageReceived(RequestContext requestContext, Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout)
3928void DetermineCloseOutputSessionMessage(out bool sendClose, out bool sendCloseResponse, out Message pendingCloseResponseMessage, out RequestContext pendingCloseRequestContext)
3965RequestContext pendingCloseRequestContext;
4038RequestContext closeRequestContext;
4725public IAsyncResult BeginHandleDemuxFailure(Message message, RequestContext faultContext, AsyncCallback callback, object state)
4727return BeginHandleDemuxFailure<RequestContext>(message, faultContext, callback, state);
4737if (result is SendFaultAsyncResult<RequestContext>)
4739SendFaultAsyncResult<RequestContext>.End(result);
4777if (faultContext is RequestContext)
4779result = ((RequestContext)(object)faultContext).BeginReply(message, sendCallback, this);
4801if (faultContext is RequestContext)
4803((RequestContext)(object)faultContext).EndReply(result);