System\ServiceModel\Channels\BinaryMessageEncoder.cs (11)
612public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType)
649Message message;
686public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType)
707Message message = Message.CreateMessage(reader, maxSizeOfHeaders, factory.messageVersion);
723public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
838public override void WriteMessage(Message message, Stream stream)
921public void AddCompressedMessageProperties(Message message, string supportedCompressionTypes)
971CompressionFormat CheckCompressedWrite(Message message)
1421public Message TryCreateMessage(byte[] buffer, int offset, int size, BufferManager bufferManager, BufferedMessageData messageData)
1914public override Message CreateMessage()
System\ServiceModel\Channels\ChannelDemuxer.cs (91)
148internal static void AbortMessage(Message message)
246protected abstract Message GetMessage(TInnerItem item);
341IChannelListener MatchListener(Message message)
603Message message = null;
1099class InputChannelDemuxer : DatagramChannelDemuxer<IInputChannel, Message>
1106protected override void AbortItem(Message message)
1118SingletonChannelListener<IInputChannel, InputChannel, Message> listener = new SingletonChannelListener<IInputChannel, InputChannel, Message>(filter, this);
1125SingletonChannelListener<IInputChannel, InputChannel, Message> singletonListener = (SingletonChannelListener<IInputChannel, InputChannel, Message>)listener;
1129protected override void EndpointNotFound(Message message)
1138protected override Message EndReceive(IAsyncResult result)
1143protected override void EnqueueAndDispatch(IChannelListener listener, Message message, Action dequeuedCallback, bool canDispatchOnThisThread)
1145SingletonChannelListener<IInputChannel, InputChannel, Message> singletonListener = (SingletonChannelListener<IInputChannel, InputChannel, Message>)listener;
1151SingletonChannelListener<IInputChannel, InputChannel, Message> singletonListener = (SingletonChannelListener<IInputChannel, InputChannel, Message>)listener;
1155protected override Message GetMessage(Message message)
1161class DuplexChannelDemuxer : DatagramChannelDemuxer<IDuplexChannel, Message>
1168protected override void AbortItem(Message message)
1180SingletonChannelListener<IDuplexChannel, DuplexChannel, Message> listener = new SingletonChannelListener<IDuplexChannel, DuplexChannel, Message>(filter, this);
1187SingletonChannelListener<IDuplexChannel, DuplexChannel, Message> singletonListener = (SingletonChannelListener<IDuplexChannel, DuplexChannel, Message>)listener;
1191protected override void EndpointNotFound(Message message)
1200protected override Message EndReceive(IAsyncResult result)
1205protected override void EnqueueAndDispatch(IChannelListener listener, Message message, Action dequeuedCallback, bool canDispatchOnThisThread)
1207SingletonChannelListener<IDuplexChannel, DuplexChannel, Message> singletonListener = (SingletonChannelListener<IDuplexChannel, DuplexChannel, Message>)listener;
1213SingletonChannelListener<IDuplexChannel, DuplexChannel, Message> singletonListener = (SingletonChannelListener<IDuplexChannel, DuplexChannel, Message>)listener;
1217protected override Message GetMessage(Message message)
1222class DuplexChannelAcceptor : SingletonChannelAcceptor<IDuplexChannel, DuplexChannel, Message>
1237protected override void OnTraceMessageReceived(Message message)
1267protected override void OnSend(Message message, TimeSpan timeout)
1272protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1320SingletonChannelListener<IInputChannel, InputChannel, Message> listener = new SingletonChannelListener<IInputChannel, InputChannel, Message>(filter, this);
1338SingletonChannelListener<IInputChannel, InputChannel, Message> inputListener = listener as SingletonChannelListener<IInputChannel, InputChannel, Message>;
1456SingletonChannelListener<IInputChannel, InputChannel, Message> inputListener = listener as SingletonChannelListener<IInputChannel, InputChannel, Message>;
1490SingletonChannelListener<IInputChannel, InputChannel, Message> inputListener = listener as SingletonChannelListener<IInputChannel, InputChannel, Message>;
1507protected override Message GetMessage(RequestContext request)
1686protected abstract Message GetMessage(TInnerItem item);
1955InputQueueChannelListener<TInnerChannel> MatchListener(Message message)
2255Message message = this.GetMessage(item);
2686class InputSessionChannelDemuxer : SessionChannelDemuxer<IInputSessionChannel, Message>
2693protected override void AbortItem(Message message)
2708protected override IInputSessionChannel CreateChannel(ChannelManagerBase channelManager, IInputSessionChannel innerChannel, Message firstMessage)
2713protected override void EndpointNotFound(IInputSessionChannel channel, Message message)
2723protected override Message EndReceive(IInputSessionChannel channel, IAsyncResult result)
2728protected override Message GetMessage(Message message)
2736public InputSessionChannelWrapper(ChannelManagerBase channelManager, IInputSessionChannel innerChannel, Message firstMessage)
2752class DuplexSessionChannelDemuxer : SessionChannelDemuxer<IDuplexSessionChannel, Message>
2759protected override void AbortItem(Message message)
2774protected override IDuplexSessionChannel CreateChannel(ChannelManagerBase channelManager, IDuplexSessionChannel innerChannel, Message firstMessage)
2823protected override void EndpointNotFound(IDuplexSessionChannel channel, Message message)
2875protected override Message EndReceive(IDuplexSessionChannel channel, IAsyncResult result)
2880protected override Message GetMessage(Message message)
2888public Message message;
2890public ChannelAndMessageAsyncState(IChannel channel, Message message)
2900public DuplexSessionChannelWrapper(ChannelManagerBase channelManager, IDuplexSessionChannel innerChannel, Message firstMessage)
2925public void Send(Message message)
2930public void Send(Message message, TimeSpan timeout)
2935public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
2940public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
3080protected override Message GetMessage(RequestContext request)
3199class InputChannelWrapper : ChannelWrapper<IInputChannel, Message>, IInputChannel
3201public InputChannelWrapper(ChannelManagerBase channelManager, IInputChannel innerChannel, Message firstMessage)
3227Message message = this.GetFirstItem();
3234public Message Receive()
3236Message message = this.GetFirstItem();
3242public Message Receive(TimeSpan timeout)
3244Message message = this.GetFirstItem();
3252Message message = this.GetFirstItem();
3260Message message = this.GetFirstItem();
3266public Message EndReceive(IAsyncResult result)
3273public bool TryReceive(TimeSpan timeout, out Message message)
3283Message message = this.GetFirstItem();
3289public bool EndTryReceive(IAsyncResult result, out Message message)
3856Message message;
3858public DuplexSessionDemuxFailureAsyncResult(IChannelDemuxFailureHandler demuxFailureHandler, IDuplexSessionChannel channel, Message message, AsyncCallback callback, object state)
3957void HandleDemuxFailure(Message message);
3959IAsyncResult BeginHandleDemuxFailure(Message message, RequestContext faultContext, AsyncCallback callback, object state);
3960IAsyncResult BeginHandleDemuxFailure(Message message, IOutputChannel faultContext, AsyncCallback callback, object state);
System\ServiceModel\Channels\ClientReliableChannelBinder.cs (31)
91public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback,
97public IAsyncResult BeginRequest(Message message, TimeSpan timeout, MaskingMode maskingMode,
158public Message EndRequest(IAsyncResult result)
196protected virtual IAsyncResult OnBeginRequest(TChannel channel, Message message,
216protected virtual Message OnEndRequest(TChannel channel, MaskingMode maskingMode,
226protected virtual Message OnRequest(TChannel channel, Message message, TimeSpan timeout,
232public Message Request(Message message, TimeSpan timeout)
237public Message Request(Message message, TimeSpan timeout, MaskingMode maskingMode)
355protected override IAsyncResult OnBeginSend(TDuplexChannel channel, Message message,
375Message message;
389protected override void OnSend(TDuplexChannel channel, Message message,
398Message message;
498InputQueue<Message> inputMessages;
518Message message;
524protected void EnqueueMessageIfNotNull(Message message)
532InputQueue<Message> GetInputMessages()
548this.inputMessages = TraceUtility.CreateInputQueue<Message>();
576Message message, TimeSpan timeout, MaskingMode maskingMode,
582protected override IAsyncResult OnBeginSend(TRequestChannel channel, Message message,
588protected override Message OnEndRequest(TRequestChannel channel,
596Message message = channel.EndRequest(result);
600protected override Message OnRequest(TRequestChannel channel, Message message,
606protected override void OnSend(TRequestChannel channel, Message message,
623Message message;
633Message reply;
642ClientReliableChannelBinder<TChannel> binder, TChannel channel, Message message,
649public static Message End(IAsyncResult result)
System\ServiceModel\Channels\ContextChannelRequestContext.cs (9)
33public override Message RequestMessage
43public override IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
48public override IAsyncResult BeginReply(Message message, AsyncCallback callback, object state)
68public override void Reply(Message message, TimeSpan timeout)
71Message replyMessage = message;
105public override void Reply(Message message)
117Message message;
118Message replyMessage;
121public ReplyAsyncResult(Message message, ContextChannelRequestContext context, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Channels\ContextRequestChannelBase.cs (15)
32public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
38public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state)
43public Message EndRequest(IAsyncResult result)
45Message message = RequestAsyncResult.End(result);
67public Message Request(Message message, TimeSpan timeout)
71Message requestMessage = message;
83Message response = null;
103public Message Request(Message message)
115Message message;
116Message replyMessage;
117Message requestMessage;
120public RequestAsyncResult(Message message, IRequestChannel channel, TimeSpan timeout, AsyncCallback callback, object state)
161public static Message End(IAsyncResult result)
System\ServiceModel\Channels\CreateSequence.cs (5)
77Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
98Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
138Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
153Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
162Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
System\ServiceModel\Channels\DatagramAdapter.cs (22)
754class InputDatagramAdapterListener : DatagramAdapterListenerBase<IInputChannel, IInputSessionChannel, Message>
756SingletonChannelAcceptor<IInputChannel, InputChannel, Message> acceptor;
773protected override Message CallEndReceive(IInputSessionChannel channel, IAsyncResult result)
778protected override void Enqueue(Message message, Action callback)
1155public void Send(Message message)
1160public void Send(Message message, TimeSpan timeout)
1199public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
1204public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1217Message message;
1221public SendAsyncResult(OutputDatagramAdapterChannel adapter, Message message, TimeSpan timeout, AsyncCallback callback, object state)
1385public Message Request(Message request)
1390public Message Request(Message request, TimeSpan timeout)
1395Message reply = null;
1432public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state)
1437public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1442public Message EndRequest(IAsyncResult result)
1450Message message;
1451Message reply = null;
1455public RequestAsyncResult(RequestDatagramAdapterChannel adapter, Message message, TimeSpan timeout, AsyncCallback callback, object state)
1576public static Message End(IAsyncResult result)
System\ServiceModel\Channels\DuplexChannel.cs (13)
11abstract class DuplexChannel : InputQueueChannel<Message>, IDuplexChannel
29public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
34public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
69protected abstract void OnSend(Message message, TimeSpan timeout);
71protected virtual IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
82public void Send(Message message)
87public void Send(Message message, TimeSpan timeout)
102protected virtual void AddHeadersTo(Message message)
106public Message Receive()
111public Message Receive(TimeSpan timeout)
138public Message EndReceive(IAsyncResult result)
143public bool TryReceive(TimeSpan timeout, out Message message)
163public bool EndTryReceive(IAsyncResult result, out Message message)
System\ServiceModel\Channels\HttpChannelHelpers.cs (32)
152Message DecodeBufferedMessage(ArraySegment<byte> buffer, Stream inputStream)
183Message ReadBufferedMessage(Stream inputStream)
210Message ReadChunkedBufferedMessage(Stream inputStream)
223Message ReadStreamedMessage(Stream inputStream)
238protected abstract void AddProperties(Message message);
240void ApplyChannelBinding(Message message)
249Exception ProcessHttpAddressing(Message message)
437public Message EndParseIncomingMessage(IAsyncResult result, out Exception requestException)
442Message message = ParseMessageAsyncResult.End(result, out requestException);
473public Message ParseIncomingMessage(out Exception requestException)
478public Message ParseIncomingMessage(HttpRequestMessage httpRequestMessage, out Exception requestException)
480Message message = null;
552Message ReadBufferedMessage(HttpRequestMessage httpRequestMessage)
556Message message;
638Message message;
801public static Message End(IAsyncResult result, out Exception requestException)
884protected override void AddProperties(Message message)
1074Message message;
1087protected HttpOutput(IHttpTransportFactorySettings settings, Message message, bool isRequest, bool supportsConcurrentIO)
1236public void ConfigureHttpResponseMessage(Message message, HttpResponseMessage httpResponseMessage, HttpResponseMessageProperty responseProperty)
1370protected virtual bool PrepareHttpSend(Message message)
1438private static void EnsureEventTraceActivity(Message message)
1461ArraySegment<byte> SerializeBufferedMessage(Message message)
1467ArraySegment<byte> SerializeBufferedMessage(Message message, bool shouldRecycleBuffer)
2365internal static HttpOutput CreateHttpOutput(HttpWebRequest httpWebRequest, IHttpTransportFactorySettings settings, Message message, bool enableChannelBindingSupport)
2370internal static HttpOutput CreateHttpOutput(HttpListenerResponse httpListenerResponse, IHttpTransportFactorySettings settings, Message message, string httpMethod)
2381public WebRequestHttpOutput(HttpWebRequest httpWebRequest, IHttpTransportFactorySettings settings, Message message, bool enableChannelBindingSupport)
2507protected override bool PrepareHttpSend(Message message)
2912public ListenerResponseHttpOutput(HttpListenerResponse listenerResponse, IHttpTransportFactorySettings settings, Message message, string httpMethod)
2944protected override bool PrepareHttpSend(Message message)
3292HttpWebResponse webResponse, Message replyMessage)
4209protected override void AddProperties(Message message)
System\ServiceModel\Channels\HttpPipeline.cs (18)
118public abstract void SendReply(Message message, TimeSpan timeout);
120public virtual AsyncCompletionResult SendAsyncReply(Message message, Action<object, HttpResponseMessage> asyncSendCallback, object state)
145protected abstract Message EndParseIncomingMesssage(IAsyncResult result, out Exception requestException);
147protected abstract void OnParseComplete(Message message, Exception requestException);
206protected HttpOutput GetHttpOutput(Message message)
227public override void SendReply(Message message, TimeSpan timeout)
262protected override Message EndParseIncomingMesssage(IAsyncResult result, out Exception requestException)
269protected override void OnParseComplete(Message message, Exception requestException)
283protected virtual void SendReplyCore(Message message, TimeSpan timeout)
360protected override void SendReplyCore(Message message, TimeSpan timeout)
435public override void SendReply(Message message, TimeSpan timeout)
475public override AsyncCompletionResult SendAsyncReply(Message message, Action<object, HttpResponseMessage> asyncSendCallback, object state)
561protected override Message EndParseIncomingMesssage(IAsyncResult result, out Exception requestException)
566protected override void OnParseComplete(Message message, Exception requestException)
706HttpResponseMessage CreateHttpResponseMessage(Message message)
720void CompleteChannelModelIntegrationHandlerTask(Message replyMessage)
772public override void SendReply(Message message, TimeSpan timeout)
908Message message = this.pipeline.EndParseIncomingMesssage(result, out requestException);
System\ServiceModel\Channels\HttpRequestContext.cs (17)
33protected HttpRequestContext(HttpChannelListener listener, Message requestMessage, EventTraceActivity eventTraceActivity)
124public abstract HttpOutput GetHttpOutput(Message message);
127public HttpOutput GetHttpOutputCore(Message message)
175internal void SetMessage(Message message, Exception requestException)
198void TraceHttpMessageReceived(Message message)
252bool PrepareReply(ref Message message)
312protected override void OnReply(Message message, TimeSpan timeout)
315Message responseMessage = message;
343Message message, TimeSpan timeout, AsyncCallback callback, object state)
417using (Message ackMessage = CreateAckMessage(statusCode, statusDescription))
465Message CreateAckMessage(HttpStatusCode statusCode, string statusDescription)
467Message ackMessage = new NullMessage();
561Message message;
562Message responseMessage;
565public ReplyAsyncResult(HttpRequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state)
830public override HttpOutput GetHttpOutput(Message message)
958protected override void AddProperties(Message message)
System\ServiceModel\Channels\InternalDuplexChannelListener.cs (11)
146public Message Receive()
151public Message Receive(TimeSpan timeout)
166public Message EndReceive(IAsyncResult result)
176public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
181public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
186public bool EndTryReceive(IAsyncResult result, out Message message)
232public bool TryReceive(TimeSpan timeout, out Message message)
237public void Send(Message message)
242public void Send(Message message, TimeSpan timeout)
257IOutputChannel ValidateStateAndGetOutputChannel(Message message, TimeoutHelper timeoutHelper)
292public SendAsyncResult(ServerCompositeDuplexChannel outer, Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Channels\IReliableChannelBinder.cs (13)
35IAsyncResult BeginSend(Message message, TimeSpan timeout, MaskingMode maskingMode, AsyncCallback callback, object state);
36IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state);
38void Send(Message message, TimeSpan timeout);
39void Send(Message message, TimeSpan timeout, MaskingMode maskingMode);
61IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state);
62IAsyncResult BeginRequest(Message message, TimeSpan timeout, MaskingMode maskingMode, AsyncCallback callback, object state);
63Message EndRequest(IAsyncResult result);
64Message Request(Message message, TimeSpan timeout);
65Message Request(Message message, TimeSpan timeout, MaskingMode maskingMode);
71bool AddressResponse(Message request, Message response);
System\ServiceModel\Channels\Message.cs (23)
155static public Message CreateMessage(MessageVersion version, string action, object body)
160static public Message CreateMessage(MessageVersion version, string action, object body, XmlObjectSerializer serializer)
169static public Message CreateMessage(MessageVersion version, string action, XmlReader body)
174static public Message CreateMessage(MessageVersion version, string action, XmlDictionaryReader body)
184static public Message CreateMessage(MessageVersion version, string action, BodyWriter body)
193static internal Message CreateMessage(MessageVersion version, ActionHeader actionHeader, BodyWriter body)
202static public Message CreateMessage(MessageVersion version, string action)
209static internal Message CreateMessage(MessageVersion version, ActionHeader actionHeader)
216static public Message CreateMessage(XmlReader envelopeReader, int maxSizeOfHeaders, MessageVersion version)
221static public Message CreateMessage(XmlDictionaryReader envelopeReader, int maxSizeOfHeaders, MessageVersion version)
227Message message = new StreamedMessage(envelopeReader, maxSizeOfHeaders, version);
231static public Message CreateMessage(MessageVersion version, FaultCode faultCode, string reason, string action)
243static public Message CreateMessage(MessageVersion version, FaultCode faultCode, string reason, object detail, string action)
255static public Message CreateMessage(MessageVersion version, MessageFault fault, string action)
370internal void InitializeReply(Message request)
584Message.ReadFromBodyContentsToEnd(reader, this.Version.Envelope);
621Message.ReadFromBodyContentsToEnd(reader, envelopeVersion);
801Message message;
804public OnWriteBodyContentsAsyncResult(XmlDictionaryWriter writer, Message message, AsyncCallback callback, object state)
823Message message;
826public OnWriteMessageAsyncResult(XmlDictionaryWriter writer, Message message, AsyncCallback callback, object state)
934this.isFault = Message.IsFaultStartElement(reader, version);
1257return Message.ReadStartBody(reader, this.Version.Envelope, out this.isFault, out this.isEmpty);
System\ServiceModel\Channels\MessageEncoder.cs (13)
36public Message ReadMessage(Stream stream, int maxSizeOfHeaders)
41public abstract Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType);
43public Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager)
45Message message = ReadMessage(buffer, bufferManager, null);
49public abstract Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType);
87internal virtual Message ReadMessage(Stream stream, BufferManager bufferManager, int maxBufferSize, string contentType)
97public abstract void WriteMessage(Message message, Stream stream);
99public virtual IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state)
109public ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager)
115public abstract ArraySegment<byte> WriteMessage(Message message, int maxMessageSize,
205internal void ThrowIfMismatchedMessageVersion(Message message)
228Message message;
231public WriteMessageAsyncResult(Message message, Stream stream, MessageEncoder encoder, AsyncCallback callback, object state)
System\ServiceModel\Channels\MsmqDecodeHelper.cs (8)
61internal static Message DecodeTransportDatagram(MsmqInputChannelListener listener, MsmqReceiveHelper receiver, MsmqInputMessage msmqMessage, MsmqMessageProperty messageProperty)
126Message message = null;
245Message message = DecodeSessiongramMessage(listener, channel, encoder, messageProperty, incoming, offset, sessionDecoder.EnvelopeSize);
312static Message DecodeSessiongramMessage(
340Message message = null;
356internal static Message DecodeIntegrationDatagram(MsmqIntegrationChannelListener listener, MsmqReceiveHelper receiver, MsmqIntegrationInputMessage msmqMessage, MsmqMessageProperty messageProperty)
360Message message = Message.CreateMessage(MessageVersion.None, (string)null);
System\ServiceModel\Channels\MsmqInputSessionChannel.cs (8)
90public override Message Receive()
95public override Message Receive(TimeSpan timeout)
110public override bool TryReceive(TimeSpan timeout, out Message message)
141return new CompletedAsyncResult<bool, Message>(true, null, callback, state);
151public override bool EndTryReceive(IAsyncResult result, out Message message)
153CompletedAsyncResult<bool, Message> completedResult = result as CompletedAsyncResult<bool, Message>;
157return CompletedAsyncResult<bool, Message>.End(result, out message);
System\ServiceModel\Channels\MtomMessageEncoder.cs (16)
223public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType)
242Message message = new BufferedMessage(messageData, messageState);
258public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType)
272Message message = Message.CreateMessage(reader, maxSizeOfHeaders, version);
285public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
305internal ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset, string boundary)
310ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset, string startInfo, string boundary, string startUri, bool writeMessageHeaders)
363public override void WriteMessage(Message message, Stream stream)
368internal void WriteMessage(Message message, Stream stream, string boundary)
373public override IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state)
378internal IAsyncResult BeginWriteMessage(Message message, Stream stream, string boundary, AsyncCallback callback, object state)
388void WriteMessage(Message message, Stream stream, string startInfo, string boundary, string startUri, bool writeMessageHeaders)
740Message message;
744public WriteMessageAsyncResult(Message message, Stream stream, MtomMessageEncoder encoder, AsyncCallback callback, object state)
756public WriteMessageAsyncResult(Message message, Stream stream, string boundary, MtomMessageEncoder encoder, AsyncCallback callback, object state)
System\ServiceModel\Channels\OneWayChannelFactory.cs (18)
21public static void AddHeadersTo(Message message, MessageHeader header)
34public static void ValidateMessage(Message message)
43public static bool TryValidateMessage(Message message)
169protected override void AddHeadersTo(Message message)
179protected override void OnSend(Message message, TimeSpan timeout)
181Message response = this.innerChannel.Request(message, timeout);
188protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
195Message response = this.innerChannel.EndRequest(result);
202void ValidateResponse(Message response)
308protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
339protected override void OnSend(Message message, TimeSpan timeout)
345void StampMessage(Message message)
508protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
518protected override void OnSend(Message message, TimeSpan timeout)
567Message message = channel.EndReceive(result);
599void StampInitialMessage(Message message)
656Message message;
663public SendAsyncResult(DuplexSessionOutputChannel parent, Message message, TimeSpan timeout,
System\ServiceModel\Channels\OutputChannel.cs (9)
22public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
27public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
63protected abstract void OnSend(Message message, TimeSpan timeout);
65protected abstract IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state);
69public void Send(Message message)
74public void Send(Message message, TimeSpan timeout)
90protected virtual TraceRecord CreateSendTrace(Message message)
95void EmitTrace(Message message)
105protected virtual void AddHeadersTo(Message message)
System\ServiceModel\Channels\PeerFlooder.cs (12)
37abstract class PeerFlooderBase<TFloodContract, TLinkContract> : IFlooderForThrottle, IPeerFlooderContract<TFloodContract, TLinkContract> where TFloodContract : Message
195protected IAsyncResult BeginSendHelper(IPeerNeighbor neighbor, TimeSpan timeout, Message message, FloodAsyncResult fresult)
265Message fmessage = messageBuffer.CreateMessage();
312int UpdateHopCount(Message message, out MessageHeader hopHeader, out ulong currentValue)
351Message message = null;
388using (Message filterMessage = messageBuffer.CreateMessage())
557class PeerFlooderSimple : PeerFlooderBase<Message, UtilityInfo>
569public override bool ShouldProcess(Message message)
573public bool IsNotSeenBefore(Message message, out byte[] id, out int cacheHit)
619public override IAsyncResult OnFloodedMessage(IPeerNeighbor neighbor, Message floodInfo, AsyncCallback callback, object state)
953Message message = (Message)result.AsyncState;
System\ServiceModel\Channels\PeerNodeImplementation.cs (18)
26public delegate void MessageAvailableCallback(Message message);
344public Guid ProcessOutgoingMessage(Message message, Uri via)
365public void SecureOutgoingMessage(ref Message message, Uri via, TimeSpan timeout, SecurityProtocol securityProtocol)
373public IAsyncResult BeginSend(object registrant, Message message, Uri via,
381Message securedMessage = null;
418using (Message filterMessage = messageBuffer.CreateMessage())
452using (Message msg = messageBuffer.CreateMessage())
874bool IPeerNodeMessageHandling.ValidateIncomingMessage(ref Message message, Uri via)
918using (Message message = messageBuffer.CreateMessage())
932using (Message traceMessage = messageBuffer.CreateMessage())
940PeerMessagePropagation IPeerNodeMessageHandling.DetermineMessagePropagation(Message message, PeerMessageOrigination origination)
1353services.Add(typeof(IPeerFlooderContract<Message, UtilityInfo>), flooder);
1415Message message = null;
1472Message localCopy;
1881bool IPeerNodeMessageHandling.IsNotSeenBefore(Message message, out byte[] id, out int cacheMiss)
1902PeerMessagePropagation DetermineMessagePropagation(Message message, PeerMessageOrigination origination);
1904bool ValidateIncomingMessage(ref Message data, Uri via);
1906bool IsNotSeenBefore(Message message, out byte[] id, out int cacheMiss);
System\ServiceModel\Channels\PeerSecurityHelpers.cs (14)
117public static bool AuthenticateRequest(Claim claim, string password, Message message)
123public static bool AuthenticateResponse(Claim claim, string password, Message message)
150public override void SecureOutgoingMessage(ref Message message, TimeSpan timeout)
153public override void VerifyIncomingMessage(ref Message request, TimeSpan timeout)
523public static PeerHashToken CreateHashTokenFrom(Message message)
614public static PeerHashToken CreateHashTokenFrom(Message message)
759Message reply = null;
767Message request = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, TrustFeb2005Strings.RequestSecurityToken, new PeerRequestSecurityToken(token));
813public Message ProcessRst(Message message, Claim claim)
817Message reply = null;
842reply = Message.CreateMessage(MessageVersion.Soap12WSAddressing10, TrustFeb2005Strings.RequestSecurityTokenResponse, response);
855public void ProcessRstr(IPeerNeighbor neighbor, Message message, Claim claim)
System\ServiceModel\Channels\ReliableChannelBinder.cs (25)
198protected virtual void AddOutputHeaders(Message message)
263public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback,
269public IAsyncResult BeginSend(Message message, TimeSpan timeout, MaskingMode maskingMode,
674protected virtual IAsyncResult OnBeginSend(TChannel channel, Message message,
793protected virtual void OnSend(TChannel channel, Message message, TimeSpan timeout)
851public void Send(Message message, TimeSpan timeout)
856public void Send(Message message, TimeSpan timeout, MaskingMode maskingMode)
1064protected bool ValidateOutputOperation(Message message, TimeSpan timeout, MaskingMode maskingMode)
1085protected RequestContext WrapMessage(Message message)
1128public BinderRequestContext(ReliableChannelBinder<TChannel> binder, Message message)
3210public MessageRequestContext(ReliableChannelBinder<TChannel> binder, Message message)
3223protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
3233protected override void OnReply(Message message, TimeSpan timeout)
3246public ReplyAsyncResult(MessageRequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state)
3308Message message;
3329Message message, TimeSpan timeout, MaskingMode maskingMode, AsyncCallback callback,
3467public void Start(Message message, TimeSpan timeout, MaskingMode maskingMode)
3522RequestContext innerContext, Message message)
3543protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout,
3624protected override void OnReply(Message message, TimeSpan timeout)
3659TChannel channel, Message message, TimeSpan timeout, MaskingMode maskingMode,
3758Message message = null;
4178CloseInputSessionChannelAsyncResult<IDuplexSessionChannel, Message>
4206protected override void DisposeItem(Message item)
4216protected override bool EndTryInput(IAsyncResult result, out Message item)
System\ServiceModel\Channels\ReliableChannelListener.cs (29)
994Message faultReply;
1064protected abstract Message GetMessage(TItem item);
1068Message message = null;
1239protected abstract void SendReply(Message reply, TInnerChannel channel, TItem item);
1284ReliableListenerOverDatagram<TChannel, TReliableChannel, IDuplexChannel, Message>
1299protected override void DisposeItem(Message item)
1304protected override void EndTryReceiveItem(IDuplexChannel channel, IAsyncResult result, out Message item)
1309protected override Message GetMessage(Message item)
1314protected override void SendReply(Message reply, IDuplexChannel channel, Message item)
1348protected override Message GetMessage(RequestContext item)
1353protected override void SendReply(Message reply, IReplyChannel channel, RequestContext item)
1424protected abstract Message GetMessage(TItem item);
1442Message faultReply = null;
1572protected abstract void SendReply(Message reply, TInnerChannel channel, TItem item);
1576: ReliableListenerOverSession<TChannel, TReliableChannel, IDuplexSessionChannel, IDuplexSession, Message>
1591protected override void DisposeItem(Message item)
1596protected override void EndTryReceiveItem(IDuplexSessionChannel channel, IAsyncResult result, out Message item)
1601protected override Message GetMessage(Message item)
1606protected override void SendReply(Message reply, IDuplexSessionChannel channel, Message item)
1640protected override Message GetMessage(RequestContext item)
1645protected override void SendReply(Message reply, IReplySessionChannel channel, RequestContext item)
1673protected override void ProcessSequencedItem(ServerReliableDuplexSessionChannel channel, Message message, WsrmMessageInfo info)
1699protected override void ProcessSequencedItem(ReliableInputSessionChannelOverDuplex channel, Message message, WsrmMessageInfo info)
1725protected override void ProcessSequencedItem(IDuplexSessionChannel channel, Message message, ServerReliableDuplexSessionChannel reliableChannel, WsrmMessageInfo info, bool newChannel)
1764protected override void ProcessSequencedItem(IDuplexSessionChannel channel, Message message, ReliableInputSessionChannelOverDuplex reliableChannel, WsrmMessageInfo info, bool newChannel)
System\ServiceModel\Channels\ReliableDuplexSessionChannel.cs (19)
23DeliveryStrategy<Message> deliveryStrategy;
90void AddPendingAcknowledgements(Message message)
146Message CreateAcknowledgmentMessage()
153Message message = WsrmUtilities.CreateAcknowledgmentMessage(this.Settings.MessageVersion,
345Message message = null;
736using (Message message = CreateAcknowledgmentMessage())
865protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
943this.session.OnLocalFault(exception, (Message)null, null);
1109protected override void OnSend(Message message, TimeSpan timeout)
1164using (Message message = WsrmUtilities.CreateAckRequestedMessage(this.Settings.MessageVersion,
1232this.ReliableSession.OnLocalFault(e, (Message)null, null);
1237Message message = context.RequestMessage;
1278this.deliveryStrategy = new OrderedDeliveryStrategy<Message>(this, this.settings.MaxTransferWindowSize, false);
1280this.deliveryStrategy = new UnorderedDeliveryStrategy<Message>(this, this.settings.MaxTransferWindowSize);
1333Message message = WsrmUtilities.CreateTerminateMessage(this.settings.MessageVersion,
1360Message message = WsrmUtilities.CreateTerminateMessage(this.settings.MessageVersion,
1643using (Message message = WsrmUtilities.CreateAckRequestedMessage(this.Settings.MessageVersion,
1686Message message = WsrmUtilities.CreateAckRequestedMessage(this.Settings.MessageVersion,
1904Message response = WsrmUtilities.CreateCreateSequenceResponse(this.Settings.MessageVersion,
System\ServiceModel\Channels\ReliableInputSessionChannel.cs (16)
18DeliveryStrategy<Message> deliveryStrategy;
40this.deliveryStrategy = new OrderedDeliveryStrategy<Message>(this, listener.MaxTransferWindowSize, false);
42this.deliveryStrategy = new UnorderedDeliveryStrategy<Message>(this, listener.MaxTransferWindowSize);
80protected DeliveryStrategy<Message> DeliveryStrategy
169protected void AddAcknowledgementHeader(Message message)
210protected Message CreateAcknowledgmentMessage()
220Message message = WsrmUtilities.CreateAcknowledgmentMessage(
319this.session.OnLocalFault(exception, (Message)null, null);
487this.ReliableSession.OnLocalFault(e, (Message)null, null);
492Message message = context.RequestMessage;
523using (Message message = CreateAcknowledgmentMessage())
595Message response = WsrmUtilities.CreateCreateSequenceResponse(this.Listener.MessageVersion,
617Message message = null;
946this.ReliableSession.OnLocalFault(e, (Message)null, null);
1007Message response = WsrmUtilities.CreateCreateSequenceResponse(this.Listener.MessageVersion,
1034Message message = null;
System\ServiceModel\Channels\ReliableMessagingHelpers.cs (87)
652public static bool AddressReply(Message message, Message faultMessage)
683public abstract void SendFaultAsync(IReliableChannelBinder binder, RequestContext requestContext, Message faultMessage);
837protected abstract TState GetState(RequestContext requestContext, Message faultMessage);
941public override void SendFaultAsync(IReliableChannelBinder binder, RequestContext requestContext, Message faultMessage)
1029Message faultMessage;
1032public FaultState(RequestContext requestContext, Message faultMessage)
1038public Message FaultMessage { get { return this.faultMessage; } }
1071protected override FaultState GetState(RequestContext requestContext, Message faultMessage)
1078class SendFaultHelper : TypedFaultHelper<Message>
1085protected override void AbortState(Message message, bool isOnAbortThread)
1094protected override IAsyncResult BeginSendFault(IReliableChannelBinder binder, Message message,
1100protected override void EndSendFault(IReliableChannelBinder binder, Message message, IAsyncResult result)
1106protected override Message GetState(RequestContext requestContext, Message faultMessage)
1476Message CreateRequestMessage()
1478Message request = Message.CreateMessage(this.messageVersion, this.messageAction, this.messageBody);
1579protected abstract Message OnRequest(Message request, TimeSpan timeout, bool last);
1580protected abstract IAsyncResult OnBeginRequest(Message request, TimeSpan timeout,
1582protected abstract Message OnEndRequest(bool last, IAsyncResult result);
1584public Message Request(TimeSpan timeout)
1593Message request = null;
1594Message reply = null;
1648public Message EndRequest(IAsyncResult result)
1665bool ValidateReply(Message response)
1684Message request;
1686Message response;
1702public static Message End(IAsyncResult result)
1885Message GetReply(Message reply, bool last)
1907protected override Message OnRequest(Message request, TimeSpan timeout, bool last)
1912protected override IAsyncResult OnBeginRequest(Message request, TimeSpan timeout, AsyncCallback callback, object state)
1917protected override Message OnEndRequest(bool last, IAsyncResult result)
1960protected override Message OnRequest(Message request, TimeSpan timeout, bool last)
1972protected override IAsyncResult OnBeginRequest(Message request, TimeSpan timeout, AsyncCallback callback, object state)
1977protected override Message OnEndRequest(bool last, IAsyncResult result)
1992Message request;
1994Message response;
1997internal SendReceiveAsyncResult(SendReceiveReliableRequestor requestor, Message request, TimeSpan timeout,
2026public static Message End(IAsyncResult result)
2127Message request;
2147Message GetReply(bool last)
2177protected override Message OnRequest(Message request, TimeSpan timeout, bool last)
2186protected override IAsyncResult OnBeginRequest(Message request, TimeSpan timeout, AsyncCallback callback, object state)
2200protected override Message OnEndRequest(bool last, IAsyncResult result)
2287public Message Message
2439Message reply;
2451protected Message Reply
2456public static Message End(IAsyncResult result)
2462public static Message End(IAsyncResult result, out Exception handledException)
3068Message message, UniqueId id, SequenceRangeCollection ranges, bool final)
3074Message message, UniqueId id, SequenceRangeCollection ranges, bool final, int bufferRemaining)
3080internal static void AddAckRequestedHeader(ReliableMessagingVersion reliableMessagingVersion, Message message,
3086internal static void AddSequenceHeader(ReliableMessagingVersion reliableMessagingVersion, Message message,
3101internal static Message CreateAcknowledgmentMessage(MessageVersion version,
3105Message message = Message.CreateMessage(version,
3115internal static Message CreateAckRequestedMessage(MessageVersion messageVersion,
3118Message message = Message.CreateMessage(messageVersion,
3127internal static Message CreateCloseSequenceResponse(MessageVersion messageVersion, UniqueId messageId,
3132Message message = Message.CreateMessage(messageVersion,
3139internal static Message CreateCreateSequenceResponse(MessageVersion messageVersion,
3151Message responseMessage
3152= Message.CreateMessage(messageVersion, ActionHeader.Create(
3158internal static Message CreateCSRefusedCommunicationFault(MessageVersion messageVersion,
3164internal static Message CreateCSRefusedProtocolFault(MessageVersion messageVersion,
3170internal static Message CreateCSRefusedServerTooBusyFault(MessageVersion messageVersion,
3180static Message CreateCSRefusedFault(MessageVersion messageVersion,
3208return Message.CreateMessage(messageVersion, fault, action);
3212ReliableMessagingVersion reliableMessagingVersion, Message message, IChannel innerChannel)
3279internal static Message CreateEndpointNotFoundFault(MessageVersion version, string reason)
3299return Message.CreateMessage(version, fault, version.Addressing.DefaultFaultAction);
3302internal static Message CreateTerminateMessage(MessageVersion version,
3308internal static Message CreateTerminateMessage(MessageVersion version,
3311Message message = Message.CreateMessage(version,
3320internal static Message CreateTerminateResponseMessage(MessageVersion version, UniqueId messageId, UniqueId sequenceId)
3322Message message = Message.CreateMessage(version,
3523Message faultReply;
System\ServiceModel\Channels\ReliableOutputConnection.cs (8)
156Message message = Message.CreateMessage(this.MessageVersion, WsrmFeb2005Strings.LastMessageAction);
179public bool AddMessage(Message message, TimeSpan timeout, object state)
184public IAsyncResult BeginAddMessage(Message message, TimeSpan timeout, object state, AsyncCallback callback, object asyncState)
198Message message = Message.CreateMessage(this.MessageVersion, WsrmFeb2005Strings.LastMessageAction);
360bool InternalAddMessage(Message message, TimeSpan timeout, object state, bool isLast)
628public AddAsyncResult(Message message, bool isLast, TimeSpan timeout, object state,
System\ServiceModel\Channels\ReliableOutputSessionChannel.cs (30)
114Message closeReply = this.closeRequestor.Request(timeout);
126Message closeReply = this.closeRequestor.EndRequest(result);
255protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
286this.session.OnLocalFault(exception, (Message)null, null);
311protected abstract void OnConnectionSend(Message message, TimeSpan timeout, bool saveHandledException,
320using (Message message = WsrmUtilities.CreateAckRequestedMessage(this.settings.MessageVersion,
330Message request = WsrmUtilities.CreateAckRequestedMessage(this.settings.MessageVersion,
390protected abstract void OnConnectionSendMessage(Message message, TimeSpan timeout, MaskingMode maskingMode);
391protected abstract IAsyncResult OnConnectionBeginSendMessage(Message message, TimeSpan timeout,
448protected override void OnSend(Message message, TimeSpan timeout)
472using (Message request = WsrmUtilities.CreateAckRequestedMessage(this.Settings.MessageVersion,
479void ProcessCloseOrTerminateReply(bool close, Message reply)
522protected void ProcessMessage(Message message)
597Message response = WsrmUtilities.CreateTerminateResponseMessage(
675Message message = WsrmUtilities.CreateTerminateMessage(this.settings.MessageVersion,
682Message terminateReply = this.terminateRequestor.Request(timeout);
701Message message = WsrmUtilities.CreateTerminateMessage(this.settings.MessageVersion,
724Message terminateReply = this.terminateRequestor.EndRequest(result);
787protected override void OnConnectionSend(Message message, TimeSpan timeout,
791Message reply = null;
849Message reply = ReliableBinderRequestAsyncResult.End(result, out handledException);
860protected override void OnConnectionSendMessage(Message message, TimeSpan timeout, MaskingMode maskingMode)
862Message reply = this.binder.Request(message, timeout, maskingMode);
870protected override IAsyncResult OnConnectionBeginSendMessage(Message message, TimeSpan timeout,
884Message reply = ReliableBinderRequestAsyncResult.End(result);
924protected override void OnConnectionSend(Message message, TimeSpan timeout, bool saveHandledException, bool maskUnhandledException)
989protected override void OnConnectionSendMessage(Message message, TimeSpan timeout, MaskingMode maskingMode)
994protected override IAsyncResult OnConnectionBeginSendMessage(Message message, TimeSpan timeout,
1063Message requestMessage = context.RequestMessage;
1074this.ReliableSession.OnLocalFault(e, (Message)null, null);
System\ServiceModel\Channels\ReliableReplySessionChannel.cs (30)
164void AddAcknowledgementHeader(Message message)
232Message CreateAcknowledgement(SequenceRangeCollection ranges)
234Message message = WsrmUtilities.CreateAcknowledgmentMessage(
245Message CreateSequenceClosedFault()
247Message message = new SequenceClosedFault(this.session.InputID).CreateMessage(
392this.session.OnLocalFault(e, (Message)null, null);
474this.session.OnLocalFault(exception, (Message)null, null);
484this.session.OnLocalFault(exception, (Message)null, null);
631Message PrepareReplyMessage(Int64 replySequenceNumber, bool isLast, SequenceRangeCollection ranges, Message reply)
690using (Message reply = CreateAcknowledgement(this.connection.Ranges))
808Message message = WsrmUtilities.CreateTerminateMessage(this.MessageVersion,
920Message response = WsrmUtilities.CreateCreateSequenceResponse(this.listener.MessageVersion,
1043Message message = null;
1180Message message = null;
1402internal IAsyncResult BeginReplyInternal(Message reply, TimeSpan timeout, AsyncCallback callback, object state)
1504this.channel.session.OnLocalFault(e, (Message)null, null);
1508protected override IAsyncResult OnBeginReply(Message reply, TimeSpan timeout, AsyncCallback callback, object state)
1525protected override void OnReply(Message reply, TimeSpan timeout)
1530internal void ReplyInternal(Message reply, TimeSpan timeout)
1594this.bufferedReply = Message.CreateMessage(this.channel.MessageVersion, WsrmFeb2005Strings.LastMessageAction).CreateBufferedCopy(int.MaxValue);
1605Message reply;
1647Message reply;
1744Message asyncMessage;
1796using (Message message = this.replyProvider.Provide(this.channel, info))
1950internal abstract Message Provide(ReliableReplySessionChannel channel, WsrmMessageInfo info);
1974internal override Message Provide(ReliableReplySessionChannel channel, WsrmMessageInfo requestInfo)
1976Message message = WsrmUtilities.CreateCloseSequenceResponse(channel.MessageVersion,
2004internal override Message Provide(ReliableReplySessionChannel channel, WsrmMessageInfo requestInfo)
2006Message message = WsrmUtilities.CreateTerminateResponseMessage(channel.MessageVersion,
System\ServiceModel\Channels\ReliableRequestSessionChannel.cs (24)
66void AddAcknowledgementHeader(Message message, bool force)
91Message closeReply = this.closeRequestor.Request(timeout);
103Message closeReply = this.closeRequestor.EndRequest(result);
117Message CreateAckRequestedMessage()
119Message request = WsrmUtilities.CreateAckRequestedMessage(this.settings.MessageVersion,
125protected override IAsyncRequest CreateAsyncRequest(Message message, AsyncCallback callback, object state)
147protected override IRequest CreateRequest(Message message)
177Message terminateReply = this.terminateRequestor.EndRequest(result);
308this.session.OnLocalFault(exception, (Message)null, null);
381Message reply = ReliableBinderRequestAsyncResult.End(result, out handledException);
414Message reply = null;
548void ProcessCloseOrTerminateReply(bool close, Message reply)
610void ProcessReply(Message reply, IReliableRequest request, Int64 requestSequenceNumber)
786Message reply = ReliableBinderRequestAsyncResult.End(result);
797Message terminateReply = this.terminateRequestor.Request(timeout);
880void Set(Message reply);
891Message reply;
942public void SendRequest(Message message, TimeSpan timeout)
949public void Set(Message reply)
970public Message WaitForReply(TimeSpan timeout)
1051Message reply;
1107public void BeginSendRequest(Message message, TimeSpan timeout)
1120public Message End()
1126public void Set(Message reply)
System\ServiceModel\Channels\RequestChannel.cs (16)
212public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state)
217public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
249protected abstract IRequest CreateRequest(Message message);
250protected abstract IAsyncRequest CreateAsyncRequest(Message message, AsyncCallback callback, object state);
252public Message EndRequest(IAsyncResult result)
268Message reply = asyncRequest.End();
284public Message Request(Message message)
289public Message Request(Message message, TimeSpan timeout)
307Message reply;
348protected virtual void AddHeadersTo(Message message)
447void SendRequest(Message message, TimeSpan timeout);
448Message WaitForReply(TimeSpan timeout);
453void BeginSendRequest(Message message, TimeSpan timeout);
454Message End();
System\ServiceModel\Channels\RequestContextBase.cs (11)
18Message requestMessage;
25protected RequestContextBase(Message requestMessage, TimeSpan defaultCloseTimeout, TimeSpan defaultSendTimeout)
32public void ReInitialize(Message requestMessage)
42public override Message RequestMessage
56protected void SetRequestMessage(Message requestMessage)
194protected abstract void OnReply(Message message, TimeSpan timeout);
195protected abstract IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state);
232public override IAsyncResult BeginReply(Message message, AsyncCallback callback, object state)
237public override IAsyncResult BeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
255public override void Reply(Message message)
260public override void Reply(Message message, TimeSpan timeout)
System\ServiceModel\Channels\SecurityChannelFactory.cs (29)
344protected bool TryGetSecurityFaultException(Message faultMessage, out Exception faultException)
547public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
552public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
564public void Send(Message message)
569public void Send(Message message, TimeSpan timeout)
602public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state)
607public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
614public Message EndRequest(IAsyncResult result)
619public Message Request(Message message)
624internal Message ProcessReply(Message reply, SecurityProtocolCorrelationState correlationState, TimeSpan timeout)
653Message unverifiedMessage = reply;
677public Message Request(Message message, TimeSpan timeout)
683Message reply = this.InnerChannel.Request(message, timeoutHelper.RemainingTime());
729public Message Receive()
734public Message Receive(TimeSpan timeout)
749public Message EndReceive(IAsyncResult result)
767public virtual bool EndTryReceive(IAsyncResult result, out Message message)
778internal Message ProcessMessage(Message message, TimeSpan timeout)
784Message unverifiedMessage = message;
810public bool TryReceive(TimeSpan timeout, out Message message)
866Message reply;
869public RequestChannelSendAsyncResult(Message message, SecurityProtocol protocol, IRequestChannel channel, SecurityRequestChannel securityChannel, TimeSpan timeout,
877protected override IAsyncResult BeginSendCore(IRequestChannel channel, Message message, TimeSpan timeout, AsyncCallback callback, object state)
882internal static Message End(IAsyncResult result)
910protected override bool OnInnerReceiveDone(ref Message message, TimeSpan timeout)
System\ServiceModel\Channels\SecurityChannelListener.cs (65)
787void ThrowIfSecureConversationCloseMessage(Message message)
798IDisposable ApplyHostingIntegrationContext(Message message)
812internal SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout, params SecurityProtocolCorrelationState[] correlationState)
828internal void VerifyIncomingMessage(ref Message message, TimeSpan timeout)
906public Message Receive()
911public Message Receive(TimeSpan timeout)
926public Message EndReceive(IAsyncResult result)
941public virtual bool EndTryReceive(IAsyncResult result, out Message message)
952public virtual bool TryReceive(TimeSpan timeout, out Message message)
1046public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
1051public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1063public void Send(Message message)
1068public void Send(Message message, TimeSpan timeout)
1098void SendFaultIfRequired(Exception e, Message unverifiedMessage, TimeSpan timeout)
1111using (Message faultMessage = Message.CreateMessage(unverifiedMessage.Version, fault, unverifiedMessage.Version.Addressing.DefaultFaultAction))
1129public override bool TryReceive(TimeSpan timeout, out Message message)
1151Message unverifiedMessage = message;
1186public override bool EndTryReceive(IAsyncResult result, out Message message)
1270Message message = requestContext.RequestMessage;
1290Message requestMessage = innerContext.RequestMessage;
1291Message faultMessage = Message.CreateMessage(requestMessage.Version, fault, requestMessage.Version.Addressing.DefaultFaultAction);
1400public SecurityRequestContext(Message requestMessage, RequestContext innerContext,
1420protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1445protected override void OnReply(Message message, TimeSpan timeout)
1457public RequestContextSendAsyncResult(Message message, SecurityProtocol protocol, RequestContext context, TimeSpan timeout,
1464protected override IAsyncResult BeginSendCore(RequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state)
1496Message faultMessage;
1545protected abstract Message CreateFaultMessage(MessageFault fault, TItem innerItem);
1546protected abstract IAsyncResult BeginSendFault(TItem innerItem, Message faultMessage, TimeSpan timeout, AsyncCallback callback, object state);
1690bool SendFault(Message faultMessage, Exception e)
1843protected override Message CreateFaultMessage(MessageFault fault, RequestContext innerItem)
1845Message requestMessage = innerItem.RequestMessage;
1846Message faultMessage = Message.CreateMessage(requestMessage.Version, fault, requestMessage.Version.Addressing.DefaultFaultAction);
1852protected override IAsyncResult BeginSendFault(RequestContext innerItem, Message faultMessage, TimeSpan timeout, AsyncCallback callback, object state)
1870sealed class DuplexSessionReceiveMessageAndVerifySecurityAsyncResult : ReceiveItemAndVerifySecurityAsyncResult<Message, IInputChannel>
1902protected override void AbortInnerItem(Message innerItem)
1906protected override void CloseInnerItem(Message innerItem, TimeSpan timeout)
1916protected override bool EndTryReceiveItem(IAsyncResult result, out Message innerItem)
1921protected override Message ProcessInnerItem(Message innerItem, TimeSpan timeout)
1927Message item = innerItem;
1932protected override Message CreateFaultMessage(MessageFault fault, Message innerItem)
1934Message faultMessage = Message.CreateMessage(innerItem.Version, fault, innerItem.Version.Addressing.DefaultFaultAction);
1940protected override IAsyncResult BeginSendFault(Message innerItem, Message faultMessage, TimeSpan timeout, AsyncCallback callback, object state)
1945protected override void EndSendFault(Message innerItem, IAsyncResult result)
1950public static bool End(IAsyncResult result, out Message message)
1959sealed class InputChannelReceiveMessageAndVerifySecurityAsyncResult : ReceiveItemAndVerifySecurityAsyncResult<Message, IInputChannel>
1996protected override void AbortInnerItem(Message innerItem)
2000protected override void CloseInnerItem(Message innerItem, TimeSpan timeout)
2010protected override bool EndTryReceiveItem(IAsyncResult result, out Message innerItem)
2015protected override Message ProcessInnerItem(Message innerItem, TimeSpan timeout)
2021Message item = innerItem;
2026protected override Message CreateFaultMessage(MessageFault fault, Message innerItem)
2031protected override IAsyncResult BeginSendFault(Message innerItem, Message faultMessage, TimeSpan timeout, AsyncCallback callback, object state)
2036protected override void EndSendFault(Message innerItem, IAsyncResult result)
2041public static bool End(IAsyncResult result, out Message message)
System\ServiceModel\Channels\ServiceChannel.cs (16)
932internal void FireUnknownMessageReceived(Message message)
1077void ThrowIfFaultUnderstood(Message reply, MessageFault fault, string action, MessageVersion version, FaultConverter faultConverter)
1244void AddMessageProperties(Message message, OperationContext context)
1273public void Send(Message message)
1278public void Send(Message message, TimeSpan timeout)
1284public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
1289public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1300public Message Request(Message message)
1305public Message Request(Message message, TimeSpan timeout)
1308return (Message)this.Call(message.Headers.Action, false, operation, new object[] { message }, EmptyArray<object>.Instance, timeout);
1311public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state)
1316public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1322public Message EndRequest(IAsyncResult result)
1324return (Message)this.EndCall(MessageHeaders.WildcardAction, EmptyArray<object>.Instance, result);
System\ServiceModel\Channels\SessionConnectionReader.cs (18)
406protected override void PrepareMessage(Message message)
1009protected override Message DecodeMessage(byte[] buffer, ref int offset, ref int size, ref bool isAtEof, TimeSpan timeout)
1054Message message = null;
1085protected override void PrepareMessage(Message message)
1114Message pendingMessage;
1138Message DecodeMessage(TimeSpan timeout)
1158protected abstract Message DecodeMessage(byte[] buffer, ref int offset, ref int size, ref bool isAtEof, TimeSpan timeout);
1278public Message Receive(TimeSpan timeout)
1280Message message = GetPendingMessage();
1336public Message EndReceive()
1341Message GetPendingMessage()
1352Message message = pendingMessage;
1377Message message = EndReceive();
1396Message message = Receive(timeout);
1444Message message = DecodeMessage(this.readTimeoutHelper.RemainingTime());
1486protected virtual void PrepareMessage(Message message)
1560protected override Message DecodeMessage(byte[] buffer, ref int offset, ref int size, ref bool isAtEOF, TimeSpan timeout)
1603Message message = null;
System\ServiceModel\Channels\SingletonConnectionReader.cs (15)
1017protected override void PrepareMessage(Message message)
1166protected virtual void PrepareMessage(Message message)
1174Message requestMessage = Receive(timeout);
1183public virtual Message EndReceive(IAsyncResult result)
1188public Message Receive(TimeSpan timeout)
1241Message message = null;
1268Message message;
1283public static Message End(IAsyncResult result)
1318public StreamedFramingRequestContext(SingletonConnectionReader parent, Message requestMessage)
1336protected override void OnReply(Message message, TimeSpan timeout)
1349protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1610public static void WriteMessage(Message message, IConnection connection, bool isRequest,
1661public static IAsyncResult BeginWriteMessage(Message message, IConnection connection, bool isRequest,
1716Message message;
1727public WriteMessageAsyncResult(Message message, IConnection connection, bool isRequest,
System\ServiceModel\Channels\TextMessageEncoder.cs (10)
406public override Message ReadMessage(ArraySegment<byte> buffer, BufferManager bufferManager, string contentType)
416Message message;
442public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType)
453Message message = Message.CreateMessage(reader, maxSizeOfHeaders, version);
466public override ArraySegment<byte> WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
510public override void WriteMessage(Message message, Stream stream)
549public override IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state)
570Message message;
575public WriteMessageAsyncResult(Message message, Stream stream, TextMessageEncoder textEncoder, AsyncCallback callback, object state)
System\ServiceModel\Channels\TransactionChannel.cs (12)
23void WriteTransactionDataToMessage(Message message, MessageDirection direction);
24void ReadTransactionDataFromMessage(Message message, MessageDirection direction);
27void ReadIssuedTokens(Message message, MessageDirection direction);
28void WriteIssuedTokens(Message message, MessageDirection direction);
98void FaultOnMessage(Message message, string reason, string codeString)
105ICollection<RequestSecurityTokenResponse> GetIssuedTokens(Message message)
110public void ReadIssuedTokens(Message message, MessageDirection direction)
130void ReadTransactionFromMessage(Message message, TransactionFlowOption txFlowOption)
153public virtual void ReadTransactionDataFromMessage(Message message, MessageDirection direction)
164public void WriteTransactionDataToMessage(Message message, MessageDirection direction)
180void WriteTransactionToMessage(Message message, TransactionFlowOption txFlowOption)
201public void WriteIssuedTokens(Message message, MessageDirection direction)
System\ServiceModel\Channels\TransactionChannelFactory.cs (13)
241public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
246public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback asyncCallback, object state)
259public void Send(Message message)
264public void Send(Message message, TimeSpan timeout)
298public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state)
303public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback asyncCallback, object state)
310public Message EndRequest(IAsyncResult result)
312Message reply = InnerChannel.EndRequest(result);
318public Message Request(Message message)
323public Message Request(Message message, TimeSpan timeout)
327Message reply = InnerChannel.Request(message, timeoutHelper.RemainingTime());
System\ServiceModel\Channels\TransactionChannelListener.cs (16)
203protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
238protected override void OnReply(Message message, TimeSpan timeout)
278public Message Receive()
283public Message Receive(TimeSpan timeout)
298public Message EndReceive(IAsyncResult result)
308public virtual bool EndTryReceive(IAsyncResult asyncResult, out Message message)
323public virtual bool TryReceive(TimeSpan timeout, out Message message)
417Message reply = Message.CreateMessage(innerContext.RequestMessage.Version, fault.CreateMessageFault(), faultAction);
535public override void ReadTransactionDataFromMessage(Message message, MessageDirection direction)
543Message reply = Message.CreateMessage(message.Version, fault.CreateMessageFault(), fault.Action);
561public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
566public virtual IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback asyncCallback, object state)
578public void Send(Message message)
583public virtual void Send(Message message, TimeSpan timeout)
System\ServiceModel\Channels\TransmissionStrategy.cs (15)
17readonly Message message;
22public MessageAttemptInfo(Message message, Int64 sequenceNumber, int retryCount, object state)
29public Message Message
208public bool Add(Message message, TimeSpan timeout, object state, out MessageAttemptInfo attemptInfo)
213public MessageAttemptInfo AddLast(Message message, TimeSpan timeout, object state)
226MessageAttemptInfo AddToWindow(Message message, bool isLast, object state)
256public IAsyncResult BeginAdd(Message message, TimeSpan timeout, object state, AsyncCallback callback, object asyncState)
261public IAsyncResult BeginAddLast(Message message, TimeSpan timeout, object state, AsyncCallback callback, object asyncState)
468bool InternalAdd(Message message, bool isLast, TimeSpan timeout, object state, out MessageAttemptInfo attemptInfo)
500IAsyncResult InternalBeginAdd(Message message, bool isLast, TimeSpan timeout, object state, AsyncCallback callback, object asyncState)
851public AsyncQueueAdder(Message message, bool isLast, TimeSpan timeout, object state, TransmissionStrategy strategy, AsyncCallback callback, object asyncState)
962public void Add(Message message, Int64 addTime, object state)
997public Message GetMessage(int index)
1089public TransmissionInfo(Message message, Int64 lastAttemptTime, object state)
1108public WaitQueueAdder(TransmissionStrategy strategy, Message message, bool isLast, object state)
System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (23)
104public Message Receive()
109public Message Receive(TimeSpan timeout)
111Message message = null;
170public Message EndReceive(IAsyncResult result)
186Message message = null;
214public bool EndTryReceive(IAsyncResult result, out Message message)
219public bool TryReceive(TimeSpan timeout, out Message message)
438protected virtual void OnReceiveMessage(Message message)
450protected void ApplyChannelBinding(Message message)
455protected virtual void PrepareMessage(Message message)
493protected abstract AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, WaitCallback callback, object state);
501protected abstract ArraySegment<byte> EncodeMessage(Message message);
503protected abstract void OnSendCore(Message message, TimeSpan timeout);
505protected abstract AsyncCompletionResult StartWritingStreamedMessage(Message message, TimeSpan timeout, WaitCallback callback, object state);
507protected override void OnSend(Message message, TimeSpan timeout)
552protected override IAsyncResult OnBeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
577Message message = this.MessageSource.Receive(timeout);
837Message message = this.channel.messageSource.EndReceive(result);
1037Message message;
1043public SendAsyncResult(TransportDuplexSessionChannel channel, Message message, TimeSpan timeout, bool streamedOutput, AsyncCallback callback, object state)
1159Message message = this.message;
1229Message message;
1264public static bool End(IAsyncResult result, out Message message)
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (16)
204protected override AsyncCompletionResult StartWritingBufferedMessage(Message message, ArraySegment<byte> messageData, bool allowOutputBatching, TimeSpan timeout, Threading.WaitCallback callback, object state)
259protected override AsyncCompletionResult StartWritingStreamedMessage(Message message, TimeSpan timeout, WaitCallback callback, object state)
314protected override void OnSendCore(Message message, TimeSpan timeout)
371protected override ArraySegment<byte> EncodeMessage(Message message)
447static WebSocketMessageType GetWebSocketMessageType(Message message)
492Message pendingMessage;
590public Message EndReceive()
602Message message = this.GetPendingMessage();
614public Message Receive(TimeSpan timeout)
626Message message = this.GetPendingMessage();
763Message message = this.EndReceive();
784Message message = this.Receive(timeout);
949Message GetPendingMessage()
955Message pendingMessage = this.pendingMessage;
963Message PrepareMessage(WebSocketReceiveResult result, byte[] buffer, int count)
967Message message;
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 (21)
26Message faultReply;
27Message message;
120public Message FaultReply
137public Message Message
209public static Exception CreateInternalFaultException(Message faultReply, string message, Exception inner)
218Message faultReply = new WsrmRequiredFault(faultReason).CreateMessage(messageVersion,
226ReliableMessagingVersion reliableMessagingVersion, IChannel channel, ISession session, Message message)
232ReliableMessagingVersion reliableMessagingVersion, IChannel channel, ISession session, Message message,
667static void ValidateMustUnderstand(MessageVersion version, Message message)
680Message faultReply;
687public InternalFaultException(Message faultReply, string message, Exception inner)
698public Message FaultReply
745public static CloseSequenceInfo ReadMessage(MessageVersion messageVersion, Message message,
797public static CloseSequenceResponseInfo ReadMessage(MessageVersion messageVersion, Message message,
901Message message, MessageHeaders headers)
907Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
924Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason);
955Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion,
1005ReliableMessagingVersion reliableMessagingVersion, Message message, MessageHeaders headers)
1072ReliableMessagingVersion reliableMessagingVersion, Message message, MessageHeaders headers)
1127public static TerminateSequenceResponseInfo ReadMessage(MessageVersion messageVersion, Message message,
System\ServiceModel\ClientBase.cs (11)
1363void IOutputChannel.Send(Message message)
1368void IOutputChannel.Send(Message message, TimeSpan timeout)
1373IAsyncResult IOutputChannel.BeginSend(Message message, AsyncCallback callback, object state)
1378IAsyncResult IOutputChannel.BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1398Message IRequestChannel.Request(Message message)
1403Message IRequestChannel.Request(Message message, TimeSpan timeout)
1408IAsyncResult IRequestChannel.BeginRequest(Message message, AsyncCallback callback, object state)
1413IAsyncResult IRequestChannel.BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1418Message IRequestChannel.EndRequest(IAsyncResult result)
System\ServiceModel\ComIntegration\ComPlusDiagnosticTraceRecords.cs (2)
135public static void Trace(TraceEventType type, int traceCode, string description, ServiceInfo info, Message message, Guid incomingTransactionID)
149public static void Trace(TraceEventType type, int traceCode, string description, ServiceInfo info, Message message, int instanceID, Guid incomingTransactionID)
System\ServiceModel\Description\ServiceMetadataExtension.cs (28)
195internal static bool TryGetHttpHostAndPort(Uri listenUri, Message request, out string host, out int port)
465WriteFilter GetWriteFilter(Message request, Uri listenUri, bool removeBaseAddress)
488DynamicAddressUpdateWriter GetDynamicAddressWriter(Message request, Uri listenUri, bool removeBaseAddress)
601public Message Get(Message request)
614public IAsyncResult BeginGet(Message request, AsyncCallback callback, object state)
619public Message EndGet(IAsyncResult result)
630Message Get(Message msg);
719bool TryHandleDocumentationRequest(Message httpGetRequest, string[] queries, out Message replyMessage)
816bool TryHandleHealthRequest(Message httpGetRequest, string[] queries, out Message replyMessage)
837bool TryHandleMetadataRequest(Message httpGetRequest, string[] queries, out Message replyMessage)
955Message CreateDiscoMessage(DynamicAddressUpdateWriter addressUpdater)
1007Message ProcessHttpRequest(Message httpGetRequest)
1019Message replyMessage = null;
1033public object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext)
1038public void BeforeSendReply(ref Message reply, object correlationState)
1060public Message Get(Message message)
1288static void AddHttpProperty(Message message, HttpStatusCode status, string contentType)
1296static Message CreateRedirectMessage(string redirectedDestination)
1298Message redirectMessage = CreateHttpResponseMessage(HttpStatusCode.RedirectKeepVerb);
1304static Message CreateHttpResponseMessage(HttpStatusCode code)
1306Message message = new NullMessage();
System\ServiceModel\Diagnostics\SecurityTraceRecordHelper.cs (10)
144internal static void TraceServiceSecurityNegotiationCompleted<T>(Message message, NegotiationTokenAuthenticator<T> authenticator, SecurityContextSecurityToken serviceToken)
272internal static void TraceOutgoingMessageSecured(SecurityProtocol binding, Message message)
287internal static void TraceIncomingMessageVerified(SecurityProtocol binding, Message message)
302internal static void TraceSecureOutgoingMessageFailure(SecurityProtocol binding, Message message)
311internal static void TraceVerifyIncomingMessageFailure(SecurityProtocol binding, Message message)
434internal static void TraceSessionRenewalFaultSent(SecurityContextSecurityToken sessionToken, Uri listenAddress, Message message)
713Message message;
724public ServerSessionTraceRecord(SecurityContextSecurityToken currentSessionToken, Message message, Uri listenAddress)
877Message message;
879public MessageSecurityTraceRecord(SecurityProtocol binding, Message message)
System\ServiceModel\Diagnostics\TraceUtility.cs (22)
484static internal void AddActivityHeader(Message message)
503static internal void AddAmbientActivityToMessage(Message message)
522static internal void CopyActivity(Message source, Message destination)
540internal static ServiceModelActivity ExtractActivity(Message message)
576internal static Guid ExtractActivityId(Message message)
600internal static ServiceModelActivity ExtractAndRemoveActivity(Message message)
612internal static void ProcessIncomingMessage(Message message, EventTraceActivity eventTraceActivity)
639internal static void ProcessOutgoingMessage(Message message, EventTraceActivity eventTraceActivity)
659internal static void SetActivity(Message message, ServiceModelActivity activity)
667internal static void TraceDroppedMessage(Message message, EndpointDispatcher dispatcher)
701internal static void TraceEvent(TraceEventType severity, int traceCode, string traceDescription, Message message)
713internal static void TraceEvent(TraceEventType severity, int traceCode, string traceDescription, object source, Message message)
722internal static void TraceEvent(TraceEventType severity, int traceCode, string traceDescription, Exception exception, Message message)
748internal static void TraceEvent(TraceEventType severity, int traceCode, string traceDescription, TraceRecord extendedData, object source, Exception exception, Message message)
816internal static Exception ThrowHelperError(Exception exception, Message message)
838internal static Exception ThrowHelperWarning(Exception exception, Message message)
849internal static ArgumentException ThrowHelperArgument(string paramName, string message, Message msg)
854internal static ArgumentNullException ThrowHelperArgumentNull(string paramName, Message message)
1018static internal void MessageFlowAtMessageSent(Message message, EventTraceActivity eventTraceActivity)
1041static internal void MessageFlowAtMessageReceived(Message message, OperationContext context, EventTraceActivity eventTraceActivity, bool createNewActivityId)
1097internal static void TransferFromTransport(Message message)
System\ServiceModel\Dispatcher\ChannelHandler.cs (16)
400Message message;
517Message message = Message.CreateMessage(this.Binder.Channel.GetProperty<MessageVersion>(), OperationDescription.SessionOpenedAction);
645ServiceChannel GetDatagramChannel(Message message, out EndpointDispatcher endpoint, out bool addressMatched)
670EndpointDispatcher GetEndpointDispatcher(Message message, out bool addressMatched)
675ServiceChannel GetSessionChannel(Message message, out EndpointDispatcher endpoint, out bool addressMatched)
1192Message fault = Message.CreateMessage(this.messageVersion, code, reason, action);
1204Message fault = Message.CreateMessage(this.messageVersion, code, reason, action);
1208void ReplyFailure(RequestContext request, Message fault, string action, string reason, FaultCode code)
1253Message reply = faultInfo.Fault;
1309bool PrepareReply(RequestContext request, Message reply)
1320Message requestMessage = null;
2057EventTraceActivity TraceDispatchMessageStart(Message message)
2080public Message Reply;
System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (39)
268internal bool HandleRequestAsReply(Message message)
289bool HandleRequestAsReplyCore(Message message)
332Message message;
353public RequestContext CreateRequestContext(Message message)
358public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
368public void Send(Message message, TimeSpan timeout)
373public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
414public Message EndRequest(IAsyncResult result)
433Message message;
454public Message Request(Message message, TimeSpan timeout)
493Message reply;
548void RequestStarting(Message message, IDuplexRequest request)
638void EnsureIncomingIdentity(SecurityMessageProperty property, EndpointAddress address, Message reply)
643void ThrowIfInvalidReplyIdentity(Message reply)
677internal DuplexRequestContext(IDuplexChannel channel, Message request, DuplexChannelBinder binder)
692protected override void OnReply(Message message, TimeSpan timeout)
700protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
715public ReplyAsyncResult(DuplexRequestContext context, Message message, TimeSpan timeout, AsyncCallback callback, object state)
773void GotReply(Message reply);
778Message reply;
808internal Message WaitForReply(TimeSpan timeout)
826public void GotReply(Message reply)
872Message reply;
879internal AsyncDuplexRequest(Message message, DuplexChannelBinder parent, TimeSpan timeout, AsyncCallback callback, object state)
1018internal Message End()
1025public void GotReply(Message reply)
1104InputQueue<Message> pendingMessages;
1111this.pendingMessages = new InputQueue<Message>();
1270Message message = null;
1387public Message Receive()
1392public Message Receive(TimeSpan timeout)
1407public Message EndReceive(IAsyncResult result)
1412public bool TryReceive(TimeSpan timeout, out Message message)
1422public bool EndTryReceive(IAsyncResult result, out Message message)
1546public void Send(Message message)
1551public void Send(Message message, TimeSpan timeout)
1556public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
1561public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Dispatcher\EndpointAddressMessageFilterTable.cs (14)
337Candidate InnerMatch(Message message)
370Candidate GetSingleMatch(CandidateSet cset, Message message)
420void InnerMatchData(Message message, ICollection<TFilterData> results)
437void InnerMatchData(Message message, ICollection<TFilterData> results, CandidateSet cset)
454protected void InnerMatchFilters(Message message, ICollection<MessageFilter> results)
471void InnerMatchFilters(Message message, ICollection<MessageFilter> results, CandidateSet cset)
488public bool GetMatchingValue(Message message, out TFilterData data)
513Message msg = messageBuffer.CreateMessage();
534public bool GetMatchingValues(Message message, ICollection<TFilterData> results)
563Message msg = messageBuffer.CreateMessage();
576public bool GetMatchingFilter(Message message, out MessageFilter filter)
601Message msg = messageBuffer.CreateMessage();
622public bool GetMatchingFilters(Message message, ICollection<MessageFilter> results)
651Message msg = messageBuffer.CreateMessage();
System\ServiceModel\Dispatcher\ErrorBehavior.cs (7)
40rpc.FaultInfo.Fault = Message.CreateMessage(rpc.RequestVersion, messageFault, action);
93faultInfo.Fault = Message.CreateMessage(this.messageVersion, fault, action);
129Message m = faultInfo.Fault;
142Message faultMessage;
154faultInfo.Fault = Message.CreateMessage(this.messageVersion, MessageFault.CreateFault(ndfe.Code, ndfe.Reason, detail), ndfe.Action);
158faultInfo.Fault = Message.CreateMessage(this.messageVersion, ndfe.CreateMessageFault(), ndfe.Action);
243internal static void ThrowAndCatch(Exception e, Message message)
System\ServiceModel\Dispatcher\InputChannelBinder.cs (13)
75Message message;
88public RequestContext CreateRequestContext(Message message)
93public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
103public void Send(Message message, TimeSpan timeout)
110Message message;
123public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
128public Message EndRequest(IAsyncResult result)
133public Message Request(Message message, TimeSpan timeout)
153RequestContext WrapMessage(Message message)
169internal InputRequestContext(Message request, InputChannelBinder binder)
183protected override void OnReply(Message message, TimeSpan timeout)
187protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Dispatcher\OperationFormatter.cs (14)
52protected abstract void AddHeadersToMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest);
54protected abstract void GetHeadersFromMessage(Message message, MessageDescription messageDescription, object[] parameters, bool isRequest);
105public object DeserializeReply(Message message, object[] parameters)
173public void DeserializeRequest(Message message, object[] parameters)
227object DeserializeBodyContents(Message message, object[] parameters, bool isRequest)
257public Message SerializeRequest(MessageVersion messageVersion, object[] parameters)
278Message msg = new OperationFormatterMessage(this, messageVersion,
287public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result)
319Message msg = new OperationFormatterMessage(this, messageVersion,
418void AddPropertiesToMessage(Message message, MessageDescription messageDescription, object[] parameters)
426void AddPropertiesToMessageCore(Message message, MessageDescription messageDescription, object[] parameters)
439void GetPropertiesFromMessage(Message message, MessageDescription messageDescription, object[] parameters)
447void GetPropertiesFromMessageCore(Message message, MessageDescription messageDescription, object[] parameters)
778public override Message CreateMessage()
System\ServiceModel\Dispatcher\PrimitiveOperationFormatter.cs (6)
389public Message SerializeRequest(MessageVersion messageVersion, object[] parameters)
397return Message.CreateMessage(messageVersion, GetActionHeader(messageVersion.Addressing), new PrimitiveRequestBodyWriter(parameters, this));
400public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result)
408return Message.CreateMessage(messageVersion, GetReplyActionHeader(messageVersion.Addressing), new PrimitiveResponseBodyWriter(parameters, result, this));
411public object DeserializeReply(Message message, object[] parameters)
451public void DeserializeRequest(Message message, object[] parameters)
System\ServiceModel\Security\AcceptorSessionSymmetricMessageSecurityProtocol.cs (7)
142protected override IAsyncResult BeginSecureOutgoingMessageCore(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state)
149return new CompletedAsyncResult<Message>(message, callback, state);
152protected override SecurityProtocolCorrelationState SecureOutgoingMessageCore(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
162protected override void EndSecureOutgoingMessageCore(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState)
164message = CompletedAsyncResult<Message>.End(result);
168void SetUpDelayedSecurityExecution(ref Message message, SecurityToken signingToken, SecurityToken encryptionToken,
184protected override SecurityProtocolCorrelationState VerifyIncomingMessageCore(ref Message message, string actor, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates)
System\ServiceModel\Security\AsymmetricSecurityProtocol.cs (13)
145protected override IAsyncResult BeginSecureOutgoingMessageCore(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state)
155return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, newCorrelationState, callback, state);
172protected override void EndSecureOutgoingMessageCore(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState)
174if (result is CompletedAsyncResult<Message, SecurityProtocolCorrelationState>)
176message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState);
184protected override SecurityProtocolCorrelationState SecureOutgoingMessageCore(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
195void SetUpDelayedSecurityExecution(ref Message message, SecurityToken encryptingToken, SecurityToken signingToken,
222void AttachRecipientSecurityProperty(Message message, SecurityToken initiatorToken, SecurityToken recipientToken, IList<SecurityToken> basicTokens, IList<SecurityToken> endorsingTokens,
232void DoIdentityCheckAndAttachInitiatorSecurityProperty(Message message, SecurityToken initiatorToken, SecurityToken recipientToken, ReadOnlyCollection<IAuthorizationPolicy> recipientTokenPolicies)
241protected override SecurityProtocolCorrelationState VerifyIncomingMessageCore(ref Message message, string actor, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates)
320bool TryGetTokenSynchronouslyForOutgoingSecurity(Message message, SecurityProtocolCorrelationState correlationState, bool isBlockingCall, TimeSpan timeout,
361public SecureOutgoingMessageAsyncResult(Message m, AsymmetricSecurityProtocol binding,
369protected override void OnBothGetTokenCallsDone(ref Message message, SecurityToken primaryToken, SecurityToken secondaryToken, TimeSpan timeout)
System\ServiceModel\Security\DuplexSecurityProtocolFactory.cs (12)
230public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state)
238return new CompletedAsyncResult<Message>(message, callback, state);
242public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState,
251return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, null, callback, state);
255public override void EndSecureOutgoingMessage(IAsyncResult result, out Message message)
263message = CompletedAsyncResult<Message>.End(result);
268out Message message, out SecurityProtocolCorrelationState newCorrelationState)
276message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState);
280public override void SecureOutgoingMessage(ref Message message, TimeSpan timeout)
288public override SecurityProtocolCorrelationState SecureOutgoingMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
300public override void VerifyIncomingMessage(ref Message message, TimeSpan timeout)
308public override SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout,
System\ServiceModel\Security\InitiatorSessionSymmetricMessageSecurityProtocol.cs (11)
157protected override IAsyncResult BeginSecureOutgoingMessageCore(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state)
170return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, newCorrelationState, callback, state);
190protected override SecurityProtocolCorrelationState SecureOutgoingMessageCore(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
204protected override void EndSecureOutgoingMessageCore(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState)
206if (result is CompletedAsyncResult<Message, SecurityProtocolCorrelationState>)
208message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState);
216internal void SetUpDelayedSecurityExecution(ref Message message, SecurityToken signingToken, SecurityToken encryptionToken, SecurityToken sourceToken, SecurityTokenParameters tokenParameters,
237protected override SecurityProtocolCorrelationState VerifyIncomingMessageCore(ref Message message, string actor, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates)
273Message message;
281public SecureOutgoingMessageAsyncResult(Message message, InitiatorSessionSymmetricMessageSecurityProtocol binding, SecurityToken signingToken, SecurityToken encryptionToken, SecurityToken sourceToken, SecurityTokenParameters tokenParameters, TimeSpan timeout, AsyncCallback callback, object state)
300internal static Message End(IAsyncResult result, out SecurityProtocolCorrelationState newCorrelationState)
System\ServiceModel\Security\InitiatorSessionSymmetricTransportSecurityProtocol.cs (10)
127internal void SetupDelayedSecurityExecution(string actor, ref Message message, SecurityToken signingToken, SecurityToken sourceToken, SecurityTokenParameters tokenParameters,
141protected override void SecureOutgoingMessageAtInitiator(ref Message message, string actor, TimeSpan timeout)
152protected override IAsyncResult BeginSecureOutgoingMessageAtInitiatorCore(Message message, string actor, TimeSpan timeout, AsyncCallback callback, object state)
167return new CompletedAsyncResult<Message>(message, callback, state);
171protected override Message EndSecureOutgoingMessageAtInitiatorCore(IAsyncResult result)
173if (result is CompletedAsyncResult<Message>)
175return CompletedAsyncResult<Message>.End(result);
185Message message;
192public SecureOutgoingMessageAsyncResult(string actor, Message message, InitiatorSessionSymmetricTransportSecurityProtocol binding, SecurityToken signingToken, SecurityToken sourceToken, SecurityTokenParameters tokenParameters, TimeSpan timeout, AsyncCallback callback, object state)
210internal static Message End(IAsyncResult result)
System\ServiceModel\Security\IssuanceTokenProviderBase.cs (15)
345static protected void ThrowIfFault(Message message, EndpointAddress target)
423protected abstract BodyWriter GetNextOutgoingMessageBody(Message incomingMessage, T negotiationState);
430void PrepareRequest(Message nextMessage)
435void PrepareRequest(Message nextMessage, RequestSecurityToken rst)
479Message nextOutgoingMessage = null;
480Message incomingMessage = null;
590Message GetNextOutgoingMessage(Message incomingMessage, T negotiationState)
604Message nextMessage;
607nextMessage = Message.CreateMessage(this.MessageVersion, ActionHeader.Create(this.RequestSecurityTokenAction, this.MessageVersion.Addressing), nextMessageBody);
611nextMessage = Message.CreateMessage(this.MessageVersion, ActionHeader.Create(this.RequestSecurityTokenResponseAction, this.MessageVersion.Addressing), nextMessageBody);
756Message nextOutgoingMessage;
966Message incomingMessage = null;
1012Message incomingMessage = null;
1054bool DoNegotiation(Message incomingMessage)
System\ServiceModel\Security\IWSTrust13AsyncContract.cs (16)
26IAsyncResult BeginTrust13Cancel( Message request, AsyncCallback callback, object state );
33Message EndTrust13Cancel( IAsyncResult ar );
43IAsyncResult BeginTrust13Issue( Message request, AsyncCallback callback, object state );
50Message EndTrust13Issue( IAsyncResult ar );
61IAsyncResult BeginTrust13Renew( Message request, AsyncCallback callback, object state );
68Message EndTrust13Renew( IAsyncResult ar );
79IAsyncResult BeginTrust13Validate( Message request, AsyncCallback callback, object state );
86Message EndTrust13Validate( IAsyncResult ar );
101IAsyncResult BeginTrust13CancelResponse( Message request, AsyncCallback callback, object state );
108Message EndTrust13CancelResponse( IAsyncResult ar );
124IAsyncResult BeginTrust13IssueResponse( Message request, AsyncCallback callback, object state );
131Message EndTrust13IssueResponse( IAsyncResult ar );
147IAsyncResult BeginTrust13RenewResponse( Message request, AsyncCallback callback, object state );
154Message EndTrust13RenewResponse( IAsyncResult ar );
170IAsyncResult BeginTrust13ValidateResponse( Message request, AsyncCallback callback, object state );
177Message EndTrust13ValidateResponse( IAsyncResult ar );
System\ServiceModel\Security\IWSTrustFeb2005AsyncContract.cs (16)
26IAsyncResult BeginTrustFeb2005Cancel( Message request, AsyncCallback callback, object state );
33Message EndTrustFeb2005Cancel( IAsyncResult ar );
43IAsyncResult BeginTrustFeb2005Issue( Message request, AsyncCallback callback, object state );
50Message EndTrustFeb2005Issue( IAsyncResult ar );
60IAsyncResult BeginTrustFeb2005Renew( Message request, AsyncCallback callback, object state );
67Message EndTrustFeb2005Renew( IAsyncResult ar );
77IAsyncResult BeginTrustFeb2005Validate( Message request, AsyncCallback callback, object state );
84Message EndTrustFeb2005Validate( IAsyncResult ar );
94IAsyncResult BeginTrustFeb2005CancelResponse( Message request, AsyncCallback callback, object state );
101Message EndTrustFeb2005CancelResponse( IAsyncResult ar );
111IAsyncResult BeginTrustFeb2005IssueResponse( Message request, AsyncCallback callback, object state );
118Message EndTrustFeb2005IssueResponse( IAsyncResult ar );
128IAsyncResult BeginTrustFeb2005RenewResponse( Message request, AsyncCallback callback, object state );
135Message EndTrustFeb2005RenewResponse( IAsyncResult ar );
145IAsyncResult BeginTrustFeb2005ValidateResponse( Message request, AsyncCallback callback, object state );
152Message EndTrustFeb2005ValidateResponse( IAsyncResult ar );
System\ServiceModel\Security\MessageSecurityProtocol.cs (33)
48protected bool RequiresIncomingSecurityProcessing(Message message)
79public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state)
87return new CompletedAsyncResult<Message>(message, callback, state);
101public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state)
109return new CompletedAsyncResult<Message>(message, callback, state);
123protected abstract IAsyncResult BeginSecureOutgoingMessageCore(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state);
125public override void EndSecureOutgoingMessage(IAsyncResult result, out Message message)
147public override void EndSecureOutgoingMessage(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState)
168protected abstract void EndSecureOutgoingMessageCore(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState);
171protected void AttachRecipientSecurityProperty(Message message, SecurityToken protectionToken, bool isWrappedToken, IList<SecurityToken> basicTokens, IList<SecurityToken> endorsingTokens,
190protected void DoIdentityCheckAndAttachInitiatorSecurityProperty(Message message, SecurityToken protectionToken, ReadOnlyCollection<IAuthorizationPolicy> protectionTokenPolicies)
198protected AuthorizationContext EnsureIncomingIdentity(Message message, SecurityToken token, ReadOnlyCollection<IAuthorizationPolicy> authorizationPolicies)
290protected static void EnsureNonWrappedToken(SecurityToken token, Message message)
308protected SendSecurityHeader ConfigureSendSecurityHeader(Message message, string actor, IList<SupportingTokenSpecification> supportingTokens, SecurityProtocolCorrelationState correlationState)
345protected ReceiveSecurityHeader CreateSecurityHeader(Message message, string actor, MessageDirection transferDirection, SecurityStandardsManager standardsManager)
376protected ReceiveSecurityHeader ConfigureReceiveSecurityHeader(Message message, string actor, SecurityProtocolCorrelationState[] correlationStates, out IList<SupportingTokenAuthenticatorSpecification> supportingAuthenticators)
381protected ReceiveSecurityHeader ConfigureReceiveSecurityHeader(Message message, string actor, SecurityProtocolCorrelationState[] correlationStates, SecurityStandardsManager standardsManager, out IList<SupportingTokenAuthenticatorSpecification> supportingAuthenticators)
425protected void ProcessSecurityHeader(ReceiveSecurityHeader securityHeader, ref Message message,
524public override void SecureOutgoingMessage(ref Message message, TimeSpan timeout)
548public override SecurityProtocolCorrelationState SecureOutgoingMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
572protected abstract SecurityProtocolCorrelationState SecureOutgoingMessageCore(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState);
574void ValidateOutgoingState(Message message)
586public override void VerifyIncomingMessage(ref Message message, TimeSpan timeout)
622public override SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout, params SecurityProtocolCorrelationState[] correlationStates)
659protected abstract SecurityProtocolCorrelationState VerifyIncomingMessageCore(ref Message message, string actor, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates);
677Message message;
685public GetOneTokenAndSetUpSecurityAsyncResult(Message m, MessageSecurityProtocol binding, SecurityTokenProvider provider,
712internal static Message End(IAsyncResult result, out SecurityProtocolCorrelationState newCorrelationState)
733protected abstract void OnGetTokenDone(ref Message message, SecurityToken token, TimeSpan timeout);
799Message message;
809public GetTwoTokensAndSetUpSecurityAsyncResult(Message m, MessageSecurityProtocol binding,
840internal static Message End(IAsyncResult result, out SecurityProtocolCorrelationState newCorrelationState)
898protected abstract void OnBothGetTokenCallsDone(ref Message message, SecurityToken primaryToken, SecurityToken secondaryToken, TimeSpan timeout);
System\ServiceModel\Security\NegotiationTokenAuthenticator.cs (18)
562protected abstract BodyWriter ProcessRequestSecurityToken(Message request, RequestSecurityToken requestSecurityToken, out T negotiationState);
563protected abstract BodyWriter ProcessRequestSecurityTokenResponse(T negotiationState, Message request, RequestSecurityTokenResponse requestSecurityTokenResponse);
566protected virtual void ParseMessageBody(Message message, out string context, out RequestSecurityToken requestSecurityToken, out RequestSecurityTokenResponse requestSecurityTokenResponse)
596static Message CreateReply(Message request, XmlDictionaryString action, BodyWriter body)
600Message reply = Message.CreateMessage(request.Version, ActionHeader.Create(action, request.Version.Addressing), body);
607return Message.CreateMessage(request.Version, ActionHeader.Create(action, request.Version.Addressing), body);
713Message ProcessRequestCore(Message request)
900Message HandleNegotiationException(Message request, Exception e)
910Message CreateFault(Message request, Exception e)
945Message faultReply = Message.CreateMessage(version, fault, version.Addressing.DefaultFaultAction);
1035Message request = (Message)inputs[0];
System\ServiceModel\Security\SecurityProtocol.cs (33)
494static void SetSecurityHeaderId(SendSecurityHeader securityHeader, Message message)
523protected SendSecurityHeader CreateSendSecurityHeader(Message message, string actor, SecurityProtocolFactory factory)
528protected SendSecurityHeader CreateSendSecurityHeaderForTransportProtocol(Message message, string actor, SecurityProtocolFactory factory)
533SendSecurityHeader CreateSendSecurityHeader(Message message, string actor, SecurityProtocolFactory factory, bool requireMessageProtection)
552internal void AddMessageSupportingTokens(Message message, ref IList<SupportingTokenSpecification> supportingTokens)
573internal bool TryGetSupportingTokens(SecurityProtocolFactory factory, EndpointAddress target, Uri via, Message message, TimeSpan timeout, bool isBlockingCall, out IList<SupportingTokenSpecification> supportingTokens)
620protected IList<SupportingTokenAuthenticatorSpecification> GetSupportingTokenAuthenticatorsAndSetExpectationFlags(SecurityProtocolFactory factory, Message message,
705public virtual IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state)
708return new CompletedAsyncResult<Message>(message, callback, state);
711public virtual IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state)
714return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, newCorrelationState, callback, state);
717public virtual IAsyncResult BeginVerifyIncomingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state)
720return new CompletedAsyncResult<Message>(message, callback, state);
723public virtual IAsyncResult BeginVerifyIncomingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates, AsyncCallback callback, object state)
726return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, newCorrelationState, callback, state);
729public virtual void EndSecureOutgoingMessage(IAsyncResult result, out Message message)
731message = CompletedAsyncResult<Message>.End(result);
734public virtual void EndSecureOutgoingMessage(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState)
736message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState);
739public virtual void EndVerifyIncomingMessage(IAsyncResult result, out Message message)
741message = CompletedAsyncResult<Message>.End(result);
744public virtual void EndVerifyIncomingMessage(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState)
746message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState);
776public abstract void SecureOutgoingMessage(ref Message message, TimeSpan timeout);
779public virtual SecurityProtocolCorrelationState SecureOutgoingMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
785protected virtual void OnOutgoingMessageSecured(Message securedMessage)
790protected virtual void OnSecureOutgoingMessageFailure(Message message)
795public abstract void VerifyIncomingMessage(ref Message message, TimeSpan timeout);
798public virtual SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout, params SecurityProtocolCorrelationState[] correlationStates)
805protected virtual void OnIncomingMessageVerified(Message verifiedMessage)
817protected virtual void OnVerifyIncomingMessageFailure(Message message, Exception exception)
858Message message;
864public GetSupportingTokensAsyncResult(Message m, SecurityProtocol binding, TimeSpan timeout, AsyncCallback callback, object state)
System\ServiceModel\Security\SecuritySessionClientSettings.cs (74)
437Message closeResponse;
751Message PrepareCloseMessage()
762Message closeMessage = Message.CreateMessage(this.MessageVersion, ActionHeader.Create(this.Settings.SecurityStandardsManager.SecureConversationDriver.CloseAction, this.MessageVersion.Addressing), rst);
817Message closeMessage = PrepareCloseMessage();
836Message message = null;
859Message closeMessage = PrepareCloseMessage();
882MessageFault GetProtocolFault(ref Message message, out bool isKeyRenewalFault, out bool isSessionAbortedFault)
890Message copy = buffer.CreateMessage();
931void ProcessCloseResponse(Message response)
970void PrepareReply(Message request, Message reply)
991bool DoesSkiClauseMatchSigningToken(SecurityContextKeyIdentifierClause skiClause, Message request)
1000void ProcessCloseMessage(Message message)
1027Message response = null;
1029response = Message.CreateMessage(message.Version, ActionHeader.Create(this.Settings.SecurityStandardsManager.SecureConversationDriver.CloseResponseAction, message.Version.Addressing), rstr);
1035response = Message.CreateMessage(message.Version, ActionHeader.Create(this.Settings.SecurityStandardsManager.SecureConversationDriver.CloseResponseAction, message.Version.Addressing), rstrCollection);
1050protected Message ProcessIncomingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, out MessageFault protocolFault)
1113protected Message ProcessRequestContext(RequestContext requestContext, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
1120Message message = requestContext.RequestMessage;
1121Message unverifiedMessage = message;
1294protected IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state)
1300return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, correlationState, callback, state);
1308protected Message EndSecureOutgoingMessage(IAsyncResult result, out SecurityProtocolCorrelationState correlationState)
1310if (result is CompletedAsyncResult<Message, SecurityProtocolCorrelationState>)
1312return CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out correlationState);
1317Message message = KeyRenewalAsyncResult.End(result, out remainingTime);
1323protected SecurityProtocolCorrelationState SecureOutgoingMessage(ref Message message, TimeSpan timeout)
1334protected void VerifyIncomingMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
1392protected Message EndReceiveInternal(IAsyncResult result)
1397protected Message ReceiveInternal(TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
1411Message message = ProcessRequestContext(requestContext, timeoutHelper.RemainingTime(), correlationState);
1848Message message;
1903public static Message End(IAsyncResult result)
2478Message message;
2482public KeyRenewalAsyncResult(Message message, ClientSecuritySessionChannel sessionChannel, TimeSpan timeout, AsyncCallback callback, object state)
2516public static Message End(IAsyncResult result, out TimeSpan remainingTime)
2527Message message;
2533protected SecureSendAsyncResultBase(Message message, ClientSecuritySessionChannel sessionChannel, TimeSpan timeout, AsyncCallback callback, object state)
2572protected Message Message
2628public SecureSendAsyncResult(Message message, ClientSecuritySessionChannel sessionChannel, TimeSpan timeout, AsyncCallback callback, object state, bool autoCloseMessage)
2852Message message = ReceiveInternal(timeoutHelper.RemainingTime(), correlationState);
2887public Message Request(Message message)
2892Message ProcessReply(Message reply, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
2898Message unverifiedReply = reply;
2899Message processedReply = null;
2934public Message Request(Message message, TimeSpan timeout)
2940Message reply = this.ChannelBinder.Request(message, timeoutHelper.RemainingTime());
2944public IAsyncResult BeginRequest(Message message, AsyncCallback callback, object state)
2949public IAsyncResult BeginRequest(Message message, TimeSpan timeout, AsyncCallback callback, object state)
2956public Message EndRequest(IAsyncResult result)
2960Message reply = SecureRequestAsyncResult.EndAsReply(result, out requestCorrelationState, out remainingTime);
2967Message reply;
2969public SecureRequestAsyncResult(Message request, ClientSecuritySessionChannel sessionChannel, TimeSpan timeout, AsyncCallback callback, object state)
3019public static Message EndAsReply(IAsyncResult result, out SecurityProtocolCorrelationState correlationState, out TimeSpan remainingTime)
3092Message message = this.requestChannel.EndReceiveInternal(result);
3107Message message = thisAsyncResult.requestChannel.EndReceiveInternal(result);
3127bool OnMessageReceived(Message message)
3151InputQueue<Message> queue;
3159this.queue = TraceUtility.CreateInputQueue<Message>();
3190public Message Receive()
3195public Message Receive(TimeSpan timeout)
3210public Message EndReceive(IAsyncResult result)
3221public bool EndTryReceive(IAsyncResult result, out Message message)
3238public bool TryReceive(TimeSpan timeout, out Message message)
3250public void Send(Message message)
3255public void Send(Message message, TimeSpan timeout)
3264public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
3269public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
3341Message message = null;
System\ServiceModel\Security\SecuritySessionSecurityTokenAuthenticator.cs (23)
434Message HandleOperationException(SecuritySessionOperation operation, Message request, Exception e)
440Message CreateFault(Message request, Exception e)
475Message faultReply = Message.CreateMessage(request.Version, fault, request.Version.Addressing.DefaultFaultAction);
658SecurityContextSecurityToken IssueToken(RequestSecurityToken rst, Message request, SecurityContextSecurityToken currentToken, ReadOnlyCollection<IAuthorizationPolicy> currentTokenPolicies, out RequestSecurityTokenResponse rstr)
762protected virtual Message ProcessRenewRequest(Message request)
807Message response = CreateReply(request, this.RenewResponseAction, replyMessage);
875protected virtual Message ProcessIssueRequest(Message request)
951Message response = CreateReply(request, this.IssueResponseAction, replyMessage);
964internal static bool DoesSkiClauseMatchSigningToken(SecurityContextKeyIdentifierClause skiClause, Message request)
994static Message CreateReply(Message request, XmlDictionaryString action, BodyWriter body)
998Message reply = Message.CreateMessage(request.Version, ActionHeader.Create(action, request.Version.Addressing), body);
1005return Message.CreateMessage(request.Version, ActionHeader.Create(action, request.Version.Addressing), body);
1009Message ProcessRequest(Message request)
1234return parent.ProcessRequest((Message)inputs[0]);
1340public override bool Match(Message message)
System\ServiceModel\Security\SecuritySessionSecurityTokenProvider.cs (20)
525Message CreateRequest(SecuritySessionOperation operation, EndpointAddress target, SecurityToken currentToken, out object requestState)
541GenericXmlSecurityToken ProcessReply(Message reply, SecuritySessionOperation operation, object requestState)
591using (Message requestMessage = this.CreateRequest(operation, target, currentToken, out requestState))
601using (Message reply = channel.Request(requestMessage, timeoutHelper.RemainingTime()))
664void PrepareRequest(Message message)
701protected virtual Message CreateIssueRequest(EndpointAddress target, out object requestState)
707Message result = Message.CreateMessage(this.MessageVersion, ActionHeader.Create(this.IssueAction, this.MessageVersion.Addressing), rst);
712GenericXmlSecurityToken ExtractToken(Message response, object requestState)
761protected virtual GenericXmlSecurityToken ProcessIssueResponse(Message response, object requestState)
767protected virtual Message CreateRenewRequest(EndpointAddress target, SecurityToken currentSessionToken, out object requestState)
774Message result = Message.CreateMessage(this.MessageVersion, ActionHeader.Create(this.RenewAction, this.MessageVersion.Addressing), rst);
782protected virtual GenericXmlSecurityToken ProcessRenewResponse(Message response, object requestState)
792static protected void ThrowIfFault(Message message, EndpointAddress target)
924Message requestMessage = this.requestor.CreateRequest(this.operation, this.target, this.currentToken, out requestState);
946Message reply = this.channel.EndRequest(result);
972Message reply = this.channel.EndRequest(result);
1001bool OnReplyReceived(Message reply, object requestState)
1079public Message Message;
System\ServiceModel\Security\SecuritySessionServerSettings.cs (92)
1025Message message = requestContext.RequestMessage;
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)
1558Message message = innerRequestContext.RequestMessage;
1572Message requestMessage = ProcessRequestContext(innerRequestContext, timeoutHelper.RemainingTime(), out correlationState, out isSecurityProcessingFailure);
1589public Message Receive()
1594public Message Receive(TimeSpan timeout)
1596Message message;
1617public Message EndReceive(IAsyncResult result)
1619Message message;
1635public bool EndTryReceive(IAsyncResult result, out Message message)
1640public bool TryReceive(TimeSpan timeout, out Message message)
1688void SendFaultIfRequired(Exception e, Message unverifiedMessage, RequestContext requestContext, TimeSpan timeout)
1706using (Message faultMessage = Message.CreateMessage(unverifiedMessage.Version, fault, unverifiedMessage.Version.Addressing.DefaultFaultAction))
1739Message ProcessRequestContext(RequestContext requestContext, TimeSpan timeout, out SecurityProtocolCorrelationState correlationState, out bool isSecurityProcessingFailure)
1748Message result = null;
1749Message message = requestContext.RequestMessage;
1754Message unverifiedMessage = message;
1832internal void SecureApplicationMessage(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
1840internal SecurityProtocolCorrelationState VerifyIncomingMessage(ref Message message, TimeSpan timeout)
1845void PrepareReply(Message request, Message reply)
1888Message message = requestContext.RequestMessage;
1893Message response;
1896response = Message.CreateMessage(message.Version, renewFault, DotNetSecurityStrings.SecuritySessionFaultAction);
1901response = Message.CreateMessage(message.Version, renewFault, DotNetSecurityStrings.SecuritySessionFaultAction);
1927Message ProcessCloseRequest(Message request)
1961Message response = Message.CreateMessage(request.Version, ActionHeader.Create(this.Settings.SecurityStandardsManager.SecureConversationDriver.CloseResponseAction, request.Version.Addressing), bodyWriter);
1966internal Message CreateCloseResponse(Message message, SecurityProtocolCorrelationState correlationState, TimeSpan timeout)
1970Message response = this.ProcessCloseRequest(message);
1998protected void SendCloseResponse(RequestContext requestContext, Message closeResponse, TimeSpan timeout)
2020internal IAsyncResult BeginSendCloseResponse(RequestContext requestContext, Message closeResponse, TimeSpan timeout, AsyncCallback callback, object state)
2060internal Message CreateCloseMessage(TimeSpan timeout)
2066Message closeMessage = Message.CreateMessage(this.messageVersion, ActionHeader.Create(this.Settings.SecurityStandardsManager.SecureConversationDriver.CloseAction, this.messageVersion.Addressing), rst);
2098using (Message closeMessage = CreateCloseMessage(timeoutHelper.RemainingTime()))
2119Message closeMessage = CreateCloseMessage(timeoutHelper.RemainingTime());
2154protected void SendMessage(RequestContext requestContext, Message message, TimeSpan timeout)
2168internal IAsyncResult BeginSendMessage(RequestContext requestContext, Message response, TimeSpan timeout, AsyncCallback callback, object state)
2184Message message;
2186public SendMessageAsyncResult(ServerSecuritySessionChannel sessionChannel, RequestContext requestContext, Message message, TimeSpan timeout, AsyncCallback callback,
2217IAsyncResult BeginSend(Message response)
2552Message requestMessage;
2762public static bool EndAsMessage(IAsyncResult result, out Message message)
2840Message closeResponse;
2912bool ShouldSendCloseResponseOnClose(out RequestContext pendingCloseRequestContext, out Message pendingCloseResponse)
2941Message pendingCloseResponse;
3009Message pendingCloseResponse;
3021Message message;
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)
3080Message localCloseResponse = null;
3137Message closeResponse;
3139public CloseAsyncResult(ServerSecuritySimplexSessionChannel sessionChannel, bool sendCloseResponse, RequestContext closeRequestContext, Message closeResponse, TimeSpan timeout, AsyncCallback callback, object state)
3265Message message = null;
3310Message message = null;
3355bool OnMessageReceived(Message message)
3535public SecuritySessionRequestContext(RequestContext requestContext, Message requestMessage, SecurityProtocolCorrelationState correlationState, ServerSecuritySessionChannel channel)
3553protected override void OnReply(Message message, TimeSpan timeout)
3563protected override IAsyncResult OnBeginReply(Message message, TimeSpan timeout, AsyncCallback callback, object state)
3587Message closeResponseMessage;
3625public void Send(Message message)
3630public void Send(Message message, TimeSpan timeout)
3638public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state)
3643public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state)
3791Message message;
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)
3964Message pendingCloseResponseMessage;
4037Message closeResponseMessage;
4228Message message = null;
4273Message message = null;
4318bool OnMessageReceived(Message message)
4695public void HandleDemuxFailure(Message message)
4707public Message CreateSessionDemuxFaultMessage(Message message)
4710Message faultMessage = Message.CreateMessage(message.Version, fault, message.Version.Addressing.DefaultFaultAction);
4718IAsyncResult BeginHandleDemuxFailure<TFaultContext>(Message message, TFaultContext faultContext, AsyncCallback callback, object state)
4721Message fault = CreateSessionDemuxFaultMessage(message);
4725public IAsyncResult BeginHandleDemuxFailure(Message message, RequestContext faultContext, AsyncCallback callback, object state)
4730public IAsyncResult BeginHandleDemuxFailure(Message message, IOutputChannel faultContext, AsyncCallback callback, object state)
4753Message message;
4757public SendFaultAsyncResult(Message fault, TFaultContext faultContext, AsyncCallback callback, object state)
4771IAsyncResult BeginSend(Message message)
System\ServiceModel\Security\SymmetricSecurityProtocol.cs (13)
156protected override IAsyncResult BeginSecureOutgoingMessageCore(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state)
167return new CompletedAsyncResult<Message, SecurityProtocolCorrelationState>(message, newCorrelationState, callback, state);
181protected override SecurityProtocolCorrelationState SecureOutgoingMessageCore(ref Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState)
193void SetUpDelayedSecurityExecution(ref Message message,
226protected override void EndSecureOutgoingMessageCore(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState)
228if (result is CompletedAsyncResult<Message, SecurityProtocolCorrelationState>)
230message = CompletedAsyncResult<Message, SecurityProtocolCorrelationState>.End(result, out newCorrelationState);
253Message message,
285bool TryGetTokenSynchronouslyForOutgoingSecurity(Message message, SecurityProtocolCorrelationState correlationState, bool isBlockingCall, TimeSpan timeout, out SecurityToken token, out SecurityTokenParameters tokenParameters, out SecurityToken prerequisiteWrappingToken, out IList<SupportingTokenSpecification> supportingTokens, out SecurityProtocolCorrelationState newCorrelationState)
323void EnsureWrappedToken(SecurityToken token, Message message)
331protected override SecurityProtocolCorrelationState VerifyIncomingMessageCore(ref Message message, string actor, TimeSpan timeout, SecurityProtocolCorrelationState[] correlationStates)
401public SecureOutgoingMessageAsyncResult(Message m, SymmetricSecurityProtocol binding, SecurityTokenProvider provider,
409protected override void OnGetTokenDone(ref Message message, SecurityToken providerToken, TimeSpan timeout)
System\ServiceModel\Security\TransportSecurityProtocol.cs (22)
24public override void SecureOutgoingMessage(ref Message message, TimeSpan timeout)
51protected virtual void SecureOutgoingMessageAtInitiator(ref Message message, string actor, TimeSpan timeout)
58protected void SecureOutgoingMessageAtResponder(ref Message message, string actor)
67internal void SetUpDelayedSecurityExecution(ref Message message, string actor,
75public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, SecurityProtocolCorrelationState correlationState, AsyncCallback callback, object state)
92return new CompletedAsyncResult<Message>(message, callback, state);
105public override IAsyncResult BeginSecureOutgoingMessage(Message message, TimeSpan timeout, AsyncCallback callback, object state)
110protected virtual IAsyncResult BeginSecureOutgoingMessageAtInitiatorCore(Message message, string actor, TimeSpan timeout, AsyncCallback callback, object state)
117return new CompletedAsyncResult<Message>(message, callback, state);
125protected virtual Message EndSecureOutgoingMessageAtInitiatorCore(IAsyncResult result)
127if (result is CompletedAsyncResult<Message>)
129return CompletedAsyncResult<Message>.End(result);
137public override void EndSecureOutgoingMessage(IAsyncResult result, out Message message)
143public override void EndSecureOutgoingMessage(IAsyncResult result, out Message message, out SecurityProtocolCorrelationState newCorrelationState)
152if (result is CompletedAsyncResult<Message>)
154message = CompletedAsyncResult<Message>.End(result);
172public sealed override void VerifyIncomingMessage(ref Message message, TimeSpan timeout)
198protected void AttachRecipientSecurityProperty(Message message, IList<SecurityToken> basicTokens, IList<SecurityToken> endorsingTokens,
206protected virtual void VerifyIncomingMessageCore(ref Message message, TimeSpan timeout)
275Message message;
279public SecureOutgoingMessageAsyncResult(string actor, Message message, TransportSecurityProtocol binding, TimeSpan timeout, AsyncCallback callback, object state)
294internal static Message End(IAsyncResult result)
System\ServiceModel\Security\WSTrustChannel.cs (53)
37Message _response;
44Message request,
85public Message Response
97public new static Message End(IAsyncResult iar)
127Message EndOperation(IAsyncResult iar)
171/// The <see cref="IChannel" /> this class uses for sending and receiving <see cref="Message" /> objects.
202/// <see cref="Message" /> objects.
217/// The version of WS-Trust this channel will use for serializing <see cref="Message" /> objects.
286/// <see cref="Message" /> objects.
289/// The version of WS-Trust this channel will use for serializing <see cref="Message" /> objects.
364/// Creates a <see cref="Message"/> object that represents a WS-Trust RST message.
369/// <returns>The <see cref="Message" /> object that represents the WS-Trust message.</returns>
370protected virtual Message CreateRequest(System.IdentityModel.Protocols.WSTrust.RequestSecurityToken request, string requestType)
372return Message.CreateMessage(_messageVersion,
380/// Deserializes a <see cref="System.IdentityModel.Protocols.WSTrust.RequestSecurityTokenResponse" /> from a <see cref="Message" />
383/// <param name="response">The <see cref="Message" /> received from the WS-Trust endpoint.</param>
387protected virtual System.IdentityModel.Protocols.WSTrust.RequestSecurityTokenResponse ReadResponse(Message response)
990Message request = CreateRequest(rst, RequestTypes.Issue);
992Message response = Contract.Issue(request);
1031Message request = this.CreateRequest(rst, requestType);
1051Message response = WSTrustChannelAsyncResult.End(result);
1171/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS.</param>
1172/// <returns>The <see cref="Message" /> returned from the STS.</returns>
1173public Message Cancel(Message message)
1181/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS.</param>
1191public IAsyncResult BeginCancel(Message message, AsyncCallback callback, object asyncState)
1200/// <returns>The <see cref="Message" /> returned from the STS.</returns>
1201public Message EndCancel(IAsyncResult asyncResult)
1209/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS</param>
1210/// <returns>The <see cref="Message" /> returned from the STS</returns>
1211public Message Issue(Message message)
1219/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS.</param>
1229public IAsyncResult BeginIssue(Message message, AsyncCallback callback, object asyncState)
1238/// <returns>The <see cref="Message" /> returned from the STS.</returns>
1239public Message EndIssue(IAsyncResult asyncResult)
1247/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS</param>
1248/// <returns>The <see cref="Message" /> returned from the STS</returns>
1249public Message Renew(Message message)
1257/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS.</param>
1267public IAsyncResult BeginRenew(Message message, AsyncCallback callback, object asyncState)
1276/// <returns>The <see cref="Message" /> returned from the STS.</returns>
1277public Message EndRenew(IAsyncResult asyncResult)
1285/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS</param>
1286/// <returns>The <see cref="Message" /> returned from the STS</returns>
1287public Message Validate(Message message)
1295/// <param name="message">The <see cref="Message" /> that contains the instructions for the request to the STS.</param>
1305public IAsyncResult BeginValidate(Message message, AsyncCallback callback, object asyncState)
1314/// <returns>The <see cref="Message" /> returned from the STS.</returns>
1315public Message EndValidate(IAsyncResult asyncResult)
System\ServiceModel\Security\WSTrustServiceContract.cs (75)
28using Message = System.ServiceModel.Channels.Message;
259protected virtual Message ProcessCore(Message requestMessage, WSTrustRequestSerializer requestSerializer, WSTrustResponseSerializer responseSerializer, string requestAction, string responseAction, string trustNamespace)
291Message response = null;
323response = Message.CreateMessage(OperationContext.Current.RequestContext.RequestMessage.Version,
352protected virtual DispatchContext CreateDispatchContext(Message requestMessage,
524protected virtual IAsyncResult BeginProcessCore(Message requestMessage, WSTrustRequestSerializer requestSerializer, WSTrustResponseSerializer responseSerializer, string requestAction, string responseAction, string trustNamespace, AsyncCallback callback, object state)
611protected virtual Message EndProcessCore(IAsyncResult ar, string requestAction, string responseAction, string trustNamespace)
624Message message = null;
704public Message ProcessTrust13Cancel(Message message)
714public Message ProcessTrust13Issue(Message message)
724public Message ProcessTrust13Renew(Message message)
734public Message ProcessTrust13Validate(Message message)
744public Message ProcessTrust13CancelResponse(Message message)
759public Message ProcessTrust13IssueResponse(Message message)
774public Message ProcessTrust13RenewResponse(Message message)
789public Message ProcessTrust13ValidateResponse(Message message)
804public Message ProcessTrustFeb2005Cancel(Message message)
814public Message ProcessTrustFeb2005Issue(Message message)
824public Message ProcessTrustFeb2005Renew(Message message)
834public Message ProcessTrustFeb2005Validate(Message message)
844public Message ProcessTrustFeb2005CancelResponse(Message message)
859public Message ProcessTrustFeb2005IssueResponse(Message message)
874public Message ProcessTrustFeb2005RenewResponse(Message message)
889public Message ProcessTrustFeb2005ValidateResponse(Message message)
921public IAsyncResult BeginTrust13Cancel(Message request, AsyncCallback callback, object state)
931public Message EndTrust13Cancel(IAsyncResult ar)
943public IAsyncResult BeginTrust13Issue(Message request, AsyncCallback callback, object state)
953public Message EndTrust13Issue(IAsyncResult ar)
965public IAsyncResult BeginTrust13Renew(Message request, AsyncCallback callback, object state)
975public Message EndTrust13Renew(IAsyncResult ar)
987public IAsyncResult BeginTrust13Validate(Message request, AsyncCallback callback, object state)
997public Message EndTrust13Validate(IAsyncResult ar)
1009public IAsyncResult BeginTrust13CancelResponse(Message request, AsyncCallback callback, object state)
1026public Message EndTrust13CancelResponse(IAsyncResult ar)
1041public IAsyncResult BeginTrust13IssueResponse(Message request, AsyncCallback callback, object state)
1058public Message EndTrust13IssueResponse(IAsyncResult ar)
1073public IAsyncResult BeginTrust13RenewResponse(Message request, AsyncCallback callback, object state)
1090public Message EndTrust13RenewResponse(IAsyncResult ar)
1105public IAsyncResult BeginTrust13ValidateResponse(Message request, AsyncCallback callback, object state)
1122public Message EndTrust13ValidateResponse(IAsyncResult ar)
1137public IAsyncResult BeginTrustFeb2005Cancel(Message request, AsyncCallback callback, object state)
1147public Message EndTrustFeb2005Cancel(IAsyncResult ar)
1159public IAsyncResult BeginTrustFeb2005Issue(Message request, AsyncCallback callback, object state)
1169public Message EndTrustFeb2005Issue(IAsyncResult ar)
1181public IAsyncResult BeginTrustFeb2005Renew(Message request, AsyncCallback callback, object state)
1191public Message EndTrustFeb2005Renew(IAsyncResult ar)
1203public IAsyncResult BeginTrustFeb2005Validate(Message request, AsyncCallback callback, object state)
1213public Message EndTrustFeb2005Validate(IAsyncResult ar)
1225public IAsyncResult BeginTrustFeb2005CancelResponse(Message request, AsyncCallback callback, object state)
1242public Message EndTrustFeb2005CancelResponse(IAsyncResult ar)
1257public IAsyncResult BeginTrustFeb2005IssueResponse(Message request, AsyncCallback callback, object state)
1274public Message EndTrustFeb2005IssueResponse(IAsyncResult ar)
1289public IAsyncResult BeginTrustFeb2005RenewResponse(Message request, AsyncCallback callback, object state)
1306public Message EndTrustFeb2005RenewResponse(IAsyncResult ar)
1321public IAsyncResult BeginTrustFeb2005ValidateResponse(Message request, AsyncCallback callback, object state)
1338public Message EndTrustFeb2005ValidateResponse(IAsyncResult ar)
1425public new static Message End(IAsyncResult ar)
1438return Message.CreateMessage(OperationContext.Current.RequestContext.RequestMessage.Version,