ConnectionPoolRegistry.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 / ConnectionPoolRegistry.cs / 1 / ConnectionPoolRegistry.cs

                            //---------------------------------------------------------------------------- 
// Copyright (c) Microsoft Corporation.  All rights reserved.
//---------------------------------------------------------------------------
namespace System.ServiceModel.Channels
{ 
    using System.Diagnostics;
    using System.ServiceModel; 
    using System.Collections.Generic; 
    using System.ServiceModel.Diagnostics;
 
    abstract class ConnectionPoolRegistry
    {
        Dictionary> registry;
 
        protected ConnectionPoolRegistry()
        { 
            registry = new Dictionary>(); 
        }
 
        object ThisLock
        {
            get { return this.registry; }
        } 

        // NOTE: performs the open on the pool for you 
        public ConnectionPool Lookup(IConnectionOrientedTransportChannelFactorySettings settings) 
        {
            ConnectionPool result = null; 
            string key = settings.ConnectionPoolGroupName;

            lock (ThisLock)
            { 
                List registryEntry = null;
 
                if (registry.TryGetValue(key, out registryEntry)) 
                {
                    for (int i = 0; i < registryEntry.Count; i++) 
                    {
                        if (registryEntry[i].IsCompatible(settings) && registryEntry[i].TryOpen())
                        {
                            result = registryEntry[i]; 
                            break;
                        } 
                    } 
                }
                else 
                {
                    registryEntry = new List();
                    registry.Add(key, registryEntry);
                } 

                if (result == null) 
                { 
                    result = CreatePool(settings);
                    registryEntry.Add(result); 
                }
            }

            return result; 
        }
 
        protected abstract ConnectionPool CreatePool(IConnectionOrientedTransportChannelFactorySettings settings); 

        public void Release(ConnectionPool pool, TimeSpan timeout) 
        {
            lock (ThisLock)
            {
                if (pool.Close(timeout)) 
                {
                    List registryEntry = registry[pool.Name]; 
                    for (int i = 0; i < registryEntry.Count; i++) 
                    {
                        if (object.ReferenceEquals(registryEntry[i], pool)) 
                        {
                            registryEntry.RemoveAt(i);
                            break;
                        } 
                    }
 
                    if (registryEntry.Count == 0) 
                    {
                        registry.Remove(pool.Name); 
                    }
                }
            }
        } 
    }
} 
 


// 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