diff options
author | 2017-09-01 16:36:52 -0700 | |
---|---|---|
committer | 2017-09-01 16:36:52 -0700 | |
commit | 56a84848c7b683e6e7fb3bef8b37364f9984cfdb (patch) | |
tree | 1b3bdae104ea63334572186ebf192ccb2de08fbb /test/cpp/qps/client.h | |
parent | 40bca8468e91e5e8a9df0b84b30458bf79a3acc3 (diff) | |
parent | da5cd59ed3f383318fb01b1bf461489cc828d453 (diff) |
Merge branch 'stats_histo_ints' into stats_histo
Diffstat (limited to 'test/cpp/qps/client.h')
-rw-r--r-- | test/cpp/qps/client.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/test/cpp/qps/client.h b/test/cpp/qps/client.h index b1d90aa9c4..7fbaf63492 100644 --- a/test/cpp/qps/client.h +++ b/test/cpp/qps/client.h @@ -34,6 +34,7 @@ #include "src/proto/grpc/testing/payloads.pb.h" #include "src/proto/grpc/testing/services.grpc.pb.h" +#include "src/cpp/util/core_stats.h" #include "test/cpp/qps/histogram.h" #include "test/cpp/qps/interarrival.h" #include "test/cpp/qps/usage_timer.h" @@ -172,6 +173,9 @@ class Client { timer_result = timer_->Mark(); } + grpc_stats_data core_stats; + grpc_stats_collect(&core_stats); + ClientStats stats; latencies.FillProto(stats.mutable_latencies()); for (StatusHistogram::const_iterator it = statuses.begin(); @@ -184,6 +188,7 @@ class Client { stats.set_time_system(timer_result.system); stats.set_time_user(timer_result.user); stats.set_cq_poll_count(poll_count); + CoreStatsToProto(core_stats, stats.mutable_core_stats()); return stats; } |