diff options
author | 2016-05-02 14:26:52 -0700 | |
---|---|---|
committer | 2016-05-02 14:26:52 -0700 | |
commit | e88030a2c282da468f9d3be5c6225327ab8f7771 (patch) | |
tree | 009e978da69d203cdb24deacbdd21ce35ce7eec2 | |
parent | 806b644d736005c61b0087891570a4b9a267db3b (diff) | |
parent | b6e444088009ade16d9af4ab497f484d63d65b86 (diff) |
Merge pull request #6340 from ctiller/fail_fast_breaks_qps
Disable fail fast for qps driver
-rw-r--r-- | test/cpp/qps/driver.cc | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/test/cpp/qps/driver.cc b/test/cpp/qps/driver.cc index 2583ceb819..04b2b453f9 100644 --- a/test/cpp/qps/driver.cc +++ b/test/cpp/qps/driver.cc @@ -83,6 +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); CoreRequest dummy; CoreResponse cores; grpc::Status s = stub->CoreCount(&ctx, dummy, &cores); @@ -166,6 +167,7 @@ namespace runsc { static ClientContext* AllocContext(list<ClientContext>* contexts) { contexts->emplace_back(); auto context = &contexts->back(); + context->set_fail_fast(false); return context; } @@ -435,6 +437,7 @@ void RunQuit() { CreateChannel(workers[i], InsecureChannelCredentials())); Void dummy; grpc::ClientContext ctx; + ctx.set_fail_fast(false); GPR_ASSERT(stub->QuitWorker(&ctx, dummy, &dummy).ok()); } } |