Navigation Menu

Skip to content

Commit

Permalink
Add options to specify progress interval
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 10, 2015
1 parent c64a1ae commit 8e989be
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 0 deletions.
7 changes: 7 additions & 0 deletions bin/droonga-engine-absorb-data
Expand Up @@ -60,6 +60,7 @@ class AbsorbDataCommand
options.dataset = Droonga::CatalogGenerator::DEFAULT_DATASET
options.receiver_host = Socket.gethostname
options.messages_per_second = Droonga::DataAbsorber::DEFAULT_MESSAGES_PER_SECOND
options.progress_interval_seconds = Droonga::DataAbsorber::DEFAULT_PROGRESS_INTERVAL_SECONDS
options.verbose = false
parser = OptionParser.new
parser.version = Droonga::Engine::VERSION
Expand Down Expand Up @@ -106,6 +107,11 @@ class AbsorbDataCommand

parser.separator("")
parser.separator("Miscellaneous:")
parser.on("--progress-interval-seconds=N", Integer,
"Interval seconds to report progress.",
"(#{options.progress_interval_seconds})") do |n|
options.progress_interval_seconds = n
end
parser.on("--[no-]verbose",
"Output details for internal operations.",
"(#{options.verbose})") do |verbose|
Expand Down Expand Up @@ -151,6 +157,7 @@ class AbsorbDataCommand
:port => @options.port,
:tag => @options.tag,
:messages_per_second => @options.messages_per_second,
:progress_interval_seconds => @options.progress_interval_seconds,
:client_options => {
:backend => :coolio,
:loop => @loop,
Expand Down
5 changes: 5 additions & 0 deletions bin/droonga-engine-join
Expand Up @@ -103,6 +103,10 @@ class JoinCommand
:default => Droonga::DataAbsorber::DEFAULT_MESSAGES_PER_SECOND)

option.separator("Miscellaneous:")
option.on("progress-interval-seconds=",
"Interval seconds to report progress.",
:as => Integer,
:default => Droonga::DataAbsorber::DEFAULT_PROGRESS_INTERVAL_SECONDS)
option.on(:verbose, "Output details for internal operations.",
:default => false)
end
Expand Down Expand Up @@ -163,6 +167,7 @@ class JoinCommand
:port => @options[:port],
:tag => @options[:tag],
:messages_per_second => @options["records-per-second"],
:progress_interval_seconds => @options["progress-interval-seconds"],
:client_options => {
:backend => :coolio,
:loop => @loop,
Expand Down

0 comments on commit 8e989be

Please sign in to comment.