Merge pull request #14250 from markdroth/dns_resolver_backoff_reset_fix

Fix DNS resolvers to reset the backoff in a better place.
pull/14272/head
Mark D. Roth 7 years ago committed by GitHub
commit 076f5ba5f3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 5
      src/core/ext/filters/client_channel/resolver/dns/c_ares/dns_resolver_ares.cc
  2. 5
      src/core/ext/filters/client_channel/resolver/dns/native/dns_resolver.cc

@ -131,7 +131,6 @@ static void dns_ares_shutdown_locked(grpc_resolver* resolver) {
static void dns_ares_channel_saw_error_locked(grpc_resolver* resolver) { static void dns_ares_channel_saw_error_locked(grpc_resolver* resolver) {
ares_dns_resolver* r = (ares_dns_resolver*)resolver; ares_dns_resolver* r = (ares_dns_resolver*)resolver;
if (!r->resolving) { if (!r->resolving) {
r->backoff->Reset();
dns_ares_start_resolving_locked(r); dns_ares_start_resolving_locked(r);
} }
} }
@ -261,6 +260,9 @@ static void dns_ares_on_resolved_locked(void* arg, grpc_error* error) {
if (service_config != nullptr) grpc_service_config_destroy(service_config); if (service_config != nullptr) grpc_service_config_destroy(service_config);
gpr_free(service_config_string); gpr_free(service_config_string);
grpc_lb_addresses_destroy(r->lb_addresses); grpc_lb_addresses_destroy(r->lb_addresses);
// Reset backoff state so that we start from the beginning when the
// next request gets triggered.
r->backoff->Reset();
} else { } else {
const char* msg = grpc_error_string(error); const char* msg = grpc_error_string(error);
gpr_log(GPR_DEBUG, "dns resolution failed: %s", msg); gpr_log(GPR_DEBUG, "dns resolution failed: %s", msg);
@ -297,7 +299,6 @@ static void dns_ares_next_locked(grpc_resolver* resolver,
r->next_completion = on_complete; r->next_completion = on_complete;
r->target_result = target_result; r->target_result = target_result;
if (r->resolved_version == 0 && !r->resolving) { if (r->resolved_version == 0 && !r->resolving) {
r->backoff->Reset();
dns_ares_start_resolving_locked(r); dns_ares_start_resolving_locked(r);
} else { } else {
dns_ares_maybe_finish_next_locked(r); dns_ares_maybe_finish_next_locked(r);

@ -106,7 +106,6 @@ static void dns_shutdown_locked(grpc_resolver* resolver) {
static void dns_channel_saw_error_locked(grpc_resolver* resolver) { static void dns_channel_saw_error_locked(grpc_resolver* resolver) {
dns_resolver* r = (dns_resolver*)resolver; dns_resolver* r = (dns_resolver*)resolver;
if (!r->resolving) { if (!r->resolving) {
r->backoff->Reset();
dns_start_resolving_locked(r); dns_start_resolving_locked(r);
} }
} }
@ -119,7 +118,6 @@ static void dns_next_locked(grpc_resolver* resolver,
r->next_completion = on_complete; r->next_completion = on_complete;
r->target_result = target_result; r->target_result = target_result;
if (r->resolved_version == 0 && !r->resolving) { if (r->resolved_version == 0 && !r->resolving) {
r->backoff->Reset();
dns_start_resolving_locked(r); dns_start_resolving_locked(r);
} else { } else {
dns_maybe_finish_next_locked(r); dns_maybe_finish_next_locked(r);
@ -160,6 +158,9 @@ static void dns_on_resolved_locked(void* arg, grpc_error* error) {
result = grpc_channel_args_copy_and_add(r->channel_args, &new_arg, 1); result = grpc_channel_args_copy_and_add(r->channel_args, &new_arg, 1);
grpc_resolved_addresses_destroy(r->addresses); grpc_resolved_addresses_destroy(r->addresses);
grpc_lb_addresses_destroy(addresses); grpc_lb_addresses_destroy(addresses);
// Reset backoff state so that we start from the beginning when the
// next request gets triggered.
r->backoff->Reset();
} else { } else {
grpc_millis next_try = r->backoff->NextAttemptTime(); grpc_millis next_try = r->backoff->NextAttemptTime();
grpc_millis timeout = next_try - grpc_core::ExecCtx::Get()->Now(); grpc_millis timeout = next_try - grpc_core::ExecCtx::Get()->Now();

Loading…
Cancel
Save