diff options
author | Julien Boeuf <jboeuf@google.com> | 2015-10-17 22:14:29 -0700 |
---|---|---|
committer | Julien Boeuf <jboeuf@google.com> | 2015-10-17 22:14:29 -0700 |
commit | 3bb61d8917a506c8bbeadfa651f59ec37c74849f (patch) | |
tree | a5b5ecd11d25d354de1b774906fed642d4cb562f /test/cpp/qps | |
parent | 18a12c4e9b1b86a9b29302ed8aac9dc9e5cecfe3 (diff) | |
parent | 627f98454cf120d1b91205b381dcbc1c9c2cccfb (diff) |
Merge branch 'master' of https://github.com/grpc/grpc into core_creds_api_change
Diffstat (limited to 'test/cpp/qps')
-rw-r--r-- | test/cpp/qps/client_sync.cc | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/test/cpp/qps/client_sync.cc b/test/cpp/qps/client_sync.cc index beef604856..3c33a1c5de 100644 --- a/test/cpp/qps/client_sync.cc +++ b/test/cpp/qps/client_sync.cc @@ -59,6 +59,8 @@ #include "test/cpp/qps/interarrival.h" #include "test/cpp/qps/timer.h" +#include "src/core/profiling/timers.h" + namespace grpc { namespace testing { @@ -99,6 +101,7 @@ class SynchronousUnaryClient GRPC_FINAL : public SynchronousClient { WaitToIssue(thread_idx); auto* stub = channels_[thread_idx % channels_.size()].get_stub(); double start = Timer::Now(); + GPR_TIMER_SCOPE("SynchronousUnaryClient::ThreadFunc", 0); grpc::ClientContext context; grpc::Status s = stub->UnaryCall(&context, request_, &responses_[thread_idx]); @@ -135,6 +138,7 @@ class SynchronousStreamingClient GRPC_FINAL : public SynchronousClient { bool ThreadFunc(Histogram* histogram, size_t thread_idx) GRPC_OVERRIDE { WaitToIssue(thread_idx); + GPR_TIMER_SCOPE("SynchronousStreamingClient::ThreadFunc", 0); double start = Timer::Now(); if (stream_[thread_idx]->Write(request_) && stream_[thread_idx]->Read(&responses_[thread_idx])) { |