System\ServiceModel\Channels\BinaryMessageEncoder.cs (11)
506public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType)
543Message message;
572public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType)
593Message message = Message.CreateMessage(reader, maxSizeOfHeaders, _factory._messageVersion);
609public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
723public override void WriteMessage(Message message, Stream stream)
807public void AddCompressedMessageProperties(Message message, string supportedCompressionTypes)
857private CompressionFormat CheckCompressedWrite(Message message)
1302public Message TryCreateMessage(byte[] buffer, int offset, int size, BufferManager bufferManager, BufferedMessageData messageData)
1773public override Message CreateMessage()
System\ServiceModel\Channels\ClientReliableChannelBinder.cs (17)
130protected virtual Task<Message> OnRequestAsync(TChannel channel, Message message, TimeSpan timeout,
136public Task<Message> RequestAsync(Message message, TimeSpan timeout)
141public async Task<Message> RequestAsync(Message message, TimeSpan timeout, MaskingMode maskingMode)
272protected override Task OnSendAsync(TDuplexChannel channel, Message message,
288Message message;
295(success, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(channel.BeginTryReceive, channel.EndTryReceive, timeout, null);
384private InputQueue<Message> _inputMessages;
394protected void EnqueueMessageIfNotNull(Message message)
402private InputQueue<Message> GetInputMessages()
418_inputMessages = TraceUtility.CreateInputQueue<Message>();
449protected override Task<Message> OnRequestAsync(TRequestChannel channel, Message message,
462protected override async Task OnSendAsync(TRequestChannel channel, Message message,
479(bool success, Message message) = await GetInputMessages().TryDequeueAsync(timeout);
System\ServiceModel\Channels\ClientReliableDuplexSessionChannel.cs (16)
19private DeliveryStrategy<Message> _deliveryStrategy;
58private void AddPendingAcknowledgements(Message message)
96private Message CreateAcknowledgmentMessage()
103Message message = WsrmUtilities.CreateAcknowledgmentMessage(Settings.MessageVersion,
267Message message = null;
664using (Message message = CreateAcknowledgmentMessage())
707ReliableSession.OnLocalFault(exception, (Message)null, null);
824protected override async Task OnSendAsync(Message message, TimeSpan timeout)
879using (Message message = WsrmUtilities.CreateAckRequestedMessage(Settings.MessageVersion,
904_deliveryStrategy = new OrderedDeliveryStrategy<Message>(this, Settings.MaxTransferWindowSize, false);
906_deliveryStrategy = new UnorderedDeliveryStrategy<Message>(this, Settings.MaxTransferWindowSize);
950ReliableSession.OnLocalFault(e, (Message)null, null);
956Message message = context.RequestMessage;
992Message message = WsrmUtilities.CreateTerminateMessage(Settings.MessageVersion,
1205using (Message message = WsrmUtilities.CreateAckRequestedMessage(Settings.MessageVersion,
1229Message message = WsrmUtilities.CreateAckRequestedMessage(Settings.MessageVersion,
System\ServiceModel\Channels\CreateSequence.cs (5)
78Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
99Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
139Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
154Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
163Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
System\ServiceModel\Channels\DuplexChannel.cs (19)
10internal abstract class DuplexChannel : InputQueueChannel<Message>, IDuplexChannel, IAsyncDuplexChannel
21public Task SendAsync(Message message)
26public Task SendAsync(Message message, TimeSpan timeout)
41public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
46public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
72protected abstract Task OnSendAsync(Message message, TimeSpan timeout);
74public void Send(Message message)
79public void Send(Message message, TimeSpan timeout)
84protected virtual void AddHeadersTo(Message message)
88public Task<Message> ReceiveAsync()
93public Task<Message> ReceiveAsync(TimeSpan timeout)
103public Message Receive()
108public Message Receive(TimeSpan timeout)
123public Message EndReceive(IAsyncResult result)
125return result.ToApmEnd<Message>();
128public Task<(bool, Message)> TryReceiveAsync(TimeSpan timeout)
138public bool TryReceive(TimeSpan timeout, out Message message)
150public bool EndTryReceive(IAsyncResult result, out Message message)
153(success, message) = result.ToApmEnd<(bool, Message)>();
System\ServiceModel\Channels\LayeredChannelFactory.cs (22)
100private Task InternalOnReceiveAsync(Message message)
110protected virtual Task OnReceiveAsync(Message message)
115public Message Receive()
120public async Task<Message> ReceiveAsync(TimeSpan timeout)
122Message message;
136public async Task<Message> ReceiveAsync()
138Message message;
152public Message Receive(TimeSpan timeout)
167public Message EndReceive(IAsyncResult result)
169return result.ToApmEnd<Message>();
177public bool EndTryReceive(IAsyncResult result, out Message message)
180(retVal, message) = result.ToApmEnd<(bool, Message)>();
184public async Task<(bool, Message)> TryReceiveAsync(TimeSpan timeout)
187Message message;
194(retVal, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(InnerChannel.BeginTryReceive, InnerChannel.EndTryReceive, timeout, null);
201public bool TryReceive(TimeSpan timeout, out Message message)
309public Task SendAsync(Message message)
314public Task SendAsync(Message message, TimeSpan timeout)
326public void Send(Message message)
331public void Send(Message message, TimeSpan timeout)
336public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
341public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Channels\Message.cs (21)
116static public Message CreateMessage(MessageVersion version, string action, object body)
121static public Message CreateMessage(MessageVersion version, string action, object body, XmlObjectSerializer serializer)
136static public Message CreateMessage(MessageVersion version, string action, XmlReader body)
141static public Message CreateMessage(MessageVersion version, string action, XmlDictionaryReader body)
156static public Message CreateMessage(MessageVersion version, string action, BodyWriter body)
171static internal Message CreateMessage(MessageVersion version, ActionHeader actionHeader, BodyWriter body)
186static public Message CreateMessage(MessageVersion version, string action)
196static internal Message CreateMessage(MessageVersion version, ActionHeader actionHeader)
206static public Message CreateMessage(XmlReader envelopeReader, int maxSizeOfHeaders, MessageVersion version)
211static public Message CreateMessage(XmlDictionaryReader envelopeReader, int maxSizeOfHeaders, MessageVersion version)
223Message message = new StreamedMessage(envelopeReader, maxSizeOfHeaders, version);
227static public Message CreateMessage(MessageVersion version, FaultCode faultCode, string reason, string action)
247static public Message CreateMessage(MessageVersion version, FaultCode faultCode, string reason, object detail, string action)
267static public Message CreateMessage(MessageVersion version, MessageFault fault, string action)
377internal void InitializeReply(Message request)
618Message.ReadFromBodyContentsToEnd(reader, Version.Envelope);
658Message.ReadFromBodyContentsToEnd(reader, envelopeVersion);
875private Message _message;
878public OnWriteMessageAsyncResult(XmlDictionaryWriter writer, Message message, AsyncCallback callback, object state)
991_isFault = Message.IsFaultStartElement(reader, version);
1279return Message.ReadStartBody(reader, Version.Envelope, out _isFault, out _isEmpty);
System\ServiceModel\Channels\MessageEncoder.cs (17)
35public Message ReadMessage(Stream stream, int maxSizeOfHeaders)
40public virtual ValueTask<Message> ReadMessageAsync(Stream stream, int maxSizeOfHeaders, string contentType)
42return new ValueTask<Message>(ReadMessage(stream, maxSizeOfHeaders, contentType));
45public virtual ValueTask<Message> ReadMessageAsync(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType)
47return new ValueTask<Message>(ReadMessage(buffer, bufferManager, contentType));
50public abstract Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType);
52public Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager)
54Message message = ReadMessage(buffer, bufferManager, null);
58public abstract Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType);
96internal virtual async Task<Message> ReadMessageAsync(Stream stream, BufferManager bufferManager, int maxBufferSize, string contentType, CancellationToken cancellationToken)
106public abstract void WriteMessage(Message message, Stream stream);
108public virtual IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state)
118public ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager)
123public abstract ArraySegment<byte> WriteMessage(Message message, int maxMessageSize,
126public virtual ValueTask WriteMessageAsync(Message message, Stream stream)
132public virtual ValueTask<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize,
240internal void ThrowIfMismatchedMessageVersion(Message message)
System\ServiceModel\Channels\MtomMessageEncoder.cs (12)
362public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType)
381Message message = new BufferedMessage(messageData, messageState);
397public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType)
411Message message = Message.CreateMessage(reader, maxSizeOfHeaders, _version);
424public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
429public override ValueTask<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
449private ArraySegment<byte> WriteMessageInternal(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset, string startInfo, string boundary, string startUri)
508public override void WriteMessage(Message message, Stream stream)
524public override ValueTask WriteMessageAsync(Message message, Stream stream)
529public override IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state)
539private async ValueTask WriteMessageInternalAsync(Message message, Stream stream, string startInfo, string boundary, string startUri)
System\ServiceModel\Channels\ReliableChannelBinder.cs (16)
169protected virtual void AddOutputHeaders(Message message)
544protected virtual Task OnSendAsync(TChannel channel, Message message, TimeSpan timeout)
601public Task SendAsync(Message message, TimeSpan timeout)
606public async Task SendAsync(Message message, TimeSpan timeout, MaskingMode maskingMode)
807protected bool ValidateOutputOperation(Message message, TimeSpan timeout, MaskingMode maskingMode)
828protected RequestContext WrapMessage(Message message)
857public BinderRequestContext(ReliableChannelBinder<TChannel> binder, Message message)
1876public MessageRequestContext(ReliableChannelBinder<TChannel> binder, Message message)
1889protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1903protected override void OnReply(Message message, TimeSpan timeout)
1917RequestContext innerContext, Message message)
1933protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout,
1967private async Task OnReplyAsync(Message message, TimeSpan timeout)
1995protected override void OnReply(Message message, TimeSpan timeout)
2017Message message = null;
2029(success, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(channel.BeginTryReceive, channel.EndTryReceive, timeout, null);
System\ServiceModel\Channels\ReliableMessagingHelpers.cs (62)
443public static bool AddressReply(Message message, Message faultMessage)
472public abstract Task SendFaultAsync(IReliableChannelBinder binder, RequestContext requestContext, Message faultMessage);
584protected abstract TState GetState(RequestContext requestContext, Message faultMessage);
627public override async Task SendFaultAsync(IReliableChannelBinder binder, RequestContext requestContext, Message faultMessage)
666public FaultState(RequestContext requestContext, Message faultMessage)
672public Message FaultMessage { get; }
701protected override FaultState GetState(RequestContext requestContext, Message faultMessage)
708internal class SendFaultHelper : TypedFaultHelper<Message>
715protected override void AbortState(Message message, bool isOnAbortThread)
724protected override async Task SendFaultAsync(IReliableChannelBinder binder, Message message, TimeSpan timeout)
730protected override Message GetState(RequestContext requestContext, Message faultMessage)
809private Message CreateRequestMessage()
811Message request = Message.CreateMessage(messageVersion, messageAction, messageBody);
912protected abstract Task<Message> OnRequestAsync(Message request, TimeSpan timeout, bool last);
914public async Task<Message> RequestAsync(TimeSpan timeout)
923Message request = null;
924Message reply = null;
985private bool ValidateReply(Message response)
1020private Message GetReply(Message reply, bool last)
1042protected override async Task<Message> OnRequestAsync(Message request, TimeSpan timeout, bool last)
1085protected override async Task<Message> OnRequestAsync(Message request, TimeSpan timeout, bool last)
1127private Message GetReply(bool last)
1157protected override async Task<Message> OnRequestAsync(Message request, TimeSpan timeout, bool last)
1673Message message, UniqueId id, SequenceRangeCollection ranges, bool final)
1679Message message, UniqueId id, SequenceRangeCollection ranges, bool final, int bufferRemaining)
1685internal static void AddAckRequestedHeader(ReliableMessagingVersion reliableMessagingVersion, Message message,
1691internal static void AddSequenceHeader(ReliableMessagingVersion reliableMessagingVersion, Message message,
1706internal static Message CreateAcknowledgmentMessage(MessageVersion version,
1710Message message = Message.CreateMessage(version,
1720internal static Message CreateAckRequestedMessage(MessageVersion messageVersion,
1723Message message = Message.CreateMessage(messageVersion,
1732internal static Message CreateCloseSequenceResponse(MessageVersion messageVersion, UniqueId messageId,
1737Message message = Message.CreateMessage(messageVersion,
1744internal static Message CreateCreateSequenceResponse(MessageVersion messageVersion,
1756Message responseMessage
1757= Message.CreateMessage(messageVersion, ActionHeader.Create(
1763internal static Message CreateCSRefusedCommunicationFault(MessageVersion messageVersion,
1769internal static Message CreateCSRefusedProtocolFault(MessageVersion messageVersion,
1775internal static Message CreateCSRefusedServerTooBusyFault(MessageVersion messageVersion,
1785private static Message CreateCSRefusedFault(MessageVersion messageVersion,
1813return Message.CreateMessage(messageVersion, fault, action);
1817ReliableMessagingVersion reliableMessagingVersion, Message message, IChannel innerChannel)
1884internal static Message CreateEndpointNotFoundFault(MessageVersion version, string reason)
1904return Message.CreateMessage(version, fault, version.Addressing.DefaultFaultAction);
1907internal static Message CreateTerminateMessage(MessageVersion version,
1913internal static Message CreateTerminateMessage(MessageVersion version,
1916Message message = Message.CreateMessage(version,
1925internal static Message CreateTerminateResponseMessage(MessageVersion version, UniqueId messageId, UniqueId sequenceId)
1927Message message = Message.CreateMessage(version,
System\ServiceModel\Channels\ReliableOutputSessionChannel.cs (21)
100Message closeReply = await _closeRequestor.RequestAsync(timeout);
235_session.OnLocalFault(exception, (Message)null, null);
265protected abstract Task OnConnectionSendAsync(Message message, TimeSpan timeout, bool saveHandledException, bool maskUnhandledException);
270using (Message message = WsrmUtilities.CreateAckRequestedMessage(Settings.MessageVersion,
299protected abstract Task OnConnectionSendMessageAsync(Message message, TimeSpan timeout, MaskingMode maskingMode);
353protected override async Task OnSendAsync(Message message, TimeSpan timeout)
359protected override void OnSend(Message message, TimeSpan timeout)
378using (Message request = WsrmUtilities.CreateAckRequestedMessage(Settings.MessageVersion,
385private void ProcessCloseOrTerminateReply(bool close, Message reply)
428protected async Task ProcessMessageAsync(Message message)
503Message response = WsrmUtilities.CreateTerminateResponseMessage(
581Message message = WsrmUtilities.CreateTerminateMessage(Settings.MessageVersion,
588Message terminateReply = await _terminateRequestor.RequestAsync(timeout);
655protected override async Task OnConnectionSendAsync(Message message, TimeSpan timeout,
659Message reply = null;
694protected override async Task OnConnectionSendMessageAsync(Message message, TimeSpan timeout, MaskingMode maskingMode)
696Message reply = await binder.RequestAsync(message, timeout, maskingMode);
734protected override async Task OnConnectionSendAsync(Message message, TimeSpan timeout, bool saveHandledException, bool maskUnhandledException)
766protected override Task OnConnectionSendMessageAsync(Message message, TimeSpan timeout, MaskingMode maskingMode)
823Message requestMessage = context.RequestMessage;
833ReliableSession.OnLocalFault(e, (Message)null, null);
System\ServiceModel\Channels\ReliableRequestSessionChannel.cs (17)
66private void AddAcknowledgementHeader(Message message, bool force)
80Message closeReply = await closeRequestor.RequestAsync(timeout);
94private Message CreateAckRequestedMessage()
96Message request = WsrmUtilities.CreateAckRequestedMessage(settings.MessageVersion,
102protected override IAsyncRequest CreateAsyncRequest(Message message)
244session.OnLocalFault(exception, (Message)null, null);
293Message reply = null;
400var message = CreateAckRequestedMessage();
401var reply = await binder.RequestAsync(message, DefaultSendTimeout, MaskingMode.All);
408private void ProcessCloseOrTerminateReply(bool close, Message reply)
470private void ProcessReply(Message reply, IReliableRequest request, long requestSequenceNumber)
634Message terminateReply = await terminateRequestor.RequestAsync(timeout);
689void Set(Message reply);
700private Message _reply;
742public async Task SendRequestAsync(Message message, TimeoutHelper timeoutHelper)
749public void Set(Message reply)
768public async Task<Message> ReceiveReplyAsync(TimeoutHelper timeoutHelper)
System\ServiceModel\Channels\RequestContextBase.cs (11)
14private Message _requestMessage;
19protected RequestContextBase(Message requestMessage, TimeSpan defaultCloseTimeout, TimeSpan defaultSendTimeout)
26public void ReInitialize(Message requestMessage)
36public override Message RequestMessage
49protected void SetRequestMessage(Message requestMessage)
176protected abstract void OnReply(Message message, TimeSpan timeout);
177protected abstract IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state);
220public override IAsyncResult BeginReply(Message message, AsyncCallback callback, object state)
225public override IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
243public override void Reply(Message message)
248public override void Reply(Message message, TimeSpan timeout)
System\ServiceModel\Channels\SecurityChannelFactory.cs (40)
267protected bool TryGetSecurityFaultException(Message faultMessage, out Exception faultException)
342public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
347public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
357public Task SendAsync(Message message)
362public async Task SendAsync(Message message, TimeSpan timeout)
378public void Send(Message message)
383public void Send(Message message, TimeSpan timeout)
412public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state)
417public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
422public Message EndRequest(IAsyncResult result)
424return result.ToApmEnd<Message>();
427public Message Request(Message message)
432internal Message ProcessReply(Message reply, SecurityProtocolCorrelationState correlationState, TimeSpan timeout)
436Message unverifiedMessage = reply;
459public Task<Message> RequestAsync(Message message)
464public async Task<Message> RequestAsync(Message message, TimeSpan timeout)
471Message reply = await Task.Factory.FromAsync(InnerChannel.BeginRequest, InnerChannel.EndRequest, message, timeoutHelper.RemainingTime(), null);
476private async Task<Message> RequestAsyncInternal(Message message, TimeSpan timeout)
482public Message Request(Message message, TimeSpan timeout)
529public Task<Message> ReceiveAsync()
534public Task<Message> ReceiveAsync(TimeSpan timeout)
539public Message Receive()
544public Message Receive(TimeSpan timeout)
559public Message EndReceive(IAsyncResult result)
561return result.ToApmEnd<Message>();
569public virtual bool EndTryReceive(IAsyncResult result, out Message message)
572(success, message) = result.ToApmEnd<(bool, Message)>();
576internal Message ProcessMessage(Message message, TimeSpan timeout)
582Message unverifiedMessage = message;
607public async Task<(bool, Message)> TryReceiveAsync(TimeSpan timeout)
616Message message;
623(success, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(InnerDuplexChannel.BeginTryReceive, InnerDuplexChannel.EndTryReceive, timeout, null);
634public bool TryReceive(TimeSpan timeout, out Message message)
System\ServiceModel\Channels\ServiceChannel.cs (16)
871internal void FireUnknownMessageReceived(Message message)
1014private void ThrowIfFaultUnderstood(Message reply, MessageFault fault, string action, MessageVersion version, FaultConverter faultConverter)
1172private void AddMessageProperties(Message message, OperationContext context)
1201public void Send(Message message)
1206public void Send(Message message, TimeSpan timeout)
1212public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
1217public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1228public Message Request(Message message)
1233public Message Request(Message message, TimeSpan timeout)
1236return (Message)Call(message.Headers.Action, false, operation, new object[] { message }, Array.Empty<object>(), timeout);
1239public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state)
1244public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1250public Message EndRequest(IAsyncResult result)
1252return (Message)EndCall(MessageHeaders.WildcardAction, Array.Empty<object>(), result);
System\ServiceModel\Channels\ServiceChannelProxy.cs (11)
745IAsyncResult IOutputChannel.BeginSend(Message message, AsyncCallback callback, object state)
750IAsyncResult IOutputChannel.BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
760void IOutputChannel.Send(Message message)
765void IOutputChannel.Send(Message message, TimeSpan timeout)
770Message IRequestChannel.Request(Message message)
775Message IRequestChannel.Request(Message message, TimeSpan timeout)
780IAsyncResult IRequestChannel.BeginRequest(Message message, AsyncCallback callback, object state)
785IAsyncResult IRequestChannel.BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
790Message IRequestChannel.EndRequest(IAsyncResult result)
System\ServiceModel\Channels\TextMessageEncoder.cs (11)
401public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType)
413Message message;
444public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType)
457Message message = Message.CreateMessage(reader, maxSizeOfHeaders, _version);
473public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
486public override void WriteMessage(Message message, Stream stream)
491public override ValueTask<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
547private async Task WriteMessageAsyncInternal(Message message, Stream stream)
553public override async ValueTask WriteMessageAsync(Message message, Stream stream)
601public override IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state)
System\ServiceModel\Channels\TransmissionStrategy.cs (10)
20public MessageAttemptInfo(Message message, long sequenceNumber, int retryCount, object state)
27public Message Message { get; }
176public Task<(MessageAttemptInfo attemptInfo, bool success)> AddAsync(Message message, TimeSpan timeout, object state)
181public async Task<MessageAttemptInfo> AddLastAsync(Message message, TimeSpan timeout, object state)
193private MessageAttemptInfo AddToWindow(Message message, bool isLast, object state)
411private async Task<(MessageAttemptInfo attemptInfo, bool success)> InternalAddAsync(Message message, bool isLast, TimeSpan timeout, object state)
748public AsyncWaitQueueAdder(TransmissionStrategy strategy, Message message, bool isLast, object state)
860public void Add(Message message, long addTime, object state)
895public Message GetMessage(int index)
987public TransmissionInfo(Message message, long lastAttemptTime, object state)
System\ServiceModel\Channels\WsrmFault.cs (8)
124public Message CreateMessage(MessageVersion messageVersion, ReliableMessagingVersion reliableMessagingVersion)
149Message message = Message.CreateMessage(messageVersion, this, action);
177protected abstract void OnFaultMessageCreated(MessageVersion version, Message message);
218protected override void OnFaultMessageCreated(MessageVersion version, Message message)
376protected override void OnFaultMessageCreated(MessageVersion version, Message message)
402public static bool TryCreateFault11(ReliableMessagingVersion reliableMessagingVersion, Message message,
454public static bool TryCreateFault12(ReliableMessagingVersion reliableMessagingVersion, Message message,
System\ServiceModel\Channels\WsrmMessageInfo.cs (20)
17private Message _faultReply;
62public Message FaultReply
79public Message Message { get; private set; }
103public static Exception CreateInternalFaultException(Message faultReply, string message, Exception inner)
112Message faultReply = new WsrmRequiredFault(faultReason).CreateMessage(messageVersion,
120ReliableMessagingVersion reliableMessagingVersion, IChannel channel, ISession session, Message message)
126ReliableMessagingVersion reliableMessagingVersion, IChannel channel, ISession session, Message message,
561private static void ValidateMustUnderstand(MessageVersion version, Message message)
574private Message faultReply;
581public InternalFaultException(Message faultReply, string message, Exception inner)
594public Message FaultReply
618public static CloseSequenceInfo ReadMessage(MessageVersion messageVersion, Message message,
647public static CloseSequenceResponseInfo ReadMessage(MessageVersion messageVersion, Message message,
699Message message, MessageHeaders headers)
705Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
722Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
753Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion,
769ReliableMessagingVersion reliableMessagingVersion, Message message, MessageHeaders headers)
813ReliableMessagingVersion reliableMessagingVersion, Message message, MessageHeaders headers)
845public static TerminateSequenceResponseInfo ReadMessage(MessageVersion messageVersion, Message message,
System\ServiceModel\ClientBase.cs (11)
1148void IOutputChannel.Send(Message message)
1153void IOutputChannel.Send(Message message, TimeSpan timeout)
1158IAsyncResult IOutputChannel.BeginSend(Message message, AsyncCallback callback, object state)
1163IAsyncResult IOutputChannel.BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1183Message IRequestChannel.Request(Message message)
1188Message IRequestChannel.Request(Message message, TimeSpan timeout)
1193IAsyncResult IRequestChannel.BeginRequest(Message message, AsyncCallback callback, object state)
1198IAsyncResult IRequestChannel.BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1203Message IRequestChannel.EndRequest(IAsyncResult result)
System\ServiceModel\Diagnostics\TraceUtility.cs (18)
34static internal void AddActivityHeader(Message message)
50static internal void AddAmbientActivityToMessage(Message message)
66static internal void CopyActivity(Message source, Message destination)
74internal static void SetActivity(Message message, ServiceModelActivity activity)
92internal static ServiceModelActivity ExtractActivity(Message message)
129internal static ServiceModelActivity ExtractAndRemoveActivity(Message message)
142static internal void MessageFlowAtMessageSent(Message message, EventTraceActivity eventTraceActivity)
165static internal void MessageFlowAtMessageReceived(Message message, OperationContext context, EventTraceActivity eventTraceActivity, bool createNewActivityId)
202internal static void ProcessIncomingMessage(Message message, EventTraceActivity eventTraceActivity)
229internal static void ProcessOutgoingMessage(Message message, EventTraceActivity eventTraceActivity)
343internal static void TraceDroppedMessage(Message message, EndpointDispatcher dispatcher)
348internal static Exception ThrowHelperWarning(Exception exception, Message message)
425internal static Guid ExtractActivityId(Message message)
455internal static Exception ThrowHelperError(Exception exception, Message message)
466internal static ArgumentException ThrowHelperArgument(string paramName, string message, Message msg)
471internal static ArgumentNullException ThrowHelperArgumentNull(string paramName, Message message)
529internal static void TransferFromTransport(Message message)
System\ServiceModel\Dispatcher\ChannelHandler.cs (14)
249Message message = request.RequestMessage;
407private ServiceChannel GetDatagramChannel(Message message, out EndpointDispatcher endpoint, out bool addressMatched)
432private EndpointDispatcher GetEndpointDispatcher(Message message, out bool addressMatched)
437private ServiceChannel GetSessionChannel(Message message, out EndpointDispatcher endpoint, out bool addressMatched)
859Message fault = Message.CreateMessage(_messageVersion, code, reason, action);
871Message fault = Message.CreateMessage(_messageVersion, code, reason, action);
875private void ReplyFailure(RequestContext request, Message fault, string action, string reason, FaultCode code)
919Message reply = faultInfo.Fault;
974private bool PrepareReply(RequestContext request, Message reply)
985Message requestMessage = null;
1279private EventTraceActivity TraceDispatchMessageStart(Message message)
1302public Message Reply;
System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (37)
248internal bool HandleRequestAsReply(Message message)
269private bool HandleRequestAsReplyCore(Message message)
314Message message;
335public RequestContext CreateRequestContext(Message message)
340public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
350public void Send(Message message, TimeSpan timeout)
355public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
398public Message EndRequest(IAsyncResult result)
419Message message;
440public Message Request(Message message, TimeSpan timeout)
481Message reply;
527private void RequestStarting(Message message, IDuplexRequest request)
635internal DuplexRequestContext(IDuplexChannel channel, Message request, DuplexChannelBinder binder)
650protected override void OnReply(Message message, TimeSpan timeout)
658protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
673public ReplyAsyncResult(DuplexRequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state)
729void GotReply(Message reply);
734private Message _reply;
763internal Message WaitForReply(TimeSpan timeout)
780public void GotReply(Message reply)
810private Message _reply;
817internal AsyncDuplexRequest(Message message, DuplexChannelBinder parent, TimeSpan timeout, AsyncCallback callback, object state)
968internal Message End()
974public void GotReply(Message reply)
1057private InputQueue<Message> _pendingMessages;
1064_pendingMessages = new InputQueue<Message>();
1225Message message = null;
1342public Message Receive()
1347public Message Receive(TimeSpan timeout)
1362public Message EndReceive(IAsyncResult result)
1367public bool TryReceive(TimeSpan timeout, out Message message)
1377public bool EndTryReceive(IAsyncResult result, out Message message)
1501public void Send(Message message)
1506public void Send(Message message, TimeSpan timeout)
1511public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
1516public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Dispatcher\ErrorBehavior.cs (7)
42rpc.FaultInfo.Fault = Message.CreateMessage(rpc.RequestVersion, messageFault, action);
104faultInfo.Fault = Message.CreateMessage(_messageVersion, fault, action);
124Message m = faultInfo.Fault;
137Message faultMessage;
149faultInfo.Fault = Message.CreateMessage(_messageVersion, MessageFault.CreateFault(ndfe.Code, ndfe.Reason, detail), ndfe.Action);
153faultInfo.Fault = Message.CreateMessage(_messageVersion, ndfe.CreateMessageFault(), ndfe.Action);
238internal static void ThrowAndCatch(Exception e, Message message)
System\ServiceModel\Dispatcher\InputChannelBinder.cs (13)
69Message message;
82public RequestContext CreateRequestContext(Message message)
87public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
97public void Send(Message message, TimeSpan timeout)
104Message message;
117public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
122public Message EndRequest(IAsyncResult result)
127public Message Request(Message message, TimeSpan timeout)
147private RequestContext WrapMessage(Message message)
163internal InputRequestContext(Message request, InputChannelBinder binder)
177protected override void OnReply(Message message, TimeSpan timeout)
181protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Dispatcher\OperationFormatter.cs (14)
51protected abstract void AddHeadersToMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest);
59protected abstract void GetHeadersFromMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest);
110public object DeserializeReply(Message message, object[] parameters)
178public void DeserializeRequest(Message message, object[] parameters)
236private object DeserializeBodyContents(Message message, object[] parameters, bool isRequest)
266public Message SerializeRequest(MessageVersion messageVersion, object[] parameters)
292Message msg = new OperationFormatterMessage(this, messageVersion,
301public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result)
335Message msg = new OperationFormatterMessage(this, messageVersion,
450private void AddPropertiesToMessage(Message message, MessageDescription messageDescription, object[] parameters)
458private void AddPropertiesToMessageCore(Message message, MessageDescription messageDescription, object[] parameters)
473private void GetPropertiesFromMessage(Message message, MessageDescription messageDescription, object[] parameters)
481private void GetPropertiesFromMessageCore(Message message, MessageDescription messageDescription, object[] parameters)
841public override Message CreateMessage()
System\ServiceModel\Dispatcher\PrimitiveOperationFormatter.cs (6)
441public Message SerializeRequest(MessageVersion messageVersion, object[] parameters)
453return Message.CreateMessage(messageVersion, GetActionHeader(messageVersion.Addressing), new PrimitiveRequestBodyWriter(parameters, this));
456public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result)
468return Message.CreateMessage(messageVersion, GetReplyActionHeader(messageVersion.Addressing), new PrimitiveResponseBodyWriter(parameters, result, this));
471public object DeserializeReply(Message message, object[] parameters)
520public void DeserializeRequest(Message message, object[] parameters)
System\ServiceModel\Security\IssuanceTokenProviderBase.cs (11)
343static protected void ThrowIfFault(Message message, EndpointAddress target)
403protected abstract BodyWriter GetNextOutgoingMessageBody(Message incomingMessage, T negotiationState);
407private void PrepareRequest(Message nextMessage)
412private void PrepareRequest(Message nextMessage, RequestSecurityToken rst)
455Message nextOutgoingMessage = null;
456Message incomingMessage = null;
546private Message GetNextOutgoingMessage(Message incomingMessage, T negotiationState)
561Message nextMessage;
564nextMessage = Message.CreateMessage(MessageVersion, ActionHeader.Create(RequestSecurityTokenAction, MessageVersion.Addressing), nextMessageBody);
568nextMessage = Message.CreateMessage(MessageVersion, ActionHeader.Create(RequestSecurityTokenResponseAction, MessageVersion.Addressing), nextMessageBody);
System\ServiceModel\Security\SecurityProtocol.cs (16)
411private static void SetSecurityHeaderId(SendSecurityHeader securityHeader, Message message)
441protected SendSecurityHeader CreateSendSecurityHeader(Message message, string actor, SecurityProtocolFactory factory)
446protected SendSecurityHeader CreateSendSecurityHeaderForTransportProtocol(Message message, string actor, SecurityProtocolFactory factory)
451private SendSecurityHeader CreateSendSecurityHeader(Message message, string actor, SecurityProtocolFactory factory, bool requireMessageProtection)
470internal void AddMessageSupportingTokens(Message message, ref IList<SupportingTokenSpecification> supportingTokens)
492internal async Task<IList<SupportingTokenSpecification>> TryGetSupportingTokensAsync(SecurityProtocolFactory factory, EndpointAddress target, Uri via, Message message, TimeSpan timeout)
612public abstract Task<Message> SecureOutgoingMessageAsync(Message message, TimeSpan timeout);
615public virtual async Task<(SecurityProtocolCorrelationState, Message)> SecureOutgoingMessageAsync(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
620protected virtual void OnOutgoingMessageSecured(Message securedMessage)
624protected virtual void OnSecureOutgoingMessageFailure(Message message)
628public abstract void VerifyIncomingMessage(ref Message message, TimeSpan timeout);
631public virtual SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout, params SecurityProtocolCorrelationState[] correlationStates)
637protected virtual void OnIncomingMessageVerified(Message verifiedMessage)
641protected virtual void OnVerifyIncomingMessageFailure(Message message, Exception exception)
System\ServiceModel\Security\SecuritySessionClientSettings.cs (64)
307private Message _closeResponse;
575private Message PrepareCloseMessage()
586Message closeMessage = Message.CreateMessage(MessageVersion, ActionHeader.Create(Settings.SecurityStandardsManager.SecureConversationDriver.CloseAction, MessageVersion.Addressing), rst);
621Message closeMessage = PrepareCloseMessage();
639Message message = null;
653private MessageFault GetProtocolFault(ref Message message, out bool isKeyRenewalFault, out bool isSessionAbortedFault)
661Message copy = buffer.CreateMessage();
699private void ProcessCloseResponse(Message response)
742private void PrepareReply(Message request, Message reply)
765private bool DoesSkiClauseMatchSigningToken(SecurityContextKeyIdentifierClause skiClause, Message request)
775private void ProcessCloseMessage(Message message)
806Message response = null;
809response = Message.CreateMessage(message.Version, ActionHeader.Create(Settings.SecurityStandardsManager.SecureConversationDriver.CloseResponseAction, message.Version.Addressing), rstr);
816response = Message.CreateMessage(message.Version, ActionHeader.Create(Settings.SecurityStandardsManager.SecureConversationDriver.CloseResponseAction, message.Version.Addressing), rstrCollection);
831protected Message ProcessIncomingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, out MessageFault protocolFault)
891protected Message ProcessRequestContext(RequestContext requestContext, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
898Message message = requestContext.RequestMessage;
899Message unverifiedMessage = message;
1066protected async Task<(SecurityProtocolCorrelationState, Message)> SecureOutgoingMessageAsync(Message message, TimeSpan timeout)
1077protected void VerifyIncomingMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
1120protected async Task<Message> ReceiveInternalAsync(TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
1133Message message = ProcessRequestContext(requestContext, timeoutHelper.RemainingTime(), correlationState);
1449Message message = await ReceiveInternalAsync(timeoutHelper.RemainingTime(), correlationState);
1462public Task<Message> RequestAsync(Message message)
1467Message IRequestChannel.Request(Message message) => ((IRequestChannel)this).Request(message, DefaultSendTimeout);
1469Message IRequestChannel.Request(Message message, TimeSpan timeout) => RequestAsync(message, timeout).WaitForCompletionNoSpin();
1471IAsyncResult IRequestChannel.BeginRequest(Message message, AsyncCallback callback, object state) => ((IRequestChannel)this).BeginRequest(message, DefaultSendTimeout, callback, state);
1473IAsyncResult IRequestChannel.BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state) => RequestAsync(message, timeout).ToApm(callback, state);
1475Message IRequestChannel.EndRequest(IAsyncResult result) => result.ToApmEnd<Message>();
1477private Message ProcessReply(Message reply, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
1483Message unverifiedReply = reply;
1484Message processedReply = null;
1518public async Task<Message> RequestAsync(Message message, TimeSpan timeout)
1526Message reply = await ChannelBinder.RequestAsync(message, timeoutHelper.RemainingTime());
1534private InputQueue<Message> _queue;
1540_queue = TraceUtility.CreateInputQueue<Message>();
1577public Message Receive() => ReceiveAsync().GetAwaiter().GetResult();
1579public Task<Message> ReceiveAsync() => ReceiveAsync(DefaultReceiveTimeout);
1581public Message Receive(TimeSpan timeout) => ReceiveAsync(timeout).GetAwaiter().GetResult();
1583public Task<Message> ReceiveAsync(TimeSpan timeout) => InputChannel.HelpReceiveAsync(this, timeout);
1589public Message EndReceive(IAsyncResult result) => result.ToApmEnd<Message>();
1593public bool EndTryReceive(IAsyncResult result, out Message message)
1596(success, message) = result.ToApmEnd<(bool, Message)>();
1606public bool TryReceive(TimeSpan timeout, out Message message)
1613public async Task<(bool, Message)> TryReceiveAsync(TimeSpan timeout)
1617(bool wasDequeued, Message message) = await _queue.TryDequeueAsync(timeout);
1626public void Send(Message message) => SendAsync(message).WaitForCompletionNoSpin();
1628public Task SendAsync(Message message) => SendAsync(message, DefaultSendTimeout);
1630public void Send(Message message, TimeSpan timeout) => SendAsync(message, timeout).WaitForCompletionNoSpin();
1632public async Task SendAsync(Message message, TimeSpan timeout)
1643public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) => SendAsync(message).ToApm(callback, state);
1645public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) => SendAsync(message, timeout).ToApm(callback, state);
1665Message message = await ReceiveInternalAsync(TimeSpan.MaxValue, null);
System\ServiceModel\Security\SecuritySessionSecurityTokenProvider.cs (15)
447private Message CreateRequest(SecuritySessionOperation operation, EndpointAddress target, SecurityToken currentToken, out object requestState)
463private GenericXmlSecurityToken ProcessReply(Message reply, SecuritySessionOperation operation, object requestState)
513using (Message requestMessage = CreateRequest(operation, target, currentToken, out requestState))
519using (Message reply = await channel.RequestAsync(requestMessage, timeoutHelper.RemainingTime()))
579private void PrepareRequest(Message message)
595protected virtual Message CreateIssueRequest(EndpointAddress target, out object requestState)
601Message result = Message.CreateMessage(MessageVersion, ActionHeader.Create(IssueAction, MessageVersion.Addressing), rst);
606private GenericXmlSecurityToken ExtractToken(Message response, object requestState)
663protected virtual GenericXmlSecurityToken ProcessIssueResponse(Message response, object requestState)
669protected virtual Message CreateRenewRequest(EndpointAddress target, SecurityToken currentSessionToken, out object requestState)
676Message result = Message.CreateMessage(MessageVersion, ActionHeader.Create(RenewAction, MessageVersion.Addressing), rst);
684protected virtual GenericXmlSecurityToken ProcessRenewResponse(Message response, object requestState)
695protected static void ThrowIfFault(Message message, EndpointAddress target)
System\ServiceModel\Security\TransportSecurityProtocol.cs (8)
23public override async Task<Message> SecureOutgoingMessageAsync(Message message, TimeSpan timeout)
52protected virtual async Task<Message> SecureOutgoingMessageAtInitiatorAsync(Message message, string actor, TimeSpan timeout)
59internal void SetUpDelayedSecurityExecution(ref Message message, string actor,
67public sealed override void VerifyIncomingMessage(ref Message message, TimeSpan timeout)
96protected void AttachRecipientSecurityProperty(Message message, IList<SecurityToken> basicTokens, IList<SecurityToken> endorsingTokens,
104protected virtual void VerifyIncomingMessageCore(ref Message message, TimeSpan timeout)