aboutsummaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorGravatar Jan Tattermusch <jtattermusch@users.noreply.github.com>2016-05-02 14:26:52 -0700
committerGravatar Jan Tattermusch <jtattermusch@users.noreply.github.com>2016-05-02 14:26:52 -0700
commite88030a2c282da468f9d3be5c6225327ab8f7771 (patch)
tree009e978da69d203cdb24deacbdd21ce35ce7eec2
parent806b644d736005c61b0087891570a4b9a267db3b (diff)
parentb6e444088009ade16d9af4ab497f484d63d65b86 (diff)
Merge pull request #6340 from ctiller/fail_fast_breaks_qps
Disable fail fast for qps driver
-rw-r--r--test/cpp/qps/driver.cc3
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());
}
}