FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\BinaryMessageEncoder.cs (11)
516public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType)
553Message message;
582public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType)
603Message message = Message.CreateMessage(reader, maxSizeOfHeaders, _factory._messageVersion);
619public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
725public override void WriteMessage(Message message, Stream stream)
809public void AddCompressedMessageProperties(Message message, string supportedCompressionTypes)
859private CompressionFormat CheckCompressedWrite(Message message)
1304public Message TryCreateMessage(byte[] buffer, int offset, int size, BufferManager bufferManager, BufferedMessageData messageData)
1782public override Message CreateMessage()
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\Message.cs (21)
113static public Message CreateMessage(MessageVersion version, string action, object body)
118static public Message CreateMessage(MessageVersion version, string action, object body, XmlObjectSerializer serializer)
127static public Message CreateMessage(MessageVersion version, string action, XmlReader body)
132static public Message CreateMessage(MessageVersion version, string action, XmlDictionaryReader body)
142static public Message CreateMessage(MessageVersion version, string action, BodyWriter body)
151static internal Message CreateMessage(MessageVersion version, ActionHeader actionHeader, BodyWriter body)
160static public Message CreateMessage(MessageVersion version, string action)
167static internal Message CreateMessage(MessageVersion version, ActionHeader actionHeader)
174static public Message CreateMessage(XmlReader envelopeReader, int maxSizeOfHeaders, MessageVersion version)
179static public Message CreateMessage(XmlDictionaryReader envelopeReader, int maxSizeOfHeaders, MessageVersion version)
185Message message = new StreamedMessage(envelopeReader, maxSizeOfHeaders, version);
189static public Message CreateMessage(MessageVersion version, FaultCode faultCode, string reason, string action)
201static public Message CreateMessage(MessageVersion version, FaultCode faultCode, string reason, object detail, string action)
213static public Message CreateMessage(MessageVersion version, MessageFault fault, string action)
308internal void InitializeReply(Message request)
543Message.ReadFromBodyContentsToEnd(reader, this.Version.Envelope);
580Message.ReadFromBodyContentsToEnd(reader, envelopeVersion);
782private Message _message;
785public OnWriteMessageAsyncResult(XmlDictionaryWriter writer, Message message, AsyncCallback callback, object state)
893_isFault = Message.IsFaultStartElement(reader, version);
1192return Message.ReadStartBody(reader, this.Version.Envelope, out _isFault, out _isEmpty);
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\MessageEncoder.cs (15)
32public Message ReadMessage(Stream stream, int maxSizeOfHeaders)
37public virtual Task<Message> ReadMessageAsync(Stream stream, int maxSizeOfHeaders, string contentType)
42public virtual Task<Message> ReadMessageAsync(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType)
47public abstract Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType);
49public Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager)
51Message message = ReadMessage(buffer, bufferManager, null);
55public abstract Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType);
93internal virtual async Task<Message> ReadMessageAsync(Stream stream, BufferManager bufferManager, int maxBufferSize, string contentType)
103public abstract void WriteMessage(Message message, Stream stream);
105public virtual IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state)
115public ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager)
121public abstract ArraySegment<byte> WriteMessage(Message message, int maxMessageSize,
124public virtual Task WriteMessageAsync(Message message, Stream stream)
130public virtual Task<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize,
223internal void ThrowIfMismatchedMessageVersion(Message message)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\RequestChannel.cs (21)
218public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state)
223public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
228protected abstract IAsyncRequest CreateAsyncRequest(Message message);
230public Message EndRequest(IAsyncResult result)
232return result.ToApmEnd<Message>();
235public Message Request(Message message)
240public Message Request(Message message, TimeSpan timeout)
245public Task<Message> RequestAsync(Message message)
250private async Task<Message> RequestAsyncInternal(Message message, TimeSpan timeout)
256public async Task<Message> RequestAsync(Message message, TimeSpan timeout)
274Message reply;
308protected virtual void AddHeadersTo(Message message)
326void SendRequest(Message message, TimeSpan timeout);
327Message WaitForReply(TimeSpan timeout);
332Task SendRequestAsync(Message message, TimeoutHelper timeoutHelper);
333Task<Message> ReceiveReplyAsync(TimeoutHelper timeoutHelper);
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\RequestContextBase.cs (11)
18private Message _requestMessage;
25protected RequestContextBase(Message requestMessage, TimeSpan defaultCloseTimeout, TimeSpan defaultSendTimeout)
32public void ReInitialize(Message requestMessage)
42public override Message RequestMessage
55protected void SetRequestMessage(Message requestMessage)
186protected abstract void OnReply(Message message, TimeSpan timeout);
187protected abstract IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state);
224public override IAsyncResult BeginReply(Message message, AsyncCallback callback, object state)
229public override IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
247public override void Reply(Message message)
252public override void Reply(Message message, TimeSpan timeout)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ServiceChannel.cs (16)
870internal void FireUnknownMessageReceived(Message message)
999private void ThrowIfFaultUnderstood(Message reply, MessageFault fault, string action, MessageVersion version, FaultConverter faultConverter)
1157private void AddMessageProperties(Message message, OperationContext context)
1186public void Send(Message message)
1191public void Send(Message message, TimeSpan timeout)
1197public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
1202public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1213public Message Request(Message message)
1218public Message Request(Message message, TimeSpan timeout)
1221return (Message)Call(message.Headers.Action, false, operation, new object[] { message }, Array.Empty<object>(), timeout);
1224public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state)
1229public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1235public Message EndRequest(IAsyncResult result)
1237return (Message)EndCall(MessageHeaders.WildcardAction, Array.Empty<object>(), result);
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ServiceChannelProxy.cs (11)
730IAsyncResult IOutputChannel.BeginSend(Message message, AsyncCallback callback, object state)
735IAsyncResult IOutputChannel.BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
745void IOutputChannel.Send(Message message)
750void IOutputChannel.Send(Message message, TimeSpan timeout)
755Message IRequestChannel.Request(Message message)
760Message IRequestChannel.Request(Message message, TimeSpan timeout)
765IAsyncResult IRequestChannel.BeginRequest(Message message, AsyncCallback callback, object state)
770IAsyncResult IRequestChannel.BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
775Message IRequestChannel.EndRequest(IAsyncResult result)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\TextMessageEncoder.cs (11)
401public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType)
411Message message;
437public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType)
448Message message = Message.CreateMessage(reader, maxSizeOfHeaders, _version);
461public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
466public override void WriteMessage(Message message, Stream stream)
471public override Task<ArraySegment<byte>> WriteMessageAsync(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
516private async Task WriteMessageAsyncInternal(Message message, Stream stream)
522public override async Task WriteMessageAsync(Message message, Stream stream)
562public override IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (21)
84public Message Receive()
89public Message Receive(TimeSpan timeout)
91Message message = null;
120public async Task<Message> ReceiveAsync(TimeSpan timeout)
122Message message = null;
161public Message EndReceive(IAsyncResult result)
163return result.ToApmEnd<Message>();
171public bool EndTryReceive(IAsyncResult result, out Message message)
175message = result.ToApmEnd<Message>();
191public bool TryReceive(TimeSpan timeout, out Message message)
445protected virtual void OnReceiveMessage(Message message)
457protected void ApplyChannelBinding(Message message)
462protected virtual void PrepareMessage(Message message)
488protected abstract AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, Action<object> callback, object state);
496protected abstract ArraySegment<byte> EncodeMessage(Message message);
498protected abstract void OnSendCore(Message message, TimeSpan timeout);
500protected abstract AsyncCompletionResult StartWritingStreamedMessage(Message message, TimeSpan timeout, Action<object> callback, object state);
502protected override async Task OnSendAsync(Message message, TimeSpan timeout)
607protected override void OnSend(Message message, TimeSpan timeout)
671Message message = await this.MessageSource.ReceiveAsync(timeout);
684Message message = this.MessageSource.Receive(timeout);
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (16)
186protected override AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, Action<object> callback, object state)
226protected override AsyncCompletionResult StartWritingStreamedMessage(Message message, TimeSpan timeout, Action<object> callback, object state)
266protected override void OnSendCore(Message message, TimeSpan timeout)
323protected override ArraySegment<byte> EncodeMessage(Message message)
391private static WebSocketMessageType GetWebSocketMessageType(Message message)
463private Message _pendingMessage;
516public async Task<Message> ReceiveAsync(TimeSpan timeout)
528Message message = GetPendingMessage();
539public Message Receive(TimeSpan timeout)
551Message message = GetPendingMessage();
659Message message = Receive(timeout);
679Message message = await ReceiveAsync(timeout);
813private Message GetPendingMessage()
819Message pendingMessage = _pendingMessage;
827private Message PrepareMessage(WebSocketReceiveResult result, byte[] buffer, int count)
831Message message;
FrameworkFork\System.ServiceModel\System\ServiceModel\ClientBase.cs (11)
771void IOutputChannel.Send(Message message)
776void IOutputChannel.Send(Message message, TimeSpan timeout)
781IAsyncResult IOutputChannel.BeginSend(Message message, AsyncCallback callback, object state)
786IAsyncResult IOutputChannel.BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
806Message IRequestChannel.Request(Message message)
811Message IRequestChannel.Request(Message message, TimeSpan timeout)
816IAsyncResult IRequestChannel.BeginRequest(Message message, AsyncCallback callback, object state)
821IAsyncResult IRequestChannel.BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
826Message IRequestChannel.EndRequest(IAsyncResult result)
FrameworkFork\System.ServiceModel\System\ServiceModel\Diagnostics\TraceUtility.cs (18)
29static internal void AddActivityHeader(Message message)
46static internal void AddAmbientActivityToMessage(Message message)
63static internal void CopyActivity(Message source, Message destination)
81internal static ServiceModelActivity ExtractActivity(Message message)
99internal static Guid ExtractActivityId(Message message)
123internal static ServiceModelActivity ExtractAndRemoveActivity(Message message)
135internal static void ProcessIncomingMessage(Message message, EventTraceActivity eventTraceActivity)
162internal static void ProcessOutgoingMessage(Message message, EventTraceActivity eventTraceActivity)
182internal static void SetActivity(Message message, ServiceModelActivity activity)
190internal static void TraceDroppedMessage(Message message, EndpointDispatcher dispatcher)
234internal static Exception ThrowHelperError(Exception exception, Message message)
244internal static Exception ThrowHelperWarning(Exception exception, Message message)
249internal static ArgumentException ThrowHelperArgument(string paramName, string message, Message msg)
254internal static ArgumentNullException ThrowHelperArgumentNull(string paramName, Message message)
372static internal void MessageFlowAtMessageSent(Message message, EventTraceActivity eventTraceActivity)
395static internal void MessageFlowAtMessageReceived(Message message, OperationContext context, EventTraceActivity eventTraceActivity, bool createNewActivityId)
438internal static void TransferFromTransport(Message message)
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\ChannelHandler.cs (12)
262Message message = request.RequestMessage;
415private ServiceChannel GetDatagramChannel(Message message, out EndpointDispatcher endpoint, out bool addressMatched)
440private EndpointDispatcher GetEndpointDispatcher(Message message, out bool addressMatched)
445private ServiceChannel GetSessionChannel(Message message, out EndpointDispatcher endpoint, out bool addressMatched)
861Message fault = Message.CreateMessage(_messageVersion, code, reason, action);
865private void ReplyFailure(RequestContext request, Message fault, string action, string reason, FaultCode code)
910Message reply = faultInfo.Fault;
966private bool PrepareReply(RequestContext request, Message reply)
977Message requestMessage = null;
1272private EventTraceActivity TraceDispatchMessageStart(Message message)
1295public Message Reply;
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (37)
258internal bool HandleRequestAsReply(Message message)
279private bool HandleRequestAsReplyCore(Message message)
322Message message;
343public RequestContext CreateRequestContext(Message message)
348public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
358public void Send(Message message, TimeSpan timeout)
363public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
404public Message EndRequest(IAsyncResult result)
423Message message;
444public Message Request(Message message, TimeSpan timeout)
483Message reply;
527private void RequestStarting(Message message, IDuplexRequest request)
633internal DuplexRequestContext(IDuplexChannel channel, Message request, DuplexChannelBinder binder)
648protected override void OnReply(Message message, TimeSpan timeout)
656protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
671public ReplyAsyncResult(DuplexRequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state)
728void GotReply(Message reply);
733private Message _reply;
762internal Message WaitForReply(TimeSpan timeout)
779public void GotReply(Message reply)
809private Message _reply;
816internal AsyncDuplexRequest(Message message, DuplexChannelBinder parent, TimeSpan timeout, AsyncCallback callback, object state)
953internal Message End()
959public void GotReply(Message reply)
1038private InputQueue<Message> _pendingMessages;
1045_pendingMessages = new InputQueue<Message>();
1206Message message = null;
1323public Message Receive()
1328public Message Receive(TimeSpan timeout)
1343public Message EndReceive(IAsyncResult result)
1348public bool TryReceive(TimeSpan timeout, out Message message)
1358public bool EndTryReceive(IAsyncResult result, out Message message)
1482public void Send(Message message)
1487public void Send(Message message, TimeSpan timeout)
1492public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
1497public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\ErrorBehavior.cs (7)
37rpc.FaultInfo.Fault = Message.CreateMessage(rpc.RequestVersion, messageFault, action);
98faultInfo.Fault = Message.CreateMessage(_messageVersion, fault, action);
118Message m = faultInfo.Fault;
131Message faultMessage;
143faultInfo.Fault = Message.CreateMessage(_messageVersion, MessageFault.CreateFault(ndfe.Code, ndfe.Reason, detail), ndfe.Action);
147faultInfo.Fault = Message.CreateMessage(_messageVersion, ndfe.CreateMessageFault(), ndfe.Action);
227internal static void ThrowAndCatch(Exception e, Message message)
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\InputChannelBinder.cs (13)
74Message message;
87public RequestContext CreateRequestContext(Message message)
92public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
102public void Send(Message message, TimeSpan timeout)
109Message message;
122public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
127public Message EndRequest(IAsyncResult result)
132public Message Request(Message message, TimeSpan timeout)
152private RequestContext WrapMessage(Message message)
168internal InputRequestContext(Message request, InputChannelBinder binder)
182protected override void OnReply(Message message, TimeSpan timeout)
186protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\OperationFormatter.cs (14)
48protected abstract void AddHeadersToMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest);
56protected abstract void GetHeadersFromMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest);
107public object DeserializeReply(Message message, object[] parameters)
171public void DeserializeRequest(Message message, object[] parameters)
225private object DeserializeBodyContents(Message message, object[] parameters, bool isRequest)
255public Message SerializeRequest(MessageVersion messageVersion, object[] parameters)
276Message msg = new OperationFormatterMessage(this, messageVersion,
285public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result)
315Message msg = new OperationFormatterMessage(this, messageVersion,
431private void AddPropertiesToMessage(Message message, MessageDescription messageDescription, object[] parameters)
439private void AddPropertiesToMessageCore(Message message, MessageDescription messageDescription, object[] parameters)
452private void GetPropertiesFromMessage(Message message, MessageDescription messageDescription, object[] parameters)
460private void GetPropertiesFromMessageCore(Message message, MessageDescription messageDescription, object[] parameters)
793public override Message CreateMessage()
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\PrimitiveOperationFormatter.cs (6)
347public Message SerializeRequest(MessageVersion messageVersion, object[] parameters)
355return Message.CreateMessage(messageVersion, GetActionHeader(messageVersion.Addressing), new PrimitiveRequestBodyWriter(parameters, this));
358public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result)
366return Message.CreateMessage(messageVersion, GetReplyActionHeader(messageVersion.Addressing), new PrimitiveResponseBodyWriter(parameters, result, this));
369public object DeserializeReply(Message message, object[] parameters)
409public void DeserializeRequest(Message message, object[] parameters)