Kouhei Sutou
null+****@clear*****
Thu Oct 17 18:08:10 JST 2013
Kouhei Sutou 2013-10-17 18:08:10 +0900 (Thu, 17 Oct 2013) New Revision: 5d1d655988001a2c5aa6abd608f21f829dc7c239 https://github.com/droonga/fluent-plugin-droonga/commit/5d1d655988001a2c5aa6abd608f21f829dc7c239 Message: Indent Modified files: lib/droonga/server.rb Modified: lib/droonga/server.rb (+18 -18) =================================================================== --- lib/droonga/server.rb 2013-10-17 18:07:29 +0900 (469255f) +++ lib/droonga/server.rb 2013-10-17 18:08:10 +0900 (b42d5f1) @@ -49,31 +49,31 @@ module Droonga module WorkerStopper def send_stop(stop_graceful) open_queue do |queue| - $log.trace("#{log_tag}: stop: start") + $log.trace("#{log_tag}: stop: start") - $log.trace("#{log_tag}: stop: queue: unblock: start") - max_n_retries = 10 - max_n_retries.times do |i| - $log.trace("#{log_tag}: stop: queue: unblock: #{i}: start") - super(stop_graceful) - queue.unblock - alive_p = alive? - $log.trace("#{log_tag}: stop: queue: unblock: #{i}: done: #{alive_p}") - break unless alive_p - sleep(i * 0.1) - end - $log.trace("#{log_tag}: stop: queue: unblock: done") + $log.trace("#{log_tag}: stop: queue: unblock: start") + max_n_retries = 10 + max_n_retries.times do |i| + $log.trace("#{log_tag}: stop: queue: unblock: #{i}: start") + super(stop_graceful) + queue.unblock + alive_p = alive? + $log.trace("#{log_tag}: stop: queue: unblock: #{i}: done: #{alive_p}") + break unless alive_p + sleep(i * 0.1) + end + $log.trace("#{log_tag}: stop: queue: unblock: done") - $log.trace("#{log_tag}: stop: done") + $log.trace("#{log_tag}: stop: done") end end def send_reload open_queue do |queue| - $log.trace("#{log_tag}: reload: start") - super - queue.unblock - $log.trace("#{log_tag}: reload: done") + $log.trace("#{log_tag}: reload: start") + super + queue.unblock + $log.trace("#{log_tag}: reload: done") end end -------------- next part -------------- HTML����������������������������...ダウンロード
