Method testSeek

core/src/test/java/io/questdb/test/network/NetTest.java:202–235

()

    }

    @Test
    public void testSeek() {
        String msg = "Test ABC";
        StringSink sink = new StringSink();
        try (Path msgSink = new Path().of(msg)) {
            int msgLen = msgSink.size() + 1;

            long acceptFd = Net.socketTcp(true);
            Assert.assertTrue(acceptFd > 0);
            int port = assertCanBind(acceptFd);
            Net.listen(acceptFd, 1024);

            long clientFd = Net.socketTcp(true);
            long sockAddr = Net.sockaddr("127.0.0.1", port);
            TestUtils.assertConnect(clientFd, sockAddr);
            Assert.assertEquals(msgLen, Net.send(clientFd, msgSink.$().ptr(), msgLen));
            Net.close(clientFd);
            Net.freeSockAddr(sockAddr);

            long serverFd = Net.accept(acceptFd);
            long serverBuf = Unsafe.malloc(msgLen, MemoryTag.NATIVE_IO_DISPATCHER_RSS);
            Assert.assertEquals(msgLen, Net.peek(serverFd, serverBuf, msgLen));
            Utf8s.utf8ToUtf16Z(serverBuf, sink);
            TestUtils.assertEquals(msg, sink);
            Assert.assertEquals(msgLen, Net.recv(serverFd, serverBuf, msgLen));
            sink.clear();
            Utf8s.utf8ToUtf16Z(serverBuf, sink);
            TestUtils.assertEquals(msg, sink);
            Unsafe.free(serverBuf, msgLen, MemoryTag.NATIVE_IO_DISPATCHER_RSS);
            Net.close(serverFd);

            Net.close(acceptFd);
        }
    }

    @Test
    public void testSendAndRecvBuffer() throws InterruptedException, BrokenBarrierException {