[Groonga-commit] droonga/drnbench at 0062b98 [master] Reduce feeder scope

Back to archive index

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����������������������������...
Download 



More information about the Groonga-commit mailing list
Back to archive index