remove threads

abak-press · Oct 3, 2013 · 3135082 · 3135082
1 parent 1b91b5b
commit 3135082
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/lib/sphinx/integration/mysql/connection_pool.rb b/lib/sphinx/integration/mysql/connection_pool.rb
@@ -87,10 +87,10 @@ def self.take_slaves(silent = true)
     @take_slaves_mutex ||= Mutex.new
     @agents_pool ||= {}
 
-    threads = []
+    #threads = []
 
     ThinkingSphinx::Configuration.instance.agents.each do |agent_name, _|
-      threads << Thread.new do
+      #threads << Thread.new do
 
         retries  = 0
         original = nil
@@ -117,12 +117,16 @@ def self.take_slaves(silent = true)
         rescue Innertube::Pool::BadResource
           retries += 1
           retry if retries < 2
-          raise original
+          if silent
+            Rails.logger.warn original.message
+          else
+            raise original
+          end
         end
 
-      end
+      #end
     end
 
-    threads.each { |t| t.join }
+    #threads.each { |t| t.join }
   end
 end