Navigation Menu

Skip to content

Commit

Permalink
Give EngineState to HandlerMessenger
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Jun 26, 2014
1 parent 672e602 commit f67be47
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 2 deletions.
1 change: 1 addition & 0 deletions lib/droonga/dispatcher.rb
Expand Up @@ -55,6 +55,7 @@ def initialize(engine_state, catalog)
@catalog = catalog
@adapter_runners = create_adapter_runners
@farm = Farm.new(@engine_state.name, @catalog, @engine_state.loop,
:engine_state => @engine_state,
:dispatcher => self,
:forwarder => @forwarder)
@collector_runners = create_collector_runners
Expand Down
5 changes: 3 additions & 2 deletions lib/droonga/handler_messenger.rb
Expand Up @@ -18,14 +18,15 @@

module Droonga
class HandlerMessenger
attr_reader :database_name, :dispatcher
attr_reader :database_name, :dispatcher, :engine_state

def initialize(forwarder, message, options={})
@forwarder = forwarder
@message = message
@options = options
@replier = Replier.new(@forwarder)
@dispatcher = @options[:dispatcher]
@dispatcher = options[:dispatcher]
@engine_state = options[:engine_state]
@database_name = options[:database]
end

Expand Down
1 change: 1 addition & 0 deletions lib/droonga/worker.rb
Expand Up @@ -25,6 +25,7 @@ def initialize
@forwarder = Forwarder.new(@loop)
@handler_runner = HandlerRunner.new(@loop,
config.merge(:dispatcher => nil,
:engine_state => nil,
:forwarder => @forwarder))
receive_socket_path = config[:job_receive_socket_path]
@job_receiver = JobReceiver.new(@loop, receive_socket_path) do |message|
Expand Down

0 comments on commit f67be47

Please sign in to comment.