diff options
author | David Garcia Quintas <dgq@google.com> | 2017-11-09 13:58:00 -0800 |
---|---|---|
committer | David Garcia Quintas <dgq@google.com> | 2017-11-09 13:58:00 -0800 |
commit | b90cb3fc29230641fd749fdb7b204f3f6deea000 (patch) | |
tree | 9b37f4b3ac0042dd49663c99c863a7f2b6b5209e | |
parent | a5c2d6b234144647d340546b08052e645da186c3 (diff) |
pr comments
-rw-r--r-- | src/core/ext/filters/client_channel/lb_policy/grpclb/grpclb.cc | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/core/ext/filters/client_channel/lb_policy/grpclb/grpclb.cc b/src/core/ext/filters/client_channel/lb_policy/grpclb/grpclb.cc index 6e4276ce3d..73a198c62b 100644 --- a/src/core/ext/filters/client_channel/lb_policy/grpclb/grpclb.cc +++ b/src/core/ext/filters/client_channel/lb_policy/grpclb/grpclb.cc @@ -1259,14 +1259,13 @@ static void lb_call_on_retry_timer_locked(grpc_exec_ctx* exec_ctx, void* arg, grpc_error* error) { glb_lb_policy* glb_policy = (glb_lb_policy*)arg; glb_policy->retry_timer_active = false; - if (!glb_policy->shutting_down && error == GRPC_ERROR_NONE) { + if (!glb_policy->shutting_down && glb_policy->lb_call == NULL && + error == GRPC_ERROR_NONE) { if (GRPC_TRACER_ON(grpc_lb_glb_trace)) { gpr_log(GPR_INFO, "Restaring call to LB server (grpclb %p)", (void*)glb_policy); } - if (glb_policy->lb_call == NULL) { - query_for_backends_locked(exec_ctx, glb_policy); - } + query_for_backends_locked(exec_ctx, glb_policy); } GRPC_LB_POLICY_WEAK_UNREF(exec_ctx, &glb_policy->base, "grpclb_retry_timer"); } |