Method TestORCAOOBFallback

interop/orcalb_test.go:132–176

TestORCAOOBFallback verifies the fallback behavior: when a per-call report is present but has all zero fields, the picker uses the most recent OOB report instead.

(t *testing.T)

// is present but has all zero fields, the picker uses the most recent OOB
// report instead.
func (s) TestORCAOOBFallback(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)
	}

	stream, err := srv.Client.FullDuplexCall(ctx)
	if err != nil {
		t.Fatalf("FullDuplexCall failed: %v", err)
	}
	req := &testpb.StreamingOutputCallRequest{
		OrcaOobReport: &testpb.TestOrcaReport{
			CpuUtilization:    0.73,
			MemoryUtilization: 0.55,
			Utilization:       map[string]float64{"util": 0.42},
		},
		ResponseParameters: []*testpb.ResponseParameters{{Size: 1}},
	}
	if err := stream.Send(req); err != nil {
		t.Fatalf("stream.Send failed: %v", err)
	}
	if _, err := stream.Recv(); err != nil {
		t.Fatalf("stream.Recv failed: %v", err)
	}

	oobWant := &v3orcapb.OrcaLoadReport{
		CpuUtilization: 0.73,
		MemUtilization: 0.55,
		Utilization:    map[string]float64{"util": 0.42},
	}
	pollORCAResult(ctx, t, srv.Client, oobWant)

	// OrcaPerQueryReport is nil: per-call report has all-zero fields,
	// triggering the OOB fallback path in orcaPicker.
	orcaRes := &v3orcapb.OrcaLoadReport{}
	if _, err := srv.Client.UnaryCall(contextWithORCAResult(ctx, &orcaRes), &testpb.SimpleRequest{}); err != nil {
		t.Fatalf("UnaryCall failed: %v", err)
	}
	if diff := cmp.Diff(orcaRes, oobWant, protocmp.Transform()); diff != "" {
		t.Fatalf("ORCA load report with zero per-call mismatch (-got +want):\n%s", diff)
	}
}

// TestEndpoints_MultipleAddresses verifies client behavior when an endpoint has
// multiple addresses and the first is unreachable. It validates that the