diff options
author | 2015-05-20 22:08:24 -0700 | |
---|---|---|
committer | 2015-05-20 23:08:29 -0700 | |
commit | a6b559a76ae3d96f8df4abe07173c8b56fbfc032 (patch) | |
tree | db1f0294769d548dacf79e8335f200dc266c7289 /test/cpp/qps/report.cc | |
parent | 226beffea1fe772e172b6eb3125b096d0d11b2b2 (diff) |
Improvements to reporting mechanism based on comments.
Turned the reporter into a composite, much cleaner arch.
Diffstat (limited to 'test/cpp/qps/report.cc')
-rw-r--r-- | test/cpp/qps/report.cc | 30 |
1 files changed, 30 insertions, 0 deletions
diff --git a/test/cpp/qps/report.cc b/test/cpp/qps/report.cc index 9c4bb0d954..e116175e3b 100644 --- a/test/cpp/qps/report.cc +++ b/test/cpp/qps/report.cc @@ -39,6 +39,36 @@ namespace grpc { namespace testing { +void CompositeReporter::add(std::unique_ptr<Reporter> reporter) { + reporters_.emplace_back(std::move(reporter)); +} + +void CompositeReporter::ReportQPS(const ScenarioResult& result) const { + for (size_t i = 0; i < reporters_.size(); ++i) { + reporters_[i]->ReportQPS(result); + } +} + +void CompositeReporter::ReportQPSPerCore(const ScenarioResult& result, + const ServerConfig& config) const { + for (size_t i = 0; i < reporters_.size(); ++i) { + reporters_[i]->ReportQPSPerCore(result, config); + } +} + +void CompositeReporter::ReportLatency(const ScenarioResult& result) const { + for (size_t i = 0; i < reporters_.size(); ++i) { + reporters_[i]->ReportLatency(result); + } +} + +void CompositeReporter::ReportTimes(const ScenarioResult& result) const { + for (size_t i = 0; i < reporters_.size(); ++i) { + reporters_[i]->ReportTimes(result); + } +} + + void GprLogReporter::ReportQPS(const ScenarioResult& result) const { gpr_log(GPR_INFO, "QPS: %.1f", result.latencies.Count() / |