Kouhei Sutou
null+****@clear*****
Fri Dec 13 11:03:14 JST 2013
Kouhei Sutou 2013-12-13 11:03:14 +0900 (Fri, 13 Dec 2013) New Revision: c9df330f22e3d8a3d5c33e3a8ef93cf0e097b534 https://github.com/droonga/fluent-plugin-droonga/commit/c9df330f22e3d8a3d5c33e3a8ef93cf0e097b534 Message: Ensure calling Forwarder#start Modified files: lib/droonga/dispatcher.rb lib/droonga/forwarder.rb lib/droonga/handler.rb lib/droonga/processor.rb lib/droonga/worker.rb Modified: lib/droonga/dispatcher.rb (+1 -0) =================================================================== --- lib/droonga/dispatcher.rb 2013-12-12 18:39:26 +0900 (a8821f6) +++ lib/droonga/dispatcher.rb 2013-12-13 11:03:14 +0900 (bb1700e) @@ -41,6 +41,7 @@ module Droonga end def start + @forwarder.start @farm.start end Modified: lib/droonga/forwarder.rb (+5 -0) =================================================================== --- lib/droonga/forwarder.rb 2013-12-12 18:39:26 +0900 (8614e02) +++ lib/droonga/forwarder.rb 2013-12-13 11:03:14 +0900 (97b09e0) @@ -24,6 +24,11 @@ module Droonga @outputs = {} end + def start + $log.trace("#{log_tag}: start: start") + $log.trace("#{log_tag}: start: done") + end + def shutdown $log.trace("#{log_tag}: shutdown: start") @outputs.each do |dest, output| Modified: lib/droonga/handler.rb (+6 -0) =================================================================== --- lib/droonga/handler.rb 2013-12-12 18:39:26 +0900 (21caf1c) +++ lib/droonga/handler.rb 2013-12-13 11:03:14 +0900 (8aeba3d) @@ -34,6 +34,12 @@ module Droonga prepare end + def start + $log.trace("#{log_tag}: start: start") + @forwarder.start + $log.trace("#{log_tag}: start: done") + end + def shutdown $log.trace("#{log_tag}: shutdown: start") super Modified: lib/droonga/processor.rb (+1 -0) =================================================================== --- lib/droonga/processor.rb 2013-12-12 18:39:26 +0900 (fb449db) +++ lib/droonga/processor.rb 2013-12-13 11:03:14 +0900 (bc16581) @@ -27,6 +27,7 @@ module Droonga def start @handler = Handler.new(@options) + @handler.start end def shutdown Modified: lib/droonga/worker.rb (+2 -0) =================================================================== --- lib/droonga/worker.rb 2013-12-12 18:39:26 +0900 (f861a48) +++ lib/droonga/worker.rb 2013-12-13 11:03:14 +0900 (2d4f433) @@ -30,7 +30,9 @@ module Droonga def run $log.trace("#{log_tag}: run: start") + @handler.start @message_receiver.run + @handler.shutdown $log.trace("#{log_tag}: run: done") end -------------- next part -------------- HTML����������������������������...下载
