aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/ext/filters/client_channel/lb_policy/pick_first
diff options
context:
space:
mode:
authorGravatar Mark D. Roth <roth@google.com>2018-08-15 14:07:11 -0700
committerGravatar Mark D. Roth <roth@google.com>2018-08-15 14:07:11 -0700
commit4c4e51d568c8e77f36e832d58407250aba890708 (patch)
treed5b94936a4f74b2856ac7982a82ed08bc942891a /src/core/ext/filters/client_channel/lb_policy/pick_first
parent1a10a9b9bf8f3ebc096b0349ccadf8f8b047251f (diff)
parent8e354419f478898c957aed82e8ea2c07057259db (diff)
Merge remote-tracking branch 'juanlishen/pf_check_state_before_watch' into pf_keep_unselected_subchannels
Diffstat (limited to 'src/core/ext/filters/client_channel/lb_policy/pick_first')
-rw-r--r--src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc13
1 files changed, 2 insertions, 11 deletions
diff --git a/src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc b/src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc
index d88b2b2ea4..fa39d9eb93 100644
--- a/src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc
+++ b/src/core/ext/filters/client_channel/lb_policy/pick_first/pick_first.cc
@@ -284,11 +284,11 @@ bool PickFirst::PickLocked(PickState* pick, grpc_error** error) {
"No pick result available but synchronous result required.");
return true;
}
+ pick->next = pending_picks_;
+ pending_picks_ = pick;
if (!started_picking_) {
StartPickingLocked();
}
- pick->next = pending_picks_;
- pending_picks_ = pick;
return false;
}
@@ -556,15 +556,6 @@ void PickFirst::PickFirstSubchannelData::ProcessConnectivityChangeLocked(
void PickFirst::PickFirstSubchannelData::ProcessUnselectedReadyLocked() {
PickFirst* p = static_cast<PickFirst*>(subchannel_list()->policy());
- if (p->selected_ == this) {
- if (grpc_lb_pick_first_trace.enabled()) {
- gpr_log(GPR_ERROR,
- "Pick First %p calling ProcessUnselectedReadyLocked() on "
- "selected subchannel %p",
- p, subchannel());
- }
- return;
- }
// If we get here, there are two possible cases:
// 1. We do not currently have a selected subchannel, and the update is
// for a subchannel in p->subchannel_list_ that we're trying to