Class: ActiveRecord::ConnectionAdapters::PoolConfig

Inherits:
Object
  • Object
show all
Includes:
Mutex_m
Defined in:
lib/active_record/connection_adapters/pool_config.rb

Overview

:nodoc:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(connection_klass, db_config) ⇒ PoolConfig

Returns a new instance of PoolConfig.



20
21
22
23
24
25
26
 
# File 'lib/active_record/connection_adapters/pool_config.rb', line 20

def initialize(connection_klass, db_config)
  super()
  @connection_klass = connection_klass
  @db_config = db_config
  @pool = nil
  INSTANCES[self] = self
end

Instance Attribute Details

#connection_klass ⇒ Object (readonly)

Returns the value of attribute connection_klass.



8
9
10
 
# File 'lib/active_record/connection_adapters/pool_config.rb', line 8

def connection_klass
  @connection_klass
end

#db_config ⇒ Object (readonly)

Returns the value of attribute db_config.



8
9
10
 
# File 'lib/active_record/connection_adapters/pool_config.rb', line 8

def db_config
  @db_config
end

#schema_cache ⇒ Object

Returns the value of attribute schema_cache.



9
10
11
 
# File 'lib/active_record/connection_adapters/pool_config.rb', line 9

def schema_cache
  @schema_cache
end

Class Method Details

.discard_pools! ⇒ Object 



15
16
17
 
# File 'lib/active_record/connection_adapters/pool_config.rb', line 15

def discard_pools!
  INSTANCES.each_key(&:discard_pool!)
end

Instance Method Details

#connection_specification_name ⇒ Object 



28
29
30
31
32
33
34
35
36
 
# File 'lib/active_record/connection_adapters/pool_config.rb', line 28

def connection_specification_name
  if connection_klass.is_a?(String)
    connection_klass
  elsif connection_klass.primary_class?
    "ActiveRecord::Base"
  else
    connection_klass.name
  end
end

#discard_pool! ⇒ Object 



59
60
61
62
63
64
65
66
67
68
 
# File 'lib/active_record/connection_adapters/pool_config.rb', line 59

def discard_pool!
  return unless @pool

  synchronize do
    return unless @pool

    @pool.discard!
    @pool = nil
  end
end

#disconnect! ⇒ Object 



38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/active_record/connection_adapters/pool_config.rb', line 38

def disconnect!
  ActiveSupport::ForkTracker.check!

  return unless @pool

  synchronize do
    return unless @pool

    @pool.automatic_reconnect = false
    @pool.disconnect!
  end

  nil
end

#pool ⇒ Object 



53
54
55
56
57
 
# File 'lib/active_record/connection_adapters/pool_config.rb', line 53

def pool
  ActiveSupport::ForkTracker.check!

  @pool || synchronize { @pool ||= ConnectionAdapters::ConnectionPool.new(self) }
end