Kouhei Sutou
null+****@clear*****
Tue Jan 21 11:58:04 JST 2014
Kouhei Sutou 2014-01-21 11:58:04 +0900 (Tue, 21 Jan 2014) New Revision: 0062b98788781fea0e9ecd6f6e92c46f34ead6c6 https://github.com/droonga/drnbench/commit/0062b98788781fea0e9ecd6f6e92c46f34ead6c6 Message: Reduce feeder scope Modified files: lib/drnbench/publish-subscribe/runner.rb Modified: lib/drnbench/publish-subscribe/runner.rb (+9 -8) =================================================================== --- lib/drnbench/publish-subscribe/runner.rb 2014-01-21 11:56:29 +0900 (ba30c1f) +++ lib/drnbench/publish-subscribe/runner.rb 2014-01-21 11:58:04 +0900 (2daeeae) @@ -20,9 +20,6 @@ module Drnbench @published_messages = Queue.new setup_server - @feeder = Droonga::Client.new(:tag => @config.engine.tag, - :host => @config.engine.host, - :port => @config.engine.port) setup_initial_subscribers end @@ -72,19 +69,23 @@ module Drnbench def do_feed(count) progressbar = ProgressBar.new("feeds", count, STDERR) - count.times do |index| - do_one_feed - progressbar.inc + Droonga::Client.open(:tag => @config.engine.tag, + :host => @config.engine.host, + :port => @config.engine.port) do |feeder| + count.times do |index| + do_one_feed(feeder) + progressbar.inc + end end progressbar.finish end - def do_one_feed + def do_one_feed(feeder) message =****@confi*****_feed message["id"] = Time.now.to_f.to_s, message["date"] = Time.now message["statusCode"] = 200 - @feeder.send(message, :response => :none) + feeder.send(message, :response => :none) end def receive_messages(count) -------------- next part -------------- HTML����������������������������...Descargar
