114 references to WsrmUtilities
System.ServiceModel (114)
System\ServiceModel\Channels\ChannelReliableSession.cs (13)
203WsrmUtilities.AddAcknowledgementHeader(this.settings.ReliableMessagingVersion, 554WsrmUtilities.AssertWsrm11(this.settings.ReliableMessagingVersion); 563WsrmUtilities.AssertWsrm11(this.settings.ReliableMessagingVersion); 575WsrmUtilities.AssertWsrm11(this.settings.ReliableMessagingVersion); 759return WsrmUtilities.CalculateKeepAliveInterval(this.Settings.InactivityTimeout, this.Settings.MaxRetryCount); 765TimeSpan keepAliveInterval = WsrmUtilities.CalculateKeepAliveInterval(this.Settings.InactivityTimeout, this.Settings.MaxRetryCount); 862throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(WsrmUtilities.CreateCSFaultException( 1015WsrmUtilities.AssertWsrm11(this.Settings.ReliableMessagingVersion); 1024WsrmUtilities.AssertWsrm11(this.Settings.ReliableMessagingVersion); 1033WsrmUtilities.AssertWsrm11(this.Settings.ReliableMessagingVersion); 1179WsrmUtilities.AssertWsrm11(this.Settings.ReliableMessagingVersion); 1188WsrmUtilities.AssertWsrm11(this.Settings.ReliableMessagingVersion); 1197WsrmUtilities.AssertWsrm11(this.Settings.ReliableMessagingVersion);
System\ServiceModel\Channels\CloseSequence.cs (1)
42closeSequenceInfo.LastMsgNumber = WsrmUtilities.ReadSequenceNumber(reader, false);
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\ReliableChannelFactory.cs (2)
196return (TChannel)(object)new ClientReliableDuplexSessionChannel(this, this, binder, this.faultHelper, channelParameters, WsrmUtilities.NextSequenceId()); 200return (TChannel)(object)new ReliableRequestSessionChannel(this, this, binder, this.faultHelper, channelParameters, WsrmUtilities.NextSequenceId());
System\ServiceModel\Channels\ReliableChannelListener.cs (6)
600id = WsrmUtilities.GetInputId(info); 609UniqueId outputId = WsrmUtilities.GetOutputId(this.ReliableMessagingVersion, info); 802if (!WsrmUtilities.ValidateCreateSequence<TChannel>(info, this, channel, out acksTo)) 819info.FaultReply = WsrmUtilities.CreateEndpointNotFoundFault(this.MessageVersion, SR.GetString(SR.RMEndpointNotFoundReason, this.Uri)); 825info.FaultReply = WsrmUtilities.CreateCSRefusedServerTooBusyFault(this.MessageVersion, this.ReliableMessagingVersion, SR.GetString(SR.ServerTooBusy, this.Uri)); 829id = WsrmUtilities.NextSequenceId();
System\ServiceModel\Channels\ReliableDuplexSessionChannel.cs (17)
103WsrmUtilities.AddAcknowledgementHeader( 153Message message = WsrmUtilities.CreateAcknowledgmentMessage(this.Settings.MessageVersion, 295? WsrmUtilities.ValidateCloseSequenceResponse(this.session, this.closeRequestor.MessageId, info, 297: WsrmUtilities.ValidateTerminateSequenceResponse(this.session, this.terminateRequestor.MessageId, 487if (!WsrmUtilities.ValidateWsrmRequest(this.session, requestInfo, this.binder, null)) 554? WsrmUtilities.CreateTerminateResponseMessage(this.settings.MessageVersion, 556: WsrmUtilities.CreateCloseSequenceResponse(this.settings.MessageVersion, 587fault = WsrmUtilities.ValidateFinalAck(this.session, info, this.outputConnection.Last); 626WsrmUtilities.AddAcknowledgementHeader(this.settings.ReliableMessagingVersion, message, 910sendResult.Message = WsrmUtilities.CreateAckRequestedMessage(this.Settings.MessageVersion, 1164using (Message message = WsrmUtilities.CreateAckRequestedMessage(this.Settings.MessageVersion, 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, 1902if (WsrmUtilities.ValidateCreateSequence<IDuplexSessionChannel>(info, this.listener, this.Binder.Channel, out acksTo)) 1904Message response = WsrmUtilities.CreateCreateSequenceResponse(this.Settings.MessageVersion,
System\ServiceModel\Channels\ReliableInputConnection.cs (2)
154WsrmUtilities.AssertWsrm11(this.reliableMessagingVersion); 193WsrmUtilities.AssertWsrm11(this.reliableMessagingVersion);
System\ServiceModel\Channels\ReliableInputSessionChannel.cs (12)
179WsrmUtilities.AddAcknowledgementHeader(this.listener.ReliableMessagingVersion, message, 220Message message = WsrmUtilities.CreateAcknowledgmentMessage( 593if (WsrmUtilities.ValidateCreateSequence<IInputSessionChannel>(info, this.Listener, this.Binder.Channel, out acksTo)) 595Message response = WsrmUtilities.CreateCreateSequenceResponse(this.Listener.MessageVersion, 747if (!WsrmUtilities.ValidateWsrmRequest(this.ReliableSession, requestInfo, this.Binder, null)) 809? WsrmUtilities.CreateTerminateResponseMessage(this.Listener.MessageVersion, 811: WsrmUtilities.CreateCloseSequenceResponse(this.Listener.MessageVersion, 1005if (WsrmUtilities.ValidateCreateSequence<IInputSessionChannel>(info, this.Listener, this.Binder.Channel, out acksTo)) 1007Message response = WsrmUtilities.CreateCreateSequenceResponse(this.Listener.MessageVersion, 1142if (!WsrmUtilities.ValidateWsrmRequest(this.ReliableSession, requestInfo, this.Binder, context)) 1206? WsrmUtilities.CreateTerminateResponseMessage(this.Listener.MessageVersion, 1208: WsrmUtilities.CreateCloseSequenceResponse(this.Listener.MessageVersion,
System\ServiceModel\Channels\ReliableMessagingHelpers.cs (5)
3070WsrmUtilities.AddAcknowledgementHeader(reliableMessagingVersion, message, id, ranges, final, -1); 3108WsrmUtilities.AddAcknowledgementHeader(reliableMessagingVersion, message, id, ranges, final, 3121WsrmUtilities.AddAckRequestedHeader(reliableMessagingVersion, message, id); 3430return WsrmUtilities.ReadSequenceNumber(reader, false); 3503info.FaultReply = WsrmUtilities.CreateCSRefusedProtocolFault(listener.MessageVersion,
System\ServiceModel\Channels\ReliableOutputSessionChannel.cs (13)
320using (Message message = WsrmUtilities.CreateAckRequestedMessage(this.settings.MessageVersion, 330Message request = WsrmUtilities.CreateAckRequestedMessage(this.settings.MessageVersion, 472using (Message request = WsrmUtilities.CreateAckRequestedMessage(this.Settings.MessageVersion, 505? WsrmUtilities.ValidateCloseSequenceResponse(this.session, requestor.MessageId, info, 507: WsrmUtilities.ValidateTerminateSequenceResponse(this.session, requestor.MessageId, info, 562fault = WsrmUtilities.ValidateTerminateSequenceResponse(this.session, 572fault = WsrmUtilities.ValidateCloseSequenceResponse(this.session, 582if (!WsrmUtilities.ValidateWsrmRequest(this.session, messageInfo.TerminateSequenceInfo, this.binder, null)) 588fault = WsrmUtilities.ValidateFinalAckExists(this.session, ackInfo); 597Message response = WsrmUtilities.CreateTerminateResponseMessage( 627fault = WsrmUtilities.ValidateFinalAck(this.session, messageInfo, this.connection.Last); 675Message message = WsrmUtilities.CreateTerminateMessage(this.settings.MessageVersion, 701Message message = WsrmUtilities.CreateTerminateMessage(this.settings.MessageVersion,
System\ServiceModel\Channels\ReliableReplySessionChannel.cs (10)
166WsrmUtilities.AddAcknowledgementHeader( 234Message message = WsrmUtilities.CreateAcknowledgmentMessage( 635WsrmUtilities.AddSequenceHeader( 714if (!WsrmUtilities.ValidateWsrmRequest(this.session, requestInfo, this.binder, context)) 808Message message = WsrmUtilities.CreateTerminateMessage(this.MessageVersion, 918if (WsrmUtilities.ValidateCreateSequence<IReplySessionChannel>(info, this.listener, this.binder.Channel, out acksTo)) 920Message response = WsrmUtilities.CreateCreateSequenceResponse(this.listener.MessageVersion, 1212message = WsrmUtilities.CreateTerminateMessage(this.MessageVersion, 1976Message message = WsrmUtilities.CreateCloseSequenceResponse(channel.MessageVersion, 2006Message message = WsrmUtilities.CreateTerminateResponseMessage(channel.MessageVersion,
System\ServiceModel\Channels\ReliableRequestSessionChannel.cs (6)
73WsrmUtilities.AddAcknowledgementHeader(this.settings.ReliableMessagingVersion, message, 119Message request = WsrmUtilities.CreateAckRequestedMessage(this.settings.MessageVersion, 588? WsrmUtilities.ValidateCloseSequenceResponse(this.session, this.closeRequestor.MessageId, info, 590: WsrmUtilities.ValidateTerminateSequenceResponse(this.session, this.terminateRequestor.MessageId, 683WsrmFault fault = WsrmUtilities.ValidateFinalAck(this.session, messageInfo, this.connection.Last); 745if (WsrmUtilities.IsWsrmAction(this.settings.ReliableMessagingVersion, messageInfo.Action))
System\ServiceModel\Channels\TerminateSequence.cs (1)
53terminateSequenceInfo.LastMsgNumber = WsrmUtilities.ReadSequenceNumber(reader, false);
System\ServiceModel\Channels\TransmissionStrategy.cs (2)
232WsrmUtilities.AddSequenceHeader(this.reliableMessagingVersion, message, this.id, sequenceNumber, isLast); 237WsrmUtilities.AddAckRequestedHeader(this.reliableMessagingVersion, message, this.id);
System\ServiceModel\Channels\WsrmFault.cs (4)
387WsrmUtilities.WriteIdentifier(writer, this.GetReliableMessagingVersion(), this.sequenceID); 394return WsrmUtilities.ReadIdentifier(reader, reliableMessagingVersion); 553this.SequenceID = WsrmUtilities.ReadIdentifier(detailReader, reliableMessagingVersion); 582WsrmUtilities.WriteIdentifier(writer, reliableMessagingVersion, this.SequenceID);
System\ServiceModel\Channels\WsrmMessageInfo.cs (15)
619if (foundAction || WsrmUtilities.IsWsrmAction(reliableMessagingVersion, action)) 907Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 924Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, reliableMessagingVersion, reason); 955Message faultReply = WsrmUtilities.CreateCSRefusedProtocolFault(messageVersion, 1329Int64 sequenceNumber = WsrmUtilities.ReadSequenceNumber(reader); 1338WsrmUtilities.ReadEmptyElement(reader); 1476Int64 lower = WsrmUtilities.ReadSequenceNumber(reader, allowZero); 1479Int64 upper = WsrmUtilities.ReadSequenceNumber(reader, allowZero); 1493WsrmUtilities.ReadEmptyElement(reader); 1513WsrmUtilities.ReadEmptyElement(reader); 1526WsrmUtilities.ReadEmptyElement(reader); 1542WsrmUtilities.ReadSequenceNumber(reader, true); 1752WsrmUtilities.ReadSequenceNumber(reader, true); 1804WsrmUtilities.ReadEmptyElement(reader); 1840WsrmUtilities.ReadEmptyElement(reader);