diff options
author | 2018-02-12 20:55:27 -0800 | |
---|---|---|
committer | 2018-02-12 20:55:27 -0800 | |
commit | f66cf0d70d113c64a1c3d5a657e08bd7388c8fd6 (patch) | |
tree | 4014de921c97a7b0b8ad71169499e7d00856e7ce /src/core/ext/filters/client_channel/lb_policy.cc | |
parent | 1d168541fd55352be71116a8c8e5c9229b65b2b4 (diff) |
Revert "Revert "Revert "grpclb re-resolution"""
Diffstat (limited to 'src/core/ext/filters/client_channel/lb_policy.cc')
-rw-r--r-- | src/core/ext/filters/client_channel/lb_policy.cc | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/core/ext/filters/client_channel/lb_policy.cc b/src/core/ext/filters/client_channel/lb_policy.cc index 27fb2ad1f4..cc4fe7ec62 100644 --- a/src/core/ext/filters/client_channel/lb_policy.cc +++ b/src/core/ext/filters/client_channel/lb_policy.cc @@ -118,8 +118,7 @@ void grpc_lb_policy_update_locked(grpc_lb_policy* policy, void grpc_lb_policy_set_reresolve_closure_locked( grpc_lb_policy* policy, grpc_closure* request_reresolution) { - GPR_ASSERT(policy->request_reresolution == nullptr); - policy->request_reresolution = request_reresolution; + policy->vtable->set_reresolve_closure_locked(policy, request_reresolution); } void grpc_lb_policy_try_reresolve(grpc_lb_policy* policy, @@ -134,8 +133,8 @@ void grpc_lb_policy_try_reresolve(grpc_lb_policy* policy, grpc_lb_trace->name(), policy, grpc_error_string(error)); } } else { - if (grpc_lb_trace->enabled()) { - gpr_log(GPR_DEBUG, "%s %p: no available re-resolution closure.", + if (grpc_lb_trace->enabled() && error == GRPC_ERROR_NONE) { + gpr_log(GPR_DEBUG, "%s %p: re-resolution already in progress.", grpc_lb_trace->name(), policy); } } |