YUKI Hiroshi
null+****@clear*****
Mon Jan 20 19:41:19 JST 2014
YUKI Hiroshi 2014-01-20 19:41:19 +0900 (Mon, 20 Jan 2014) New Revision: d78ec92ef13f650fa4a441a6aa4fbb513e6e287d https://github.com/droonga/drnbench/commit/d78ec92ef13f650fa4a441a6aa4fbb513e6e287d Message: Show progressbar for feeds and received messages Modified files: lib/drnbench/publish-subscribe/runner.rb Modified: lib/drnbench/publish-subscribe/runner.rb (+27 -12) =================================================================== --- lib/drnbench/publish-subscribe/runner.rb 2014-01-20 19:37:52 +0900 (352fc18) +++ lib/drnbench/publish-subscribe/runner.rb 2014-01-20 19:41:19 +0900 (1475650) @@ -47,22 +47,16 @@ module Drnbench def run publishing_times =****@confi*****_publishings n_will_be_published_messages =****@subsc***** * publishing_times - publishing_times.times do |index| - do_feed - end - published_messages = [] - n_will_be_published_messages.times do - # we should implement "timeout" for too slow cases - published_messages << @published_messages.pop - end + do_feed(publishing_times) + published_messages = receive_messages(n_will_be_published_messages) teardown_server published_messages end def add_subscribers(n_subscribers) - prpgressbar = ProgressBar.new("adding subscribers", n_subscribers, STDERR) + progressbar = ProgressBar.new("adding subscribers", n_subscribers, STDERR) n_subscribers.times do |index| message =****@confi*****_subscribe_request client = Droonga::Client.new(:protocol => :http, @@ -72,18 +66,39 @@ module Drnbench @published_messages.push(published_message) end @subscribers << client - prpgressbar.inc + progressbar.inc + end + progressbar.finish + end + + def do_feed(count) + progressbar = ProgressBar.new("feeds", count, STDERR) + count.times do |index| + do_one_feed + progressbar.inc end - prpgressbar.finish + progressbar.finish end - def do_feed + def do_one_feed message =****@confi*****_feed message["id"] = Time.now.to_f.to_s, message["date"] = Time.now message["statusCode"] = 200 @feeder.send(message, :response => :none) end + + def receive_messages(count) + progressbar = ProgressBar.new("received messages", count, STDERR) + published_messages = [] + count.times do + # we should implement "timeout" for too slow cases + published_messages << @published_messages.pop + progressbar.inc + end + progressbar.finish + published_messages + end end end end -------------- next part -------------- HTML����������������������������...下載
