--- a/test/jdk/java/net/httpclient/http2/BasicTest.java Tue Nov 28 18:03:56 2017 +0300
+++ b/test/jdk/java/net/httpclient/http2/BasicTest.java Wed Nov 29 11:15:19 2017 +0000
@@ -103,6 +103,7 @@
currentCF.getAndUpdate((cf) -> {
if (cf == null || cf.isDone()) {
cf = exchange.sendPing();
+ assert cf != null;
cfs.add(cf);
}
return cf;
@@ -123,8 +124,10 @@
paramsTest();
Thread.sleep(1000 * 4);
CompletableFuture.allOf(cfs.toArray(new CompletableFuture[0])).join();
- for (CompletableFuture<Long> cf : cfs) {
- System.out.printf("Ping ack received in %d millisec\n", cf.get());
+ synchronized (cfs) {
+ for (CompletableFuture<Long> cf : cfs) {
+ System.out.printf("Ping ack received in %d millisec\n", cf.get());
+ }
}
} catch (Throwable tt) {
System.err.println("tt caught");