diff options
| author |  Nathaniel Manista <nathaniel@google.com> | 2016-12-16 21:21:14 +0000 |
|---|---|---|
| committer | Nathaniel Manista <nathaniel@google.com> | 2016-12-16 23:48:52 +0000 |
| commit | 8f7b0b48bf75b652653cb0391fff06c5160e46fa (patch) | |
| tree | 3d57d49ad90086e0b5e29c72e6a47e956fffc4ea /src/ruby/qps | |
| parent | b229094678502e2606164a3240dbc8375ad403b5 (diff) | |
| parent | 3fa20cffc6d7f46a6df262a0c8e155619bb7ed39 (diff) | |
v1.0.x → master upmerge
Manual changes:
- Fixed use of Exception.message in _invalid_metadata_test.py
- Fixed merge of one_failed_as_unavailable in rpc_server_spec.rb
- Added "set -e" to generate_build_additions.sh
Diffstat (limited to 'src/ruby/qps')
| -rw-r--r-- | src/ruby/qps/client.rb | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/ruby/qps/client.rb b/src/ruby/qps/client.rb index 8aed866da5..817192626b 100644 --- a/src/ruby/qps/client.rb +++ b/src/ruby/qps/client.rb @@ -134,6 +134,7 @@ class BenchmarkClient resp = stub.streaming_call(q.each_item) start = Time.now q.push(req) + pushed_sentinal = false resp.each do |r| @histogram.add((Time.now-start)*1e9) if !@done @@ -141,8 +142,9 @@ class BenchmarkClient start = Time.now q.push(req) else - q.push(self) - break + q.push(self) unless pushed_sentinal + # Continue polling on the responses to consume and release resources + pushed_sentinal = true end end end |