Method TestEndpoints_MultipleAddresses

interop/orcalb_test.go:182–220

TestEndpoints_MultipleAddresses verifies client behavior when an endpoint has multiple addresses and the first is unreachable. It validates that the pick_first falls through the address list and connects via the first reachable address, so per-call ORCA reports flow correctly.

(t *testing.T)

// pick_first falls through the address list and connects via the first
// reachable address, so per-call ORCA reports flow correctly.
func (s) TestEndpoints_MultipleAddresses(t *testing.T) {
	ctx, cancel := context.WithTimeout(context.Background(), defaultTestTimeout)
	defer cancel()

	srv := startORCAServer(t)
	if err := srv.StartClient(grpc.WithDefaultServiceConfig(orcaSvcConfig())); err != nil {
		t.Fatalf("Error starting client: %v", err)
	}

	// First address is unreachable; pick_first falls through to the good one.
	state := resolver.State{
		Endpoints: []resolver.Endpoint{
			{Addresses: []resolver.Address{
				{Addr: "bad-address"},
				{Addr: srv.Address},
			}},
		},
	}
	srv.R.UpdateState(state)
	// Transient errors while pick_first probes the bad address are expected.
	want := &v3orcapb.OrcaLoadReport{CpuUtilization: 0.42, MemUtilization: 0.21}
	for ; ctx.Err() == nil; <-time.After(100 * time.Millisecond) {
		orcaRes := &v3orcapb.OrcaLoadReport{}
		req := &testpb.SimpleRequest{
			OrcaPerQueryReport: &testpb.TestOrcaReport{
				CpuUtilization:    0.42,
				MemoryUtilization: 0.21,
			},
		}
		if _, err := srv.Client.UnaryCall(contextWithORCAResult(ctx, &orcaRes), req); err != nil {
			continue
		}
		if diff := cmp.Diff(orcaRes, want, protocmp.Transform()); diff != "" {
			t.Fatalf("Per-RPC ORCA mismatch (-got +want):\n%s", diff)
		}
		return
	}
	t.Fatalf("timed out waiting for connection through good address")
}

// TestMultipleEndpoints_OOBListeners verifies that N endpoints produce N
// independent pick_first instances and N independent OOB listeners, each