stepus53/dhfs
1
0
Fork 0
mirror of https://github.com/usatiuk/dhfs.git synced 2025-10-28 20:47:49 +01:00
Code Issues Packages Projects Releases Wiki Activity

Dhfs-fuse: fix LazyFsIT tests

Browse Source
This commit is contained in:
Stepan Usatiuk
2025-05-10 16:24:33 +02:00
parent f544a67fb5
commit 3eb7164c0f
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
dhfs-parent/dhfs-fuse/src/test/java/com/usatiuk/dhfsfuse/integration/LazyFsIT.java
View File

@@ -154,7 +154,7 @@ public class LazyFsIT {
Thread.sleep(3000); Thread.sleep(3000);
Log.info("Killing"); Log.info("Killing");
lazyFs1.crash(); lazyFs1.crash();
waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS); waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("org.lmdbjava.LmdbNativeException"), 60, TimeUnit.SECONDS);
var client = DockerClientFactory.instance().client(); var client = DockerClientFactory.instance().client();
client.killContainerCmd(container1.getContainerId()).exec(); client.killContainerCmd(container1.getContainerId()).exec();
container1.stop(); container1.stop();
@@ -195,7 +195,7 @@ public class LazyFsIT {
lazyFs1.crash(); lazyFs1.crash();
} }
try { try {
waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS); waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("org.lmdbjava.LmdbNativeException"), 60, TimeUnit.SECONDS);
} catch (TimeoutException e) { } catch (TimeoutException e) {
// Sometimes crash doesn't work // Sometimes crash doesn't work
Log.info("Failed to crash: " + testInfo.getDisplayName()); Log.info("Failed to crash: " + testInfo.getDisplayName());
@@ -237,7 +237,7 @@ public class LazyFsIT {
Thread.sleep(3000); Thread.sleep(3000);
Log.info("Killing"); Log.info("Killing");
lazyFs1.crash(); lazyFs1.crash();
waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS); waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("org.lmdbjava.LmdbNativeException"), 60, TimeUnit.SECONDS);
var client = DockerClientFactory.instance().client(); var client = DockerClientFactory.instance().client();
client.killContainerCmd(container1.getContainerId()).exec(); client.killContainerCmd(container1.getContainerId()).exec();
container1.stop(); container1.stop();
@@ -279,7 +279,7 @@ public class LazyFsIT {
lazyFs1.crash(); lazyFs1.crash();
} }
try { try {
waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS); waitingConsumer1.waitUntil(frame -> frame.getUtf8String().contains("org.lmdbjava.LmdbNativeException"), 60, TimeUnit.SECONDS);
} catch (TimeoutException e) { } catch (TimeoutException e) {
// Sometimes crash doesn't work // Sometimes crash doesn't work
Log.info("Failed to crash: " + testInfo.getDisplayName()); Log.info("Failed to crash: " + testInfo.getDisplayName());
@@ -322,7 +322,7 @@ public class LazyFsIT {
Log.info("Killing"); Log.info("Killing");
lazyFs2.crash(); lazyFs2.crash();
container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting1"); container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting1");
waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS); waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("org.lmdbjava.LmdbNativeException"), 60, TimeUnit.SECONDS);
var client = DockerClientFactory.instance().client(); var client = DockerClientFactory.instance().client();
client.killContainerCmd(container2.getContainerId()).exec(); client.killContainerCmd(container2.getContainerId()).exec();
container2.stop(); container2.stop();
@@ -366,7 +366,7 @@ public class LazyFsIT {
} }
container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting2"); container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting2");
try { try {
waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS); waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("org.lmdbjava.LmdbNativeException"), 60, TimeUnit.SECONDS);
} catch (TimeoutException e) { } catch (TimeoutException e) {
// Sometimes crash doesn't work // Sometimes crash doesn't work
Log.info("Failed to crash: " + testInfo.getDisplayName()); Log.info("Failed to crash: " + testInfo.getDisplayName());
@@ -409,7 +409,7 @@ public class LazyFsIT {
Log.info("Killing"); Log.info("Killing");
lazyFs2.crash(); lazyFs2.crash();
container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting1"); container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting1");
waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS); waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("org.lmdbjava.LmdbNativeException"), 60, TimeUnit.SECONDS);
var client = DockerClientFactory.instance().client(); var client = DockerClientFactory.instance().client();
client.killContainerCmd(container2.getContainerId()).exec(); client.killContainerCmd(container2.getContainerId()).exec();
container2.stop(); container2.stop();
@@ -453,7 +453,7 @@ public class LazyFsIT {
} }
container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting2"); container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting2");
try { try {
waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS); waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("org.lmdbjava.LmdbNativeException"), 60, TimeUnit.SECONDS);
} catch (TimeoutException e) { } catch (TimeoutException e) {
// Sometimes crash doesn't work // Sometimes crash doesn't work
Log.info("Failed to crash: " + testInfo.getDisplayName()); Log.info("Failed to crash: " + testInfo.getDisplayName());