aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/qps/client_sync.cc
diff options
context:
space:
mode:
authorGravatar Vijay Pai <vpai@ubivpai.dls.corp.google.com>2016-07-08 09:41:59 -0700
committerGravatar Vijay Pai <vpai@ubivpai.dls.corp.google.com>2016-07-08 09:41:59 -0700
commitaa8bbeb6c6f006a630f18e305044e30bdc44b4f2 (patch)
tree58733022e3c3ce09b81822ef69e077c9158cdb53 /test/cpp/qps/client_sync.cc
parentf373f2cf8b9d6f8975e1dd976cddb1e3618e8ff9 (diff)
parentceb1a7d79f04bcee8c153b43fbe8bef408160537 (diff)
Merge branch 'verbose_errors' into histo
Diffstat (limited to 'test/cpp/qps/client_sync.cc')
-rw-r--r--test/cpp/qps/client_sync.cc12
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_;