droonga/droonga-engine at 1567290 [buffered-forward] Use accidental buffer fou buffered forwarder always (Groonga-commit) - Groonga - fulltext search engine.

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����������������������������...
Download 


Groonga - fulltext search engine.

[Groonga-commit] droonga/droonga-engine at 1567290 [buffered-forward] Use accidental buffer fou buffered forwarder always