diff options
| author |  Mark D. Roth <roth@google.com> | 2016-09-27 13:07:00 -0700 |
|---|---|---|
| committer | Mark D. Roth <roth@google.com> | 2016-09-27 13:07:00 -0700 |
| commit | 94777240032e41dd0cfb56218a09912395aded05 (patch) | |
| tree | 284a33b102416e07970f0a0c5240c4f97900be91 /test/cpp/qps | |
| parent | 9a574ec95289c9382fd0f130da12371e63e798a1 (diff) | |
Change C++ API to expose wait_for_ready instead of fail_fast.
Diffstat (limited to 'test/cpp/qps')
| -rw-r--r-- | test/cpp/qps/driver.cc | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/test/cpp/qps/driver.cc b/test/cpp/qps/driver.cc index b4c18bcb46..7460bb526a 100644 --- a/test/cpp/qps/driver.cc +++ b/test/cpp/qps/driver.cc @@ -83,7 +83,7 @@ static std::unordered_map<string, std::deque<int>> get_hosts_and_cores( auto stub = WorkerService::NewStub( CreateChannel(*it, InsecureChannelCredentials())); grpc::ClientContext ctx; - ctx.set_fail_fast(false); + ctx.set_wait_for_ready(true); CoreRequest dummy; CoreResponse cores; grpc::Status s = stub->CoreCount(&ctx, dummy, &cores); @@ -167,7 +167,7 @@ namespace runsc { static ClientContext* AllocContext(list<ClientContext>* contexts) { contexts->emplace_back(); auto context = &contexts->back(); - context->set_fail_fast(false); + context->set_wait_for_ready(true); return context; } @@ -527,7 +527,7 @@ bool RunQuit() { CreateChannel(workers[i], InsecureChannelCredentials())); Void dummy; grpc::ClientContext ctx; - ctx.set_fail_fast(false); + ctx.set_wait_for_ready(true); Status s = stub->QuitWorker(&ctx, dummy, &dummy); if (!s.ok()) { gpr_log(GPR_ERROR, "Worker %zu could not be properly quit because %s", i, |