diff options
author | 2016-07-08 09:41:59 -0700 | |
---|---|---|
committer | 2016-07-08 09:41:59 -0700 | |
commit | aa8bbeb6c6f006a630f18e305044e30bdc44b4f2 (patch) | |
tree | 58733022e3c3ce09b81822ef69e077c9158cdb53 /test/cpp/qps/client_sync.cc | |
parent | f373f2cf8b9d6f8975e1dd976cddb1e3618e8ff9 (diff) | |
parent | ceb1a7d79f04bcee8c153b43fbe8bef408160537 (diff) |
Merge branch 'verbose_errors' into histo
Diffstat (limited to 'test/cpp/qps/client_sync.cc')
-rw-r--r-- | test/cpp/qps/client_sync.cc | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/test/cpp/qps/client_sync.cc b/test/cpp/qps/client_sync.cc index f328f492e3..92680986bd 100644 --- a/test/cpp/qps/client_sync.cc +++ b/test/cpp/qps/client_sync.cc @@ -31,7 +31,6 @@ * */ -#include <cassert> #include <chrono> #include <memory> #include <mutex> @@ -126,11 +125,16 @@ class SynchronousStreamingClient GRPC_FINAL : public SynchronousClient { } ~SynchronousStreamingClient() { EndThreads(); - for (auto stream = &stream_[0]; stream != &stream_[num_threads_]; - stream++) { + for (size_t i = 0; i < num_threads_; i++) { + auto stream = &stream_[i]; if (*stream) { (*stream)->WritesDone(); - EXPECT_TRUE((*stream)->Finish().ok()); + Status s = (*stream)->Finish(); + EXPECT_TRUE(s.ok()); + if (!s.ok()) { + gpr_log(GPR_ERROR, "Stream %zu received an error %s", i, + s.error_message().c_str()); + } } } delete[] stream_; |