diff options
| author |  Craig Tiller <ctiller@google.com> | 2015-11-24 16:28:54 -0800 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2015-11-24 16:28:54 -0800 |
| commit | 27e5aa47a734929f902481b66fab795a8bba65ae (patch) | |
| tree | 668c15224db8104935d34a30a5300218999ddd28 /src/core/client_config | |
| parent | 11beb9a55c34fdac8398ce01381ca030c8d6223f (diff) | |
Test fixes
Diffstat (limited to 'src/core/client_config')
| -rw-r--r-- | src/core/client_config/lb_policies/pick_first.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/core/client_config/lb_policies/pick_first.c b/src/core/client_config/lb_policies/pick_first.c index e093c3e9a9..1c9652fc47 100644 --- a/src/core/client_config/lb_policies/pick_first.c +++ b/src/core/client_config/lb_policies/pick_first.c @@ -363,9 +363,9 @@ static void pf_broadcast(grpc_exec_ctx *exec_ctx, grpc_lb_policy *pol, gpr_mu_unlock(&p->mu); for (i = 0; i < n; i++) { - if (selected == grpc_subchannel_get_connected_subchannel(subchannels[i])) - continue; - grpc_subchannel_process_transport_op(exec_ctx, subchannels[i], op); + if (selected != grpc_subchannel_get_connected_subchannel(subchannels[i])) { + grpc_subchannel_process_transport_op(exec_ctx, subchannels[i], op); + } GRPC_SUBCHANNEL_UNREF(exec_ctx, subchannels[i], "pf_broadcast"); } if (p->selected) { |