diff options
author | Craig Tiller <ctiller@google.com> | 2016-02-11 08:48:13 -0800 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2016-02-11 08:48:13 -0800 |
commit | b718c8af703fc3442d691a091d5c8f9c321e3b55 (patch) | |
tree | 90c9c265035f3714b81badc68ea3e6d1e1ff026b /test/cpp/qps/driver.cc | |
parent | 6456a47b184540e9be3bbff25fe39ee4072676ad (diff) | |
parent | f79366a3c99592eccd9c719c86dca2f976804d3d (diff) |
Merge github.com:grpc/grpc into compatibility_mode
Diffstat (limited to 'test/cpp/qps/driver.cc')
-rw-r--r-- | test/cpp/qps/driver.cc | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/test/cpp/qps/driver.cc b/test/cpp/qps/driver.cc index c70b0303b8..80f6ada409 100644 --- a/test/cpp/qps/driver.cc +++ b/test/cpp/qps/driver.cc @@ -384,5 +384,18 @@ std::unique_ptr<ScenarioResult> RunScenario( delete[] servers; return result; } + +void RunQuit() { + // Get client, server lists + auto workers = get_workers("QPS_WORKERS"); + for (size_t i = 0; i < workers.size(); i++) { + auto stub = WorkerService::NewStub( + CreateChannel(workers[i], InsecureChannelCredentials())); + Void dummy; + grpc::ClientContext ctx; + GPR_ASSERT(stub->QuitWorker(&ctx, dummy, &dummy).ok()); + } +} + } // namespace testing } // namespace grpc |