stepus53/dhfs
1
0
Fork 0
mirror of https://github.com/usatiuk/dhfs.git synced 2025-10-29 04:57:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

Dhfs-app: please work now

Browse Source
This commit is contained in:
Stepan Usatiuk
2025-04-24 15:48:57 +02:00
parent 1ae813aacd
commit 6685575ca5
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
dhfs-parent/dhfs-app/src/test/java/com/usatiuk/dhfs/integration/LazyFsIT.java
View File

@@ -300,9 +300,9 @@ public class LazyFsIT {
}); });
barrier.await(); barrier.await();
Thread.sleep(3000); Thread.sleep(3000);
container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting1");
Log.info("Killing"); Log.info("Killing");
lazyFs2.crash(); lazyFs2.crash();
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("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS);
var client = DockerClientFactory.instance().client(); var client = DockerClientFactory.instance().client();
client.killContainerCmd(container2.getContainerId()).exec(); client.killContainerCmd(container2.getContainerId()).exec();
@@ -334,13 +334,12 @@ public class LazyFsIT {
} }
}); });
barrier2.await(); barrier2.await();
Thread.sleep(3000);
container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting2");
Log.info("Killing"); Log.info("Killing");
Thread.sleep(3000);
if (crashType.equals(CrashType.CRASH)) { if (crashType.equals(CrashType.CRASH)) {
Thread.sleep(2000);
lazyFs2.crash(); lazyFs2.crash();
} }
container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting2");
waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS); waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS);
client.killContainerCmd(container2.getContainerId()).exec(); client.killContainerCmd(container2.getContainerId()).exec();
container2.stop(); container2.stop();
@@ -375,9 +374,9 @@ public class LazyFsIT {
}); });
barrier.await(); barrier.await();
Thread.sleep(3000); Thread.sleep(3000);
container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting1");
Log.info("Killing"); Log.info("Killing");
lazyFs2.crash(); lazyFs2.crash();
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("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS);
var client = DockerClientFactory.instance().client(); var client = DockerClientFactory.instance().client();
client.killContainerCmd(container2.getContainerId()).exec(); client.killContainerCmd(container2.getContainerId()).exec();
@@ -410,12 +409,11 @@ public class LazyFsIT {
}); });
barrier2.await(); barrier2.await();
Thread.sleep(3000); Thread.sleep(3000);
container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting2");
Log.info("Killing"); Log.info("Killing");
if (crashType.equals(CrashType.CRASH)) { if (crashType.equals(CrashType.CRASH)) {
Thread.sleep(2000);
lazyFs2.crash(); lazyFs2.crash();
} }
container1.execInContainer("/bin/sh", "-c", "touch /tmp/stopprinting2");
waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS); waitingConsumer2.waitUntil(frame -> frame.getUtf8String().contains("Caused by: org.lmdbjava"), 60, TimeUnit.SECONDS);
client.killContainerCmd(container2.getContainerId()).exec(); client.killContainerCmd(container2.getContainerId()).exec();
container2.stop(); container2.stop();