diff options
author | 2016-03-30 09:58:46 -0700 | |
---|---|---|
committer | 2016-03-30 09:58:46 -0700 | |
commit | ad1c1cc6cf4495b2af05058335869eafedd3e9fb (patch) | |
tree | 55a29d8c6482a07b2c250f74f09acea3bb343b9d /src/ruby/qps/worker.rb | |
parent | d7f43b3aabd3d34ebd7ac2ce55fe86095fb92a8b (diff) |
Add support for unary client, closed-loop or poisson
Diffstat (limited to 'src/ruby/qps/worker.rb')
-rwxr-xr-x | src/ruby/qps/worker.rb | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/ruby/qps/worker.rb b/src/ruby/qps/worker.rb index 208211c410..744d19751d 100755 --- a/src/ruby/qps/worker.rb +++ b/src/ruby/qps/worker.rb @@ -73,7 +73,7 @@ class WorkerServiceImpl < Grpc::Testing::WorkerService::Service Thread.new { client = '' reqs.each do |req| - case req.argtype + case req.argtype.to_s when 'setup' client = BenchmarkClient.new(req.setup) q.push(Grpc::Testing::ClientStatus.new(stats: client.mark(false))) @@ -82,6 +82,7 @@ class WorkerServiceImpl < Grpc::Testing::WorkerService::Service end end q.push(self) + client.shutdown } q.each_item end |