diff --git a/xds/internal/balancer/edsbalancer/edsbalancer_test.go b/xds/internal/balancer/edsbalancer/edsbalancer_test.go index 38c169a54178..3161c9e5a3ba 100644 --- a/xds/internal/balancer/edsbalancer/edsbalancer_test.go +++ b/xds/internal/balancer/edsbalancer/edsbalancer_test.go @@ -409,8 +409,21 @@ func TestEDS_EndpointsHealth(t *testing.T) { }) edsb.HandleEDSResponse(clab1.build()) - var readySCs []balancer.SubConn + var ( + readySCs []balancer.SubConn + + wantNewSubConnAddrStrs = []string{ + testEndpointAddrs[0], + testEndpointAddrs[2], + testEndpointAddrs[6], + testEndpointAddrs[8], + } + ) for i := 0; i < 4; i++ { + addr := <-cc.newSubConnAddrsCh + if addr[0].Addr != wantNewSubConnAddrStrs[i] { + t.Fatalf("want newSubConn with address %q, got %v", wantNewSubConnAddrStrs[i], addr) + } sc := <-cc.newSubConnCh edsb.HandleSubConnStateChange(sc, connectivity.Connecting) edsb.HandleSubConnStateChange(sc, connectivity.Ready)