YUKI Hiroshi
null+****@clear*****
Fri Nov 21 20:43:27 JST 2014
YUKI Hiroshi 2014-11-21 20:43:27 +0900 (Fri, 21 Nov 2014) New Revision: ddde3694c596cf78e95d5ad1a1b1a81f5719b2db https://github.com/droonga/droonga-engine/commit/ddde3694c596cf78e95d5ad1a1b1a81f5719b2db Message: Report progress even if there is no response Modified files: bin/droonga-engine-absorb-data Modified: bin/droonga-engine-absorb-data (+5 -3) =================================================================== --- bin/droonga-engine-absorb-data 2014-11-21 20:37:26 +0900 (b811f24) +++ bin/droonga-engine-absorb-data 2014-11-21 20:43:27 +0900 (c4b1546) @@ -83,7 +83,7 @@ destination_node = "#{options.destination_host}:#{options.port}/#{options.tag}" def run_remote_command(target, command, options) serf = Droonga::Serf.new(nil, target) result = serf.send_query(command, options) - puts result[:result] + #puts result[:result] puts result[:error] unless result[:error].empty? result[:response] end @@ -118,8 +118,10 @@ if options.remote response = run_remote_command(destination_node, "report_status", "node" => destination_node, "key" => "absorbing") - absorbing = response["value"] - break unless absorbing + if response + absorbing = response["value"] + break unless absorbing + end progress = absorber.report_progress(start_time_in_seconds) puts(progress) if progress -------------- next part -------------- HTML����������������������������...다운로드
