From 005bc35496241549b181f6e35be25b74b0feb344 Mon Sep 17 00:00:00 2001 From: Stepan Usatiuk Date: Thu, 24 Apr 2025 16:32:25 +0200 Subject: [PATCH] Dhfs-app: assume lazyfs doesn't crash too early --- .../usatiuk/dhfs/integration/LazyFsIT.java | 19 ++++++++++++++----- 1 file changed, 14 insertions(+), 5 deletions(-) diff --git a/dhfs-parent/dhfs-app/src/test/java/com/usatiuk/dhfs/integration/LazyFsIT.java b/dhfs-parent/dhfs-app/src/test/java/com/usatiuk/dhfs/integration/LazyFsIT.java index b12d752a..6fa18d5e 100644 --- a/dhfs-parent/dhfs-app/src/test/java/com/usatiuk/dhfs/integration/LazyFsIT.java +++ b/dhfs-parent/dhfs-app/src/test/java/com/usatiuk/dhfs/integration/LazyFsIT.java @@ -320,9 +320,13 @@ public class LazyFsIT { waitingConsumer2 = new WaitingConsumer(); var loggingConsumer2 = new Slf4jLogConsumer(LoggerFactory.getLogger(LazyFsIT.class)).withPrefix("2-" + testInfo.getDisplayName()); container2.followOutput(loggingConsumer2.andThen(waitingConsumer2)); - waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Connected"), 60, TimeUnit.SECONDS); - waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("Connected"), 60, TimeUnit.SECONDS); - + try { + waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Connected"), 60, TimeUnit.SECONDS); + waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("Connected"), 60, TimeUnit.SECONDS); + } catch (TimeoutException e) { + // LazyFs can crash too early + Assumptions.assumeTrue(false); + } var barrier2 = new CountDownLatch(1); executor.submit(() -> { try { @@ -394,8 +398,13 @@ public class LazyFsIT { waitingConsumer2 = new WaitingConsumer(); var loggingConsumer2 = new Slf4jLogConsumer(LoggerFactory.getLogger(LazyFsIT.class)).withPrefix("2-" + testInfo.getDisplayName()); container2.followOutput(loggingConsumer2.andThen(waitingConsumer2)); - waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Connected"), 60, TimeUnit.SECONDS); - waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("Connected"), 60, TimeUnit.SECONDS); + try { + waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Connected"), 60, TimeUnit.SECONDS); + waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("Connected"), 60, TimeUnit.SECONDS); + } catch (TimeoutException e) { + // LazyFs can crash too early + Assumptions.assumeTrue(false); + } var barrier2 = new CountDownLatch(1); executor.submit(() -> {