ips.cs

namespace Couchbase
{
    internal class SocketPool : ResourcePool {
        // .....
        public IPooledSocket Acquire()
        {
            // Log..
            IPooledSocket socket = null;
            lock(_syncObj)
            {
                while (_queue.Count == 0)
                {
                    // Releases the lock atomically,
                    // so a call to .Release() will not
                    // block
                    if (!Monitor.Wait(_syncObj, /* Timeout */)) {
                        break;
                    }
                }
                // Pool is locked again
                // This should never fail. Count > 0
                IPooledSocket socket = _queue.Dequeue();
            }

            if (socket == null) {
                // Timed out
                throw new TimedOutError("...");
            }

            // We have the Socket object from the queue.
            // Whether the socket is active or not, it will
            // not change membership status in the queue,
            // and therefore, it's safe to execute this outside
            // of a synchronized block
            try {
                if (!socket.IsAlive) {
                    socket.Close();
                    socket.Create();
                }
                return socket;
            } catch (...) {
                Release(socket);
                throw;
            }
        }


        public void Release(IPooledSocket socket)
        {
            // Log..
            lock(_syncObj)
            {
                _queue.Enqueue(socket);
                Monitor.PulseAll(_syncObj);
            }
        }
    }
}