From e7f7b00e8b9614d7c4d9fe3fef20481872159b85 Mon Sep 17 00:00:00 2001 From: Hellblazer <hellblazer@me.com> Date: Sat, 23 Sep 2023 15:57:53 -0700 Subject: [PATCH] fix --- .../com/salesforce/apollo/ring/SyncSliceIteratorTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/memberships/src/test/java/com/salesforce/apollo/ring/SyncSliceIteratorTest.java b/memberships/src/test/java/com/salesforce/apollo/ring/SyncSliceIteratorTest.java index d6933f0dd..756d0f753 100644 --- a/memberships/src/test/java/com/salesforce/apollo/ring/SyncSliceIteratorTest.java +++ b/memberships/src/test/java/com/salesforce/apollo/ring/SyncSliceIteratorTest.java @@ -85,13 +85,13 @@ public Any ping(Any request) { var scheduler = Executors.newSingleThreadScheduledExecutor(); var exec = Executors.newVirtualThreadPerTaskExecutor(); var slice = new SynchSliceIterator<TestItService>("Test Me", serverMember1, Arrays.asList(serverMember1, serverMember2), commsA, exec); - var countdown = new CountDownLatch(2); + var countdown = new CountDownLatch(1); slice.iterate((link, member) -> link.ping(Any.getDefaultInstance()), (result, comms, member) -> true, () -> { countdown.countDown(); }, Executors.newSingleThreadScheduledExecutor(), Duration.ofMillis(1)); - boolean finished = countdown.await(1, TimeUnit.SECONDS); + boolean finished = countdown.await(3, TimeUnit.SECONDS); assertTrue(finished, "completed: " + countdown.getCount()); - assertFalse(pinged1.get()); + assertTrue(pinged1.get()); assertTrue(pinged2.get()); } }