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 936acaa commit d5f8d24
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 d5f8d24

Please sign in to comment.