From cc73117d6f926d7e54b5896c70cdacbf3133c14a Mon Sep 17 00:00:00 2001 From: Stepan Usatiuk Date: Thu, 3 Oct 2024 11:03:42 +0200 Subject: [PATCH] Server: add connected logs to fileConflictTest --- .../test/java/com/usatiuk/dhfs/integration/DhfsFusex3IT.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/dhfs-parent/server/src/test/java/com/usatiuk/dhfs/integration/DhfsFusex3IT.java b/dhfs-parent/server/src/test/java/com/usatiuk/dhfs/integration/DhfsFusex3IT.java index 518cea26..257661ed 100644 --- a/dhfs-parent/server/src/test/java/com/usatiuk/dhfs/integration/DhfsFusex3IT.java +++ b/dhfs-parent/server/src/test/java/com/usatiuk/dhfs/integration/DhfsFusex3IT.java @@ -268,9 +268,11 @@ public class DhfsFusex3IT { Assertions.assertEquals(0, container1.execInContainer("/bin/sh", "-c", "echo test1 >> /root/dhfs_default/fuse/testf").getExitCode()); client.unpauseContainerCmd(container2.getContainerId()).exec(); client.unpauseContainerCmd(container3.getContainerId()).exec(); + Log.warn("Waiting for connections"); waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("Connected"), 60, TimeUnit.SECONDS, 2); waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Connected"), 60, TimeUnit.SECONDS, 2); waitingConsumer3.waitUntil(frame -> frame.getUtf8String().contains("Connected"), 60, TimeUnit.SECONDS, 2); + Log.warn("Connected"); Thread.sleep(20000); for (var c : List.of(container1, container2, container3)) {