clientconn: stop automatically connecting to idle subchannels returned by picker (#4579)

clientconn.go

@@ -1429,26 +1429,14 @@ func (ac *addrConn) resetConnectBackoff() {
 	ac.mu.Unlock()
 }
 
-// getReadyTransport returns the transport if ac's state is READY.
+// getReadyTransport returns the transport if ac's state is READY or nil if not.
-// Otherwise it returns nil, false.
+func (ac *addrConn) getReadyTransport() transport.ClientTransport {
-// If ac's state is IDLE, it will trigger ac to connect.
-func (ac *addrConn) getReadyTransport() (transport.ClientTransport, bool) {
 	ac.mu.Lock()
-	if ac.state == connectivity.Ready && ac.transport != nil {
+	defer ac.mu.Unlock()
-		t := ac.transport
+	if ac.state == connectivity.Ready {
-		ac.mu.Unlock()
+		return ac.transport
-		return t, true
 	}
-	var idle bool
+	return nil
-	if ac.state == connectivity.Idle {
-		idle = true
-	}
-	ac.mu.Unlock()
-	// Trigger idle ac to connect.
-	if idle {
-		ac.connect()
-	}
-	return nil, false
 }
 
 // tearDown starts to tear down the addrConn.

picker_wrapper.go

@@ -147,7 +147,7 @@ func (pw *pickerWrapper) pick(ctx context.Context, failfast bool, info balancer.
 			logger.Error("subconn returned from pick is not *acBalancerWrapper")
 			continue
 		}
-		if t, ok := acw.getAddrConn().getReadyTransport(); ok {
+		if t := acw.getAddrConn().getReadyTransport(); t != nil {
 			if channelz.IsOn() {
 				return t, doneChannelzWrapper(acw, pickResult.Done), nil
 			}