Class: Vault::PersistentHTTP::Pool

Inherits:
ConnectionPool show all
Defined in:
lib/vault/persistent/pool.rb

Overview

:nodoc:

Constant Summary

Constants inherited from ConnectionPool

ConnectionPool::DEFAULTS, ConnectionPool::VERSION

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from ConnectionPool

#shutdown, #with, wrap

Constructor Details

#initialize(options = {}, &block) ⇒ Pool

Returns a new instance of Pool.



7
8
9
10
11
12
 
# File 'lib/vault/persistent/pool.rb', line 7

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

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

Instance Attribute Details

#available ⇒ Object (readonly)

:nodoc:



4
5
6
 
# File 'lib/vault/persistent/pool.rb', line 4

def available
  @available
end

#key ⇒ Object (readonly)

:nodoc:



5
6
7
 
# File 'lib/vault/persistent/pool.rb', line 5

def key
  @key
end

Instance Method Details

#checkin(net_http_args) ⇒ Object

Raises:



14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/vault/persistent/pool.rb', line 14

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

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

  conn = stack.pop

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

  nil
end

#checkout(net_http_args) ⇒ Object 



29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/vault/persistent/pool.rb', line 29

def checkout net_http_args
  stacks = Thread.current[@key] ||= Hash.new { |h, k| h[k] = [] }
  stack  = stacks[net_http_args]

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

  stack.push conn

  conn
end