diff options
| author |  Bill Feng <yfen@google.com> | 2018-08-27 10:32:50 -0700 |
|---|---|---|
| committer | Bill Feng <yfen@google.com> | 2018-08-27 10:32:50 -0700 |
| commit | 5fb6603ad5c6f419159efa851c92ebb291d015c0 (patch) | |
| tree | 5683a4607b00d3f38cca807a5ceae95a36959591 /test/cpp/qps/qps_json_driver.cc | |
| parent | 2fa4d430a6f0937ac829b28bb28671c4811cc833 (diff) | |
| parent | ca12a87af1371a37b168f1158bbb9088c9aee06a (diff) | |
Merge remote-tracking branch 'upstream/master' into feature/qps-bazel-test
Diffstat (limited to 'test/cpp/qps/qps_json_driver.cc')
| -rw-r--r-- | test/cpp/qps/qps_json_driver.cc | 19 |
1 files changed, 12 insertions, 7 deletions
diff --git a/test/cpp/qps/qps_json_driver.cc b/test/cpp/qps/qps_json_driver.cc index 0ff692255c..eaa0dd992c 100644 --- a/test/cpp/qps/qps_json_driver.cc +++ b/test/cpp/qps/qps_json_driver.cc @@ -66,6 +66,11 @@ DEFINE_string(json_file_out, "", "File to write the JSON output to."); DEFINE_string(credential_type, grpc::testing::kInsecureCredentialsType, "Credential type for communication with workers"); DEFINE_bool(run_inproc, false, "Perform an in-process transport test"); +DEFINE_int32( + median_latency_collection_interval_millis, 0, + "Specifies the period between gathering latency medians in " + "milliseconds. The medians will be logged out on the client at the " + "end of the benchmark run. If 0, this periodic collection is disabled."); namespace grpc { namespace testing { @@ -73,13 +78,13 @@ namespace testing { static std::unique_ptr<ScenarioResult> RunAndReport(const Scenario& scenario, bool* success) { std::cerr << "RUNNING SCENARIO: " << scenario.name() << "\n"; - auto result = - RunScenario(scenario.client_config(), scenario.num_clients(), - scenario.server_config(), scenario.num_servers(), - scenario.warmup_seconds(), scenario.benchmark_seconds(), - !FLAGS_run_inproc ? scenario.spawn_local_worker_count() : -2, - FLAGS_qps_server_target_override, FLAGS_credential_type, - FLAGS_run_inproc); + auto result = RunScenario( + scenario.client_config(), scenario.num_clients(), + scenario.server_config(), scenario.num_servers(), + scenario.warmup_seconds(), scenario.benchmark_seconds(), + !FLAGS_run_inproc ? scenario.spawn_local_worker_count() : -2, + FLAGS_qps_server_target_override, FLAGS_credential_type, FLAGS_run_inproc, + FLAGS_median_latency_collection_interval_millis); // Amend the result with scenario config. Eventually we should adjust // RunScenario contract so we don't need to touch the result here. |