Class ActiveRecord::ConnectionAdapters::ConnectionPool < Object

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 74
def initialize(spec)
  super()

  @spec = spec

  # The cache of reserved connections mapped to threads
  @reserved_connections = {}

  @queue = new_cond
  # 'wait_timeout', the backward-compatible key, conflicts with spec key 
  # used by mysql2 for something entirely different, checkout_timeout
  # preferred to avoid conflict and allow independent values. 
  @timeout = spec.config[:checkout_timeout] || spec.config[:wait_timeout] || 5

  # default max pool size to 5
  @size = (spec.config[:pool] && spec.config[:pool].to_i) || 5

  @connections         = []
  @automatic_reconnect = true
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 107
def active_connection?
  synchronize do
    @reserved_connections.fetch(current_connection_id) {
      return false
    }.in_use?
  end
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 285
def checkin(conn)
  synchronize do
    conn.run_callbacks :checkin do
      conn.expire
      @queue.signal
    end

    release conn
  end
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 238
def checkout
  synchronize do
    waited_time = 0

    loop do
      conn = @connections.find { |c| c.lease }

      unless conn
        if @connections.size < @size
          conn = checkout_new_connection
          conn.lease
        end
      end

      if conn
        checkout_and_verify conn
        return conn
      end

      if waited_time >= @timeout
        raise ConnectionTimeoutError, "could not obtain a database connection#{" within #{@timeout} seconds" if @timeout} (waited #{waited_time} seconds). The max pool size is currently #{@size}; consider increasing it."
      end

      # Sometimes our wait can end because a connection is available,
      # but another thread can snatch it up first. If timeout hasn't
      # passed but no connection is avail, looks like that happened --
      # loop and wait again, for the time remaining on our timeout. 
      before_wait = Time.now
      @queue.wait( [@timeout - waited_time, 0].max )
      waited_time += (Time.now - before_wait)

      # Will go away in Rails 4, when we don't clean up
      # after leaked connections automatically anymore. Right now, clean
      # up after we've returned from a 'wait' if it looks like it's
      # needed, then loop and try again. 
      if(active_connections.size >= @connections.size)
        clear_stale_cached_connections!
      end
    end
  end
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 197
def clear_cache!
  with_connection do |c|
    c.schema_cache.clear!
  end
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 152
def clear_reloadable_connections!
  synchronize do
    @reserved_connections = {}
    @connections.each do |conn|
      checkin conn
      conn.disconnect! if conn.requires_reloading?
    end
    @connections.delete_if do |conn|
      conn.requires_reloading?
    end
  end
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 206
      def clear_stale_cached_connections!
        keys = @reserved_connections.keys - Thread.list.find_all { |t|
          t.alive?
        }.map { |thread| thread.object_id }
        keys.each do |key|
          conn = @reserved_connections[key]
          ActiveSupport::Deprecation.warn("Database connections will not be closed automatically, please close your
database connection at the end of the thread by calling `close` on your
connection.  For example: ActiveRecord::Base.connection.close
") if conn.in_use?
          checkin conn
          @reserved_connections.delete(key)
        end
      end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 176
def columns
  with_connection do |c|
    c.schema_cache.columns
  end
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 183
def columns_hash
  with_connection do |c|
    c.schema_cache.columns_hash
  end
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 135
def connected?
  synchronize { @connections.any? }
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 100
def connection
  synchronize do
    @reserved_connections[current_connection_id] ||= checkout
  end
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 140
def disconnect!
  synchronize do
    @reserved_connections = {}
    @connections.each do |conn|
      checkin conn
      conn.disconnect!
    end
    @connections = []
  end
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 190
def primary_keys
  with_connection do |c|
    c.schema_cache.primary_keys
  end
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 118
def release_connection(with_id = current_connection_id)
  conn = synchronize { @reserved_connections.delete(with_id) }
  checkin conn if conn
end

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool.rb, line 126
def with_connection
  connection_id = current_connection_id
  fresh_connection = true unless active_connection?
  yield connection
ensure
  release_connection(connection_id) if fresh_connection
end