Navigation Menu

Skip to content

Commit

Permalink
Isolate Dumper from Coolio
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 10, 2015
1 parent c9024ea commit 0ebeb56
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 8 deletions.
6 changes: 5 additions & 1 deletion lib/drndump/command.rb
Expand Up @@ -110,7 +110,11 @@ def dump
:tag => @tag,
:receiver_host => @receiver_host,
:receiver_port => @receiver_port)
@dumper.run(:loop => @loop)
client_options = {
:backend => :coolio,
:loop => @loop,
}
@dumper.run(:client_options => client_options)
@loop.run
@dumper.error_message
end
Expand Down
12 changes: 5 additions & 7 deletions lib/drndump/dumper.rb
Expand Up @@ -16,12 +16,8 @@
require "socket"
require "json"

require "cool.io"

require "droonga/client"

require "drndump/version"

module Drndump
class Dumper
attr_reader :error_message
Expand All @@ -36,8 +32,9 @@ def initialize(params)
@receiver_port = params[:receiver_port] || 0
end

def run(loop)
client = Droonga::Client.new(client_options.merge(:loop => loop))
def run(options={})
extra_client_options = options[:client_options] || {}
client = Droonga::Client.new(client_options.merge(extra_client_options))

@error_message = nil
n_dumpers = 0
Expand Down Expand Up @@ -78,6 +75,8 @@ def run(loop)
end
end
end

@error_message
end

private
Expand All @@ -89,7 +88,6 @@ def client_options
:protocol => :droonga,
:receiver_host => @receiver_host,
:receiver_port => @receiver_port,
:backend => :coolio,
}
end

Expand Down

0 comments on commit 0ebeb56

Please sign in to comment.