ExclusiveNamedPipeTransportManager.cs source code in C# .NET

Source code for the .NET framework in C#

                        
Code:

                         / WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / ExclusiveNamedPipeTransportManager.cs / 1 / ExclusiveNamedPipeTransportManager.cs
                        

                        
                            //---------------------------------------------------------------------------- 
// Copyright (c) Microsoft Corporation.  All rights reserved.
//---------------------------------------------------------------------------
namespace System.ServiceModel.Channels
{ 
    using System.Collections.Generic;
    using System.ServiceModel; 
    using System.IO; 
    using System.Text;
    using System.Threading; 
    using System.ServiceModel.Diagnostics;
    using System.Diagnostics;
    using System.Security.Principal;
 
    sealed class ExclusiveNamedPipeTransportManager : NamedPipeTransportManager
    { 
        ConnectionDemuxer connectionDemuxer; 
        IConnectionListener connectionListener;
 
        public ExclusiveNamedPipeTransportManager(Uri listenUri, NamedPipeChannelListener channelListener)
            : base(listenUri)
        {
            ApplyListenerSettings(channelListener); 
            SetHostNameComparisonMode(channelListener.HostNameComparisonMode);
            SetAllowedUsers(channelListener.AllowedUsers); 
        } 

        internal override void OnOpen() 
        {
            connectionListener = new BufferedConnectionListener(
                new PipeConnectionListener(ListenUri, HostNameComparisonMode, ConnectionBufferSize,
                    AllowedUsers, true, int.MaxValue), 
                    MaxOutputDelay, ConnectionBufferSize);
            if (DiagnosticUtility.ShouldUseActivity) 
            { 
                connectionListener = new TracingConnectionListener(connectionListener, this.ListenUri.ToString(), false);
            } 

            connectionDemuxer = new ConnectionDemuxer(connectionListener,
                MaxPendingAccepts, MaxPendingConnections, ChannelInitializationTimeout,
                IdleTimeout, MaxPooledConnections, 
                OnGetTransportFactorySettings,
                OnGetSingletonMessageHandler, 
                OnHandleServerSessionPreamble, 
                OnDemuxerError);
 
            bool startedDemuxing = false;
            try
            {
                connectionDemuxer.StartDemuxing(); 
                startedDemuxing = true;
            } 
            finally 
            {
                if (!startedDemuxing) 
                {
                    connectionDemuxer.Dispose();
                }
            } 
        }
 
        internal override void OnClose() 
        {
            connectionDemuxer.Dispose(); 
            connectionListener.Dispose();
            base.OnClose();
        }
    } 
}

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.

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