YUKI Piro Hiroshi
null+****@clear*****
Mon Dec 22 19:56:41 JST 2014
YUKI "Piro" Hiroshi 2014-12-22 19:56:41 +0900 (Mon, 22 Dec 2014) New Revision: 1567290e2bbf8159b1a8c5d0fbf262502f832ad6 https://github.com/droonga/droonga-engine/commit/1567290e2bbf8159b1a8c5d0fbf262502f832ad6 Message: Use accidental buffer fou buffered forwarder always Modified files: lib/droonga/buffered_forwarder.rb Modified: lib/droonga/buffered_forwarder.rb (+1 -8) =================================================================== --- lib/droonga/buffered_forwarder.rb 2014-12-22 19:48:54 +0900 (7c9c881) +++ lib/droonga/buffered_forwarder.rb 2014-12-22 19:56:41 +0900 (27def7c) @@ -25,11 +25,9 @@ module Droonga def initialize(loop, options={}) @loop = loop - @options = options - @buffering = options[:buffering] @engine_state = options[:engine_state] @buffers = {} - @forwarder = Forwarder.new(loop, options) + @forwarder = Forwarder.new(loop, :buffering => true) end def start @@ -55,11 +53,6 @@ module Droonga def forward(message, destination) logger.trace("forward: start") - unless @buffering - @forwarder.forward(message, destination) - return - end - receiver = destination["to"] receiver_is_node = (receiver =~ /\A([^:]+:\d+\/[^\.]+)/) node_name = $1 -------------- next part -------------- HTML����������������������������...ダウンロード
