Revert "Add a flag to the resolver_component_test that permits extra addresses"

This reverts commit 02ce860592.
pull/14878/head
Alexander Polcyn 7 years ago
parent a7773a2000
commit 42c0d59d76
  1. 26
      test/cpp/naming/resolver_component_test.cc

@ -65,11 +65,6 @@ DEFINE_string(expected_addrs, "",
"List of expected backend or balancer addresses in the form " "List of expected backend or balancer addresses in the form "
"'<ip0:port0>,<is_balancer0>;<ip1:port1>,<is_balancer1>;...'. " "'<ip0:port0>,<is_balancer0>;<ip1:port1>,<is_balancer1>;...'. "
"'is_balancer' should be bool, i.e. true or false."); "'is_balancer' should be bool, i.e. true or false.");
DEFINE_bool(allow_extra_addrs, false,
"Permit extra resolved addresses in the final list of "
"resolved addresses. This is useful in certain integration "
"test environments in which DNS responses are not fully "
"deterministic.");
DEFINE_string(expected_chosen_service_config, "", DEFINE_string(expected_chosen_service_config, "",
"Expected service config json string that gets chosen (no " "Expected service config json string that gets chosen (no "
"whitespace). Empty for none."); "whitespace). Empty for none.");
@ -245,11 +240,9 @@ void CheckResolverResultLocked(void* argsp, grpc_error* err) {
GPR_ASSERT(channel_arg->type == GRPC_ARG_POINTER); GPR_ASSERT(channel_arg->type == GRPC_ARG_POINTER);
grpc_lb_addresses* addresses = grpc_lb_addresses* addresses =
(grpc_lb_addresses*)channel_arg->value.pointer.p; (grpc_lb_addresses*)channel_arg->value.pointer.p;
gpr_log(GPR_INFO, gpr_log(GPR_INFO, "num addrs found: %" PRIdPTR ". expected %" PRIdPTR,
"num addrs found: %" PRIdPTR ". expected %" PRIdPTR addresses->num_addresses, args->expected_addrs.size());
". Allow extra addresses:%d.", GPR_ASSERT(addresses->num_addresses == args->expected_addrs.size());
addresses->num_addresses, args->expected_addrs.size(),
FLAGS_allow_extra_addrs);
std::vector<GrpcLBAddress> found_lb_addrs; std::vector<GrpcLBAddress> found_lb_addrs;
for (size_t i = 0; i < addresses->num_addresses; i++) { for (size_t i = 0; i < addresses->num_addresses; i++) {
grpc_lb_address addr = addresses->addresses[i]; grpc_lb_address addr = addresses->addresses[i];
@ -261,20 +254,13 @@ void CheckResolverResultLocked(void* argsp, grpc_error* err) {
gpr_free(str); gpr_free(str);
} }
if (args->expected_addrs.size() != found_lb_addrs.size()) { if (args->expected_addrs.size() != found_lb_addrs.size()) {
// Permit extra resolved addresses if "--allow_extra_addrs" was set.
if (!(FLAGS_allow_extra_addrs &&
found_lb_addrs.size() > args->expected_addrs.size())) {
gpr_log(GPR_DEBUG, gpr_log(GPR_DEBUG,
"found lb addrs size is: %" PRIdPTR "found lb addrs size is: %" PRIdPTR
". expected addrs size is %" PRIdPTR ". --allow_extra_addrs=%d.", ". expected addrs size is %" PRIdPTR,
found_lb_addrs.size(), args->expected_addrs.size(), found_lb_addrs.size(), args->expected_addrs.size());
FLAGS_allow_extra_addrs);
abort(); abort();
} }
} EXPECT_THAT(args->expected_addrs, UnorderedElementsAreArray(found_lb_addrs));
for (size_t i = 0; i < args->expected_addrs.size(); i++) {
EXPECT_THAT(found_lb_addrs, ::testing::Contains(args->expected_addrs[i]));
}
CheckServiceConfigResultLocked(channel_args, args); CheckServiceConfigResultLocked(channel_args, args);
if (args->expected_service_config_string == "") { if (args->expected_service_config_string == "") {
CheckLBPolicyResultLocked(channel_args, args); CheckLBPolicyResultLocked(channel_args, args);

Loading…
Cancel
Save