Kouhei Sutou
null+****@clear*****
Tue Jan 21 14:06:03 JST 2014
Kouhei Sutou 2014-01-21 14:06:03 +0900 (Tue, 21 Jan 2014) New Revision: d6da8b214f6ad5423b88fa49ab2d173a9a057301 https://github.com/droonga/drnbench/commit/d6da8b214f6ad5423b88fa49ab2d173a9a057301 Message: Don't keep published messages It will reduce memory usage. Modified files: lib/drnbench/publish-subscribe/gradual-runner.rb lib/drnbench/publish-subscribe/runner.rb Modified: lib/drnbench/publish-subscribe/gradual-runner.rb (+2 -2) =================================================================== --- lib/drnbench/publish-subscribe/gradual-runner.rb 2014-01-21 12:42:31 +0900 (d6022a5) +++ lib/drnbench/publish-subscribe/gradual-runner.rb 2014-01-21 14:06:03 +0900 (573a789) @@ -22,8 +22,8 @@ module Drnbench percentage = nil result = Benchmark.bm do |benchmark| benchmark.report(label) do - published_messages =****@runne***** - percentage = published_messages.size.to_f / @config.n_publishings * 100 + n_published_messages =****@runne***** + percentage = n_published_messages.to_f / @config.n_publishings * 100 end end if****@confi*****_progressively Modified: lib/drnbench/publish-subscribe/runner.rb (+4 -3) =================================================================== --- lib/drnbench/publish-subscribe/runner.rb 2014-01-21 12:42:31 +0900 (77438ff) +++ lib/drnbench/publish-subscribe/runner.rb 2014-01-21 14:06:03 +0900 (4316ee0) @@ -105,14 +105,15 @@ module Drnbench def receive_messages(count) progressbar = ProgressBar.new("received", count, STDERR) - published_messages = [] + n_published_messages = 0 count.times do # we should implement "timeout" for too slow cases - published_messages << @published_messages.pop + @published_messages.pop + n_published_messages += 1 progressbar.inc end progressbar.finish - published_messages + n_published_messages end end end -------------- next part -------------- HTML����������������������������...Descargar
