YUKI Hiroshi
null+****@clear*****
Mon Jan 20 14:23:39 JST 2014
YUKI Hiroshi 2014-01-20 14:23:39 +0900 (Mon, 20 Jan 2014) New Revision: 671973f577ea23fdf467f4a3fdc64ba9bc36997c https://github.com/droonga/drnbench/commit/671973f577ea23fdf467f4a3fdc64ba9bc36997c Message: Store subscriber clients 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-20 14:23:16 +0900 (4bb5850) +++ lib/drnbench/publish-subscribe/gradual-runner.rb 2014-01-20 14:23:39 +0900 (f1ba061) @@ -16,8 +16,8 @@ module Drnbench def run results = [] @config.n_steps.times do |try_count| - @runner.add_subscribers(@runner.n_subscribers) if try_count > 0 - label = "#{@runner.n_subscribers} subscribers" + @runner.add_subscribers(@runner.subscribers.size) if try_count > 0 + label = "#{@runner.subscribers.size} subscribers" percentage = nil result = Benchmark.bm do |benchmark| benchmark.report(label) do Modified: lib/drnbench/publish-subscribe/runner.rb (+14 -8) =================================================================== --- lib/drnbench/publish-subscribe/runner.rb 2014-01-20 14:23:16 +0900 (115db68) +++ lib/drnbench/publish-subscribe/runner.rb 2014-01-20 14:23:39 +0900 (0d352a2) @@ -10,14 +10,17 @@ require "drnbench/server/protocol-adapter" module Drnbench module PublishSubscribe class Runner - attr_reader :n_subscribers + attr_reader :subscribers def initialize(config) @config = config - @n_subscribers = 0 + @subscribers = [] + @published_messages = [] - @feeder = Droonga::Client.new(tag: "droonga", port: 23003) + @feeder = Droonga::Client.new(:tag => @config.engine.tag, + :host => @config.engine.host, + :port => @config.engine.port) setup_server setup_initial_subscribers @@ -56,12 +59,15 @@ module Drnbench def add_subscribers(n_subscribers) n_subscribers.times do |index| - @request[:path] - @request[:method] - @request[:body] - @client.connection.send(message, :response => :one) + message =****@confi*****_subscribe_request + client = Droonga::Client.new(:protocol => :http, + :host => @config.protocol_adapter.host, + :port => @config.protocol_adapter.port) + client.subscribe(message) do |object| + @published_messages << object + end + @subscribers << client end - @n_subscribers += n_subscribers end def do_feed -------------- next part -------------- HTML����������������������������...Download