Function pollORCAResult

interop/orcalb_test.go:350–363

(ctx context.Context, t *testing.T, tc testgrpc.TestServiceClient, want *v3orcapb.OrcaLoadReport)

}

func pollORCAResult(ctx context.Context, t *testing.T, tc testgrpc.TestServiceClient, want *v3orcapb.OrcaLoadReport) {
	t.Helper()
	for ; ctx.Err() == nil; <-time.After(time.Second) {
		orcaRes := &v3orcapb.OrcaLoadReport{}
		if _, err := tc.UnaryCall(contextWithORCAResult(ctx, &orcaRes), &testpb.SimpleRequest{}); err != nil {
			t.Fatalf("UnaryCall failed: %v", err)
		}
		if diff := cmp.Diff(orcaRes, want, protocmp.Transform()); diff == "" {
			return
		}
		t.Logf("ORCA load report = %v; want %v; retrying...", orcaRes, want)
	}
	t.Fatalf("Timed out waiting for expected ORCA load report %v", want)
}