From 22b34c378f5754154d462c87085f39c8017dc333 Mon Sep 17 00:00:00 2001 From: Michail Merkushin Date: Sun, 20 Sep 2015 21:42:43 +0500 Subject: [PATCH] fix: misstypes in connection pool --- lib/sphinx/integration/mysql/connection_pool.rb | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/sphinx/integration/mysql/connection_pool.rb b/lib/sphinx/integration/mysql/connection_pool.rb index 3e0609e..d44403a 100644 --- a/lib/sphinx/integration/mysql/connection_pool.rb +++ b/lib/sphinx/integration/mysql/connection_pool.rb @@ -52,7 +52,7 @@ def take_slaves(&block) @agents ||= ThinkingSphinx::Configuration.instance.agents errors = [] - agents.each do |agent_name, _| + @agents.each do |agent_name, _| begin take(slaves_pool(agent_name), &block) rescue ::Innertube::Pool::BadResource, @@ -64,7 +64,7 @@ def take_slaves(&block) end # Райзим ошибку, только если она получаена от обоих реплик - return if errors.size < agents.size + return if errors.size < @agents.size raise errors[0] end @@ -115,7 +115,7 @@ def master_pool end def slaves_pool(agent_name) - @slavess_lock.synchronize do + @slaves_lock.synchronize do @slaves_pool[agent_name] ||= Innertube::Pool.new( proc { ::Sphinx::Integration::Mysql::ConnectionPool.slave_connection(agent_name) }, proc { |connection| connection.close }