123456789_123456789_123456789_123456789_123456789_

Class: Bundler::Persistent::Net::HTTP::Persistent::Pool

Do not use. This class is for internal use only.
Relationships & Source Files
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, ::Bundler::ConnectionPool
Instance Chain:
self, ::Bundler::ConnectionPool
Inherits: Bundler::ConnectionPool
Defined in: lib/bundler/vendor/net-http-persistent/lib/net/http/persistent/pool.rb

Constant Summary

::Bundler::ConnectionPool - Inherited

DEFAULTS, VERSION

Class Method Summary

::Bundler::ConnectionPool - Inherited

.new, .wrap

Instance Attribute Summary

::Bundler::ConnectionPool - Inherited

#size

Size of this connection pool.

Instance Method Summary

::Bundler::ConnectionPool - Inherited

#available

Number of pool entries available for checkout at this instant.
#checkin, #checkout,
#reload

Reloads the ::Bundler::ConnectionPool by passing each connection to block and then removing it the pool.
#shutdown

Shuts down the ::Bundler::ConnectionPool by passing each connection to block and then removing it from the pool.
#then

Alias for ConnectionPool#with.
#with

Constructor Details

.new(options = {}, &block) ⇒ Pool

[ GitHub ] 

  


# File 'lib/bundler/vendor/net-http-persistent/lib/net/http/persistent/pool.rb', line 6



def initialize(options = {}, &block)
  super

  @available = Bundler::Persistent::Net::HTTP::Persistent::TimedStackMulti.new(@size, &block)
  @key = "current-#{@available.object_id}"
end


  







Instance Attribute Details



  

    #available   (readonly)
  

  [ GitHub ]


  

  


# File 'lib/bundler/vendor/net-http-persistent/lib/net/http/persistent/pool.rb', line 3



attr_reader :available # :nodoc:


  








  

    #key   (readonly)
  

  [ GitHub ]


  

  


# File 'lib/bundler/vendor/net-http-persistent/lib/net/http/persistent/pool.rb', line 4



attr_reader :key # :nodoc:


  







Instance Method Details



  

    #checkin(net_http_args)  
  



  

    
  





  
Raises:





  [ GitHub ]


  

  


# File 'lib/bundler/vendor/net-http-persistent/lib/net/http/persistent/pool.rb', line 13



def checkin net_http_args
  stack = Thread.current[@key][net_http_args] ||= []

  raise Bundler::ConnectionPool::Error, 'no connections are checked out' if
    stack.empty?

  conn = stack.pop

  if stack.empty?
    @available.push conn, connection_args: net_http_args

    Thread.current[@key].delete(net_http_args)
    Thread.current[@key] = nil if Thread.current[@key].empty?
  end

  nil
end


  








  

    #checkout(net_http_args)  
  

  [ GitHub ]


  

  


# File 'lib/bundler/vendor/net-http-persistent/lib/net/http/persistent/pool.rb', line 31



def checkout net_http_args
  stacks = Thread.current[@key] ||= {}
  stack  = stacks[net_http_args] ||= []

  if stack.empty? then
    conn = @available.pop connection_args: net_http_args
  else
    conn = stack.last
  end

  stack.push conn

  conn
end


  








  

    #shutdown  
  

  [ GitHub ]


  

  


# File 'lib/bundler/vendor/net-http-persistent/lib/net/http/persistent/pool.rb', line 46



def shutdown
  Thread.current[@key] = nil
  super
end