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: 5868ad1fca66ce71432eb658762586e50ec6fc1e https://github.com/droonga/droonga-engine/commit/5868ad1fca66ce71432eb658762586e50ec6fc1e Message: Synchronize data from updated node metadata dynamically Conflicts: lib/droonga/engine_node.rb 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 (ad1f35a) +++ lib/droonga/engine_node.rb 2015-03-27 16:58:27 +0900 (a4d85d4) @@ -31,6 +31,11 @@ module Droonga @buffer = ForwardBuffer.new(name) + @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], @@ -43,11 +48,13 @@ module Droonga logger.trace("start: start") @sender.resume @buffer.start_forward if really_writable? + @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