Class | Mongo::PoolManager |
In: |
lib/mongo/util/pool_manager.rb
|
Parent: | Object |
arbiters | [R] | |
connection | [R] | |
hosts | [R] | |
max_bson_size | [R] | |
members | [R] | |
nodes | [R] | |
primary | [R] | |
primary_pool | [R] | |
read_pool | [R] | |
secondaries | [R] | |
secondary_pools | [R] | |
seeds | [R] | |
tags_to_pools | [R] |
# File lib/mongo/util/pool_manager.rb, line 8 def initialize(connection, seeds) @connection = connection @seeds = seeds @refresh_node = nil @previously_connected = false end
# File lib/mongo/util/pool_manager.rb, line 41 def close begin if @primary_pool @primary_pool.close end if @secondary_pools @secondary_pools.each do |pool| pool.close end end if @members @members.each do |member| member.close end end rescue ConnectionFailure end end
# File lib/mongo/util/pool_manager.rb, line 19 def connect if @previously_connected close end initialize_data members = connect_to_members initialize_pools(members) update_seed_list(members) @members = members @previously_connected = true end