Class FilesTest

core/src/test/java/io/questdb/test/FilesTest.java:69–1769

import static io.questdb.test.tools.TestUtils.assertMemoryLeak;

public class FilesTest {
    private static final String EOL = System.lineSeparator();
    private static final Log LOG = LogFactory.getLog(FilesTest.class);
    @Rule
    public final TemporaryFolder temporaryFolder = new TemporaryFolder();

    @Test
    public void testAllocate() throws Exception {
        assertMemoryLeak(() -> {
            File temp = temporaryFolder.newFile();
            TestUtils.writeStringToFile(temp, "abcde");
            try (Path path = new Path().of(temp.getAbsolutePath())) {
                Assert.assertTrue(Files.exists(path.$()));
                Assert.assertEquals(5, Files.length(path.$()));

                long fd = Files.openRW(path.$());
                try {
                    Files.allocate(fd, 10);
                    Assert.assertEquals(10, Files.length(path.$()));
                    Files.allocate(fd, 120);
                    Assert.assertEquals(120, Files.length(path.$()));
                } finally {
                    Files.close(fd);
                }
            }
        });
    }

    @Test
    public void testAllocateConcurrent() throws IOException, InterruptedException {
        // This test allocates (but doesn't write to) potentially very large files
        // size of which will depend on free disk space of the host OS.
        // I found that on OSX (m1) with large disk allocate() call is painfully slow and
        // for that reason (until we understood the problem better) we won't run this test
        // on OSX
        Assume.assumeTrue(Os.type != Os.DARWIN);
        FilesFacade ff = TestFilesFacadeImpl.INSTANCE;

        String tmpFolder = temporaryFolder.newFolder("allocate").getAbsolutePath();
        assumeIsNotTmpFs(tmpFolder);
        AtomicInteger errors = new AtomicInteger();

        for (int i = 0; i < 10; i++) {
            Thread th1 = new Thread(() -> testAllocateConcurrent0(ff, tmpFolder, 1, errors));
            Thread th2 = new Thread(() -> testAllocateConcurrent0(ff, tmpFolder, 2, errors));
            th1.start();
            th2.start();
            th1.join();
            th2.join();
            Assert.assertEquals(0, errors.get());
        }
    }

    @Test
    public void testAllocateLoop() throws Exception {
        assertMemoryLeak(() -> {
            File temp = temporaryFolder.newFile();
            TestUtils.writeStringToFile(temp, "abcde");