Navigation Menu

Skip to content

Commit

Permalink
Never use buffering feature for the global forwarder.
Browse files Browse the repository at this point in the history
It is used for clients or the engine node itself, and
never be used for other engine nodes.
  • Loading branch information
piroor committed Jan 6, 2015
1 parent 39bf724 commit 03fb153
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 4 deletions.
3 changes: 0 additions & 3 deletions lib/droonga/dispatcher.rb
Expand Up @@ -52,9 +52,6 @@ def initialize(engine_state, cluster, catalog)
@engine_state = engine_state
@cluster = cluster
@forwarder = @engine_state.forwarder
@cluster.on_change = lambda do
@forwarder.resume
end
@replier = @engine_state.replier
@catalog = catalog
@adapter_runners = create_adapter_runners
Expand Down
2 changes: 1 addition & 1 deletion lib/droonga/engine_state.rb
Expand Up @@ -41,7 +41,7 @@ def initialize(loop, name, internal_name)
@internal_name = internal_name
@sessions = {}
@current_id = 0
@forwarder = Forwarder.new(@loop, :buffering => true)
@forwarder = Forwarder.new(@loop)
@replier = Replier.new(@forwarder)
@on_ready = nil
@on_finish = nil
Expand Down

0 comments on commit 03fb153

Please sign in to comment.