Method close

core/src/main/java/io/questdb/network/Kqueue.java:65–70

()

    }

    @Override
    public void close() {
        kqf.getNetworkFacade().close(kq, LOG);
        Unsafe.free(this.changeList, bufferSize, MemoryTag.NATIVE_IO_DISPATCHER_RSS);
        Unsafe.free(this.eventList, bufferSize, MemoryTag.NATIVE_IO_DISPATCHER_RSS);
    }

    public long getData() {
        return Unsafe.getLong(readAddress + KqueueAccessor.DATA_OFFSET);