aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/ruby/qps/worker.rb
diff options
context:
space:
mode:
authorGravatar vjpai <vpai@google.com>2016-03-30 09:58:46 -0700
committerGravatar vjpai <vpai@google.com>2016-03-30 09:58:46 -0700
commitad1c1cc6cf4495b2af05058335869eafedd3e9fb (patch)
tree55a29d8c6482a07b2c250f74f09acea3bb343b9d /src/ruby/qps/worker.rb
parentd7f43b3aabd3d34ebd7ac2ce55fe86095fb92a8b (diff)
Add support for unary client, closed-loop or poisson
Diffstat (limited to 'src/ruby/qps/worker.rb')
-rwxr-xr-xsrc/ruby/qps/worker.rb3
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