YUKI Hiroshi
null+****@clear*****
Thu Apr 30 12:36:01 JST 2015
YUKI Hiroshi 2015-04-30 12:36:01 +0900 (Thu, 30 Apr 2015) New Revision: 1ac0759524db0ae8bd80ef2b75aadcabf02d36be https://github.com/droonga/droonga-engine/commit/1ac0759524db0ae8bd80ef2b75aadcabf02d36be Message: Make EngineNode's forward buffer easy to replace Modified files: lib/droonga/engine_node.rb Modified: lib/droonga/engine_node.rb (+11 -6) =================================================================== --- lib/droonga/engine_node.rb 2015-04-30 12:35:29 +0900 (d2d1cca) +++ lib/droonga/engine_node.rb 2015-04-30 12:36:01 +0900 (3e09378) @@ -36,12 +36,7 @@ module Droonga @state = params[:state] logger.trace("initialize: start") - @buffer = ForwardBuffer.new(name) - boundary_timestamp = accept_messages_newer_than_timestamp - @buffer.process_messages_newer_than(boundary_timestamp) - @buffer.on_forward = lambda do |message, destination| - output(message, destination) - end + @buffer = create_buffer @node_name = NodeName.parse(@name) @@ -186,6 +181,16 @@ module Droonga NodeRole.mine end + def create_buffer + buffer = ForwardBuffer.new(@name) + boundary_timestamp = accept_messages_newer_than_timestamp + buffer.process_messages_newer_than(boundary_timestamp) + buffer.on_forward = lambda do |message, destination| + output(message, destination) + end + buffer + end + def have_unprocessed_messages? @state and @state["have_unprocessed_messages"] end -------------- next part -------------- HTML����������������������������...다운로드
