Work toward pool tests

Author: andrewvc

elasticsearch-transport/lib/elasticsearch/transport/transport/http/manticore/pool.rb

@@ -6,12 +6,12 @@ class Manticore
           class Pool
             attr_reader :logger
 
-            def initialize(logger, adapter, healthcheck_url, urls=[], resurrect_interval=5)
+            def initialize(logger, adapter, healthcheck_path="/", urls=[], resurrect_interval=5)
               @logger = logger
               @state_mutex = Mutex.new
               @url_info = {}
               @adapter = adapter
-              @healthcheck_url = healthcheck_url
+              @healthcheck_path = healthcheck_path
               @stopping = false
               @resurrect_interval = resurrect_interval
               @resurrectionist = start_resurrectionist
@@ -58,7 +58,7 @@ def resurrect_dead!
               # Try to keep locking granularity low such that we don't affect IO...
               @state_mutex.synchronize { @url_info.select {|url,meta| meta[:dead] } }.each do |url,meta|
                 begin
-                  perform_request_to_url(url, "GET", @healthcheck_url)
+                  perform_request_to_url(url, "GET", @healthcheck_path)
                   # If no exception was raised it must have succeeded!
                   logger.warn("Resurrected connection to dead ES instance at #{url}")
                   @state_mutex.synchronize { meta[:dead] = false }

elasticsearch-transport/test/unit/transport_manticore_pool.rb

@@ -12,9 +12,11 @@ class Elasticsearch::Transport::Transport::HTTP::ManticorePoolTest < Test::Unit:
 
     context "Manticore transport" do
       setup do
-        @transport = Manticore.new :hosts => [ { :host => '127.0.0.1', :port => 8080 } ]
+        @logger = Logger.new
+        @adapter = mock()
+        @healthcheck_path = "/healthcheck"
+        @pool = ::Elasticsearch::Transport::Transport::HTTP::Manticore::Pool.new(@logger, @adapter, @healthcheck_path)
       end
-
     end
   end
 end