Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

Try to fix failing tests on Windows S1E2

Browse Source
This commit is contained in:
Per Minborg
2020-09-03 09:00:50 +02:00
parent 6b4b995219
commit aa3658e890
1 changed files with 74 additions and 71 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/net/openhft/chronicle/map/FileLockUtilTest.java
+74 -71
View File
@@ -4,7 +4,6 @@ import net.openhft.chronicle.core.OS;
import net.openhft.chronicle.hash.ChronicleFileLockException;
import net.openhft.chronicle.hash.impl.util.CanonicalRandomAccessFiles;
import org.junit.After;
import org.junit.Assume;
import org.junit.Before;
import org.junit.Test;
@@ -40,81 +39,85 @@ public class FileLockUtilTest {
@Test
public void testShared() {
doNotRunOnWindows();
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
FileLockUtil.releaseFileLock(canonicalFile);
}
@Test
public void testExclusiveNormalCase() {
doNotRunOnWindows();
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
}
@Test
public void testTryExclusiveButWasShared() {
doNotRunOnWindows();
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
try {
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
fail();
} catch (ChronicleFileLockException ignore) {
}
FileLockUtil.releaseFileLock(canonicalFile);
}
@Test
public void testTrySharedButWasExclusive() {
doNotRunOnWindows();
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
try {
if (!OS.isWindows()) {
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
fail();
} catch (ChronicleFileLockException ignore) {
}
FileLockUtil.releaseFileLock(canonicalFile);
}
@Test
public void testComplicated() {
doNotRunOnWindows();
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
FileLockUtil.releaseFileLock(canonicalFile);
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
}
@Test
public void testRunExclusively() {
doNotRunOnWindows();
final AtomicInteger cnt = new AtomicInteger();
FileLockUtil.runExclusively(canonicalFile, fileChannel, cnt::incrementAndGet);
assertEquals(1, cnt.get());
}
@Test
public void testRunExclusivelyButUsed() {
doNotRunOnWindows();
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
try {
FileLockUtil.runExclusively(canonicalFile, fileChannel, () -> {});
fail();
} catch (ChronicleFileLockException e) {
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
FileLockUtil.releaseFileLock(canonicalFile);
}
}
private void doNotRunOnWindows() {
Assume.assumeFalse(OS.isWindows());
@Test
public void testExclusiveNormalCase() {
if (!OS.isWindows()) {
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
}
}
@Test
public void testTryExclusiveButWasShared() {
if (!OS.isWindows()) {
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
try {
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
fail();
} catch (ChronicleFileLockException ignore) {
}
FileLockUtil.releaseFileLock(canonicalFile);
}
}
@Test
public void testTrySharedButWasExclusive() {
if (!OS.isWindows()) {
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
try {
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
fail();
} catch (ChronicleFileLockException ignore) {
}
FileLockUtil.releaseFileLock(canonicalFile);
}
}
@Test
public void testComplicated() {
if (!OS.isWindows()) {
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
FileLockUtil.releaseFileLock(canonicalFile);
FileLockUtil.acquireExclusiveFileLock(canonicalFile, fileChannel);
FileLockUtil.releaseFileLock(canonicalFile);
}
}
@Test
public void testRunExclusively() {
if (!OS.isWindows()) {
final AtomicInteger cnt = new AtomicInteger();
FileLockUtil.runExclusively(canonicalFile, fileChannel, cnt::incrementAndGet);
assertEquals(1, cnt.get());
}
}
@Test
public void testRunExclusivelyButUsed() {
if (!OS.isWindows()) {
FileLockUtil.acquireSharedFileLock(canonicalFile, fileChannel);
try {
FileLockUtil.runExclusively(canonicalFile, fileChannel, () -> {
});
fail();
} catch (ChronicleFileLockException e) {
FileLockUtil.releaseFileLock(canonicalFile);
}
}
}
}