diff --git a/test/cpp/end2end/xds/xds_cluster_end2end_test.cc b/test/cpp/end2end/xds/xds_cluster_end2end_test.cc index 6887be3d39b..1d66a39dd7e 100644 --- a/test/cpp/end2end/xds/xds_cluster_end2end_test.cc +++ b/test/cpp/end2end/xds/xds_cluster_end2end_test.cc @@ -478,7 +478,9 @@ TEST_P(EdsTest, SameBackendListedMultipleTimes) { EdsResourceArgs args({{"locality0", endpoints}}); balancer_->ads_service()->SetEdsResource(BuildEdsResource(args)); // We need to wait for the backend to come online. - WaitForAllBackends(DEBUG_LOCATION); + WaitForAllBackends(DEBUG_LOCATION, /*start_index=*/0, /*stop_index=*/0, + /*check_status=*/nullptr, WaitForBackendOptions(), + RpcOptions().set_timeout_ms(2000)); // Send kNumRpcsPerAddress RPCs per server. const size_t kNumRpcsPerAddress = 10; CheckRpcSendOk(DEBUG_LOCATION, kNumRpcsPerAddress * endpoints.size()); diff --git a/test/cpp/end2end/xds/xds_end2end_test_lib.h b/test/cpp/end2end/xds/xds_end2end_test_lib.h index 7ed7a5a672a..1b98f92146c 100644 --- a/test/cpp/end2end/xds/xds_end2end_test_lib.h +++ b/test/cpp/end2end/xds/xds_end2end_test_lib.h @@ -717,6 +717,9 @@ class XdsEnd2endTest : public ::testing::TestWithParam { struct RpcOptions { RpcService service = SERVICE_ECHO; RpcMethod method = METHOD_ECHO; + // Dev note: If a timeout or Deadline Exceeded error is occurring in an XDS + // end2end test, consider changing that test's timeout instead of this + // global default. int timeout_ms = 1000; bool wait_for_ready = false; std::vector> metadata;