Skip to content

Commit ecb2210

Browse files
authored
interop-test: test_orca_oob add retry limit 5 (grpc#9251)
1 parent 746cb15 commit ecb2210

File tree

1 file changed

+18
-6
lines changed

1 file changed

+18
-6
lines changed

interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java

+18-6
Original file line numberDiff line numberDiff line change
@@ -1765,19 +1765,31 @@ public void testOrcaOob() throws Exception {
17651765
.putUtilization("util", 0.30499)
17661766
.build();
17671767
blockingStub.unaryCall(SimpleRequest.newBuilder().setOrcaOobReport(answer).build());
1768-
Thread.sleep(1500);
1769-
blockingStub.withOption(ORCA_OOB_REPORT_KEY, reportHolder).emptyCall(EMPTY);
1770-
assertThat(reportHolder.get()).isEqualTo(answer);
1768+
int i;
1769+
int retryLimit = 5;
1770+
for (i = 0; i < retryLimit; i++) {
1771+
Thread.sleep(1000);
1772+
blockingStub.withOption(ORCA_OOB_REPORT_KEY, reportHolder).emptyCall(EMPTY);
1773+
if (reportHolder.get().equals(answer)) {
1774+
break;
1775+
}
1776+
}
1777+
assertThat(i).isLessThan(retryLimit);
17711778

17721779
answer = TestOrcaReport.newBuilder()
17731780
.setCpuUtilization(0.29309)
17741781
.setMemoryUtilization(0.2)
17751782
.putUtilization("util", 100.2039)
17761783
.build();
17771784
blockingStub.unaryCall(SimpleRequest.newBuilder().setOrcaOobReport(answer).build());
1778-
Thread.sleep(1500);
1779-
blockingStub.withOption(ORCA_OOB_REPORT_KEY, reportHolder).emptyCall(EMPTY);
1780-
assertThat(reportHolder.get()).isEqualTo(answer);
1785+
for (i = 0; i < retryLimit; i++) {
1786+
Thread.sleep(1000);
1787+
blockingStub.withOption(ORCA_OOB_REPORT_KEY, reportHolder).emptyCall(EMPTY);
1788+
if (reportHolder.get().equals(answer)) {
1789+
break;
1790+
}
1791+
}
1792+
assertThat(i).isLessThan(retryLimit);
17811793
}
17821794

17831795
/** Sends a large unary rpc with service account credentials. */

0 commit comments

Comments
 (0)