Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Discovery / System / ServiceModel / Channels / UdpTransportBindingElement.cs / 1305376 / UdpTransportBindingElement.cs
//---------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------- namespace System.ServiceModel.Channels { using System; using System.Runtime; using System.ServiceModel.Discovery; sealed class UdpTransportBindingElement : TransportBindingElement, IUdpTransportSettings { int duplicateMessageHistoryLength; int maxPendingMessageCount; UdpRetransmissionSettings retransmissionSettings; int socketReceiveBufferSize; int timeToLive; public UdpTransportBindingElement() : base() { this.duplicateMessageHistoryLength = UdpConstants.Defaults.DuplicateMessageHistoryLength; this.maxPendingMessageCount = UdpConstants.Defaults.MaxPendingMessageCount; this.ManualAddressing = true; this.retransmissionSettings = new UdpRetransmissionSettings(); this.socketReceiveBufferSize = UdpConstants.Defaults.SocketReceiveBufferSize; this.timeToLive = UdpConstants.Defaults.TimeToLive; this.MaxReceivedMessageSize = UdpConstants.Defaults.MaxReceivedMessageSize; } internal UdpTransportBindingElement(UdpTransportBindingElement other) : base(other) { this.duplicateMessageHistoryLength = other.duplicateMessageHistoryLength; this.maxPendingMessageCount = other.maxPendingMessageCount; this.retransmissionSettings = other.retransmissionSettings.Clone(); this.socketReceiveBufferSize = other.socketReceiveBufferSize; this.timeToLive = other.timeToLive; this.EnableMulticast = other.EnableMulticast; this.MulticastInterfaceId = other.MulticastInterfaceId; } public int DuplicateMessageHistoryLength { get { return this.duplicateMessageHistoryLength; } set { const int min = 0; if (value < min) { throw FxTrace.Exception.ArgumentOutOfRange("value", value, SR.ArgumentOutOfMinRange(min)); } this.duplicateMessageHistoryLength = value; } } public bool EnableMulticast { get; set; } public int MaxPendingMessageCount { get { return this.maxPendingMessageCount; } set { const int min = 1; if (value < min) { throw FxTrace.Exception.ArgumentOutOfRange("value", value, SR.ArgumentOutOfMinRange(min)); } this.maxPendingMessageCount = value; } } public override long MaxReceivedMessageSize { get { return base.MaxReceivedMessageSize; } set { const long min = 1L; const long max = (long)UdpConstants.MaxMessageSizeOverIPv4; if (value < min || value > max) { throw FxTrace.Exception.ArgumentOutOfRange("value", value, SR.ArgumentOutOfMinMaxRange(min, max)); } base.MaxReceivedMessageSize = value; } } public string MulticastInterfaceId { get; set; } public UdpRetransmissionSettings RetransmissionSettings { get { return this.retransmissionSettings; } set { if (value == null) { throw FxTrace.Exception.ArgumentNull("value"); } this.retransmissionSettings = value; } } public override string Scheme { get { return UdpConstants.Scheme; } } public int SocketReceiveBufferSize { get { return this.socketReceiveBufferSize; } set { if (value < UdpConstants.MinReceiveBufferSize) { throw FxTrace.Exception.ArgumentOutOfRange("value", value, SR.ArgumentOutOfMinRange(UdpConstants.MinReceiveBufferSize)); } this.socketReceiveBufferSize = value; } } public int TimeToLive { get { return this.timeToLive; } set { if (value < UdpConstants.MinTimeToLive || value > UdpConstants.MaxTimeToLive) { throw FxTrace.Exception.ArgumentOutOfRange("value", value, SR.ArgumentOutOfMinMaxRange(UdpConstants.MinTimeToLive, UdpConstants.MaxTimeToLive)); } this.timeToLive = value; } } public override IChannelFactoryBuildChannelFactory (BindingContext context) { if (context == null) { throw FxTrace.Exception.ArgumentNull("context"); } if (!this.CanBuildChannelFactory (context)) { throw FxTrace.Exception.Argument("TChannel", SR.ChannelTypeNotSupported(typeof(TChannel))); } return (IChannelFactory )(object)new UdpChannelFactory(new UdpTransportBindingElement(this), context); } public override IChannelListener BuildChannelListener (BindingContext context) { if (context == null) { throw FxTrace.Exception.ArgumentNull("context"); } if (this.ManualAddressing == false) { throw FxTrace.Exception.AsError(new InvalidOperationException(SR.ManualAddressingRequiredOnServer)); } if (!this.CanBuildChannelListener (context)) { throw FxTrace.Exception.Argument("TChannel", SR.ChannelTypeNotSupported(typeof(TChannel))); } return (IChannelListener )(object)new UdpChannelListener(new UdpTransportBindingElement(this), context); } public override bool CanBuildChannelFactory (BindingContext context) { if (context == null) { throw FxTrace.Exception.ArgumentNull("context"); } return (typeof(TChannel) == typeof(IDuplexChannel)); } public override bool CanBuildChannelListener (BindingContext context) { if (context == null) { throw FxTrace.Exception.ArgumentNull("context"); } if (this.ManualAddressing == false) { return false; } return (typeof(TChannel) == typeof(IDuplexChannel)); } public override T GetProperty (BindingContext context) { if (context == null) { throw FxTrace.Exception.ArgumentNull("context"); } if (typeof(T) == typeof(IBindingMulticastCapabilities)) { return (T)(object)new BindingMulticastCapabilities(this.EnableMulticast); } return base.GetProperty (context); } public override BindingElement Clone() { return new UdpTransportBindingElement(this); } class BindingMulticastCapabilities : IBindingMulticastCapabilities { public BindingMulticastCapabilities(bool isMulticast) { this.IsMulticast = isMulticast; } public bool IsMulticast { get; private set; } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- CustomAttributeBuilder.cs
- GenericEnumerator.cs
- RefreshResponseInfo.cs
- ExtendLockCommand.cs
- BordersPage.cs
- nulltextnavigator.cs
- FunctionUpdateCommand.cs
- MatchingStyle.cs
- Catch.cs
- SqlReorderer.cs
- InternalRelationshipCollection.cs
- DesignOnlyAttribute.cs
- BamlBinaryReader.cs
- COM2TypeInfoProcessor.cs
- HtmlTable.cs
- Frame.cs
- GeneralTransform3DCollection.cs
- SimpleBitVector32.cs
- Model3DGroup.cs
- SqlProfileProvider.cs
- CompatibleComparer.cs
- StateDesigner.cs
- BadImageFormatException.cs
- ScrollEventArgs.cs
- _RequestCacheProtocol.cs
- InkCanvas.cs
- RTLAwareMessageBox.cs
- BinaryCommonClasses.cs
- XPathBinder.cs
- SqlParameterizer.cs
- SectionVisual.cs
- EntityDataSourceColumn.cs
- SamlSubjectStatement.cs
- OpenFileDialog.cs
- OpCodes.cs
- ReferencedAssembly.cs
- AdapterDictionary.cs
- QueryResponse.cs
- SendMessageChannelCache.cs
- EntityCommandDefinition.cs
- SqlCacheDependencySection.cs
- StrokeNodeData.cs
- GenericIdentity.cs
- MaskedTextBoxDesigner.cs
- TitleStyle.cs
- WsdlInspector.cs
- ReachNamespaceInfo.cs
- ContentValidator.cs
- SurrogateSelector.cs
- SqlConnectionPoolGroupProviderInfo.cs
- DoubleLink.cs
- Optimizer.cs
- WebBrowsableAttribute.cs
- SecurityToken.cs
- LocalizedNameDescriptionPair.cs
- DataSvcMapFile.cs
- RSAPKCS1SignatureFormatter.cs
- UrlPath.cs
- DataServiceRequestOfT.cs
- BatchParser.cs
- ObfuscateAssemblyAttribute.cs
- CodeCastExpression.cs
- DesignerAutoFormatCollection.cs
- EntityDataSourceContainerNameItem.cs
- EntityTypeEmitter.cs
- StrongNameKeyPair.cs
- PrintingPermission.cs
- ResponseBodyWriter.cs
- TraceLevelHelper.cs
- URLMembershipCondition.cs
- Convert.cs
- MsmqPoisonMessageException.cs
- DataSourceControlBuilder.cs
- ViewSimplifier.cs
- MatrixTransform.cs
- MeasurementDCInfo.cs
- MouseEvent.cs
- SimpleApplicationHost.cs
- X500Name.cs
- PropertyStore.cs
- WindowsSolidBrush.cs
- InputLanguage.cs
- LiteralControl.cs
- DocumentPageHost.cs
- NonPrimarySelectionGlyph.cs
- Object.cs
- SqlRetyper.cs
- ping.cs
- DbDataReader.cs
- EventLogPermissionEntryCollection.cs
- IntSecurity.cs
- SpeechUI.cs
- MessageDesigner.cs
- CanonicalFontFamilyReference.cs
- DataRecordObjectView.cs
- DiscoveryUtility.cs
- PerformanceCounterManager.cs
- AuthenticationService.cs
- BeginEvent.cs
- ObjRef.cs