YUKI Hiroshi
null+****@clear*****
Fri Mar 27 16:58:27 JST 2015
YUKI Hiroshi 2015-03-27 16:58:27 +0900 (Fri, 27 Mar 2015) New Revision: a4b51f8ee902e07dee314c9f967d09c0952cabdc https://github.com/droonga/droonga-engine/commit/a4b51f8ee902e07dee314c9f967d09c0952cabdc Message: Synchronize data from updated node metadata dynamically Modified files: lib/droonga/engine.rb lib/droonga/engine_node.rb Modified: lib/droonga/engine.rb (+1 -0) =================================================================== --- lib/droonga/engine.rb 2015-03-27 16:35:30 +0900 (9576219) +++ lib/droonga/engine.rb 2015-03-27 16:58:27 +0900 (de27af7) @@ -26,6 +26,7 @@ require "droonga/catalog_loader" require "droonga/dispatcher" require "droonga/file_observer" require "droonga/node_metadata" +require "droonga/file_observer" module Droonga class Engine Modified: lib/droonga/engine_node.rb (+7 -0) =================================================================== --- lib/droonga/engine_node.rb 2015-03-27 16:35:30 +0900 (5212f21) +++ lib/droonga/engine_node.rb 2015-03-27 16:58:27 +0900 (2a734d0) @@ -28,6 +28,11 @@ module Droonga @state = state @sender_node_metadata = params[:metadata] + @node_metadata_observer = FileObserver.new(@loop, Path.node_metadata) + @node_metadata_observer.on_change = lambda do + @sender_node_metadata.reload + end + parsed_name = parse_node_name(@name) @sender = FluentMessageSender.new(loop, parsed_name[:host], @@ -39,11 +44,13 @@ module Droonga def start logger.trace("start: start") @sender.resume + @node_metadata_observer.start logger.trace("start: done") end def shutdown logger.trace("shutdown: start") + @node_metadata_observer.stop @sender.shutdown logger.trace("shutdown: done") end -------------- next part -------------- HTML����������������������������...Download