UdpTransportBindingElement.cs source code in C# .NET

                        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 IChannelFactory BuildChannelFactory(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

Network programming in C#, Network Programming in VB.NET, Network Programming in .NET
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
UdpTransportBindingElement.cs source code in C# .NET

Source code for the .NET framework in C#

Code:

Link Menu
