Method Kqueue

core/src/main/java/io/questdb/network/Kqueue.java:48–63

(KqueueFacade kqf, int capacity)

    private long writeAddress;

    public Kqueue(KqueueFacade kqf, int capacity) {
        try {
            this.kqf = kqf;
            this.capacity = capacity;
            this.bufferSize = KqueueAccessor.SIZEOF_KEVENT * capacity;
            this.changeList = this.writeAddress = Unsafe.calloc(bufferSize, MemoryTag.NATIVE_IO_DISPATCHER_RSS);
            this.eventList = this.readAddress = Unsafe.calloc(bufferSize, MemoryTag.NATIVE_IO_DISPATCHER_RSS);
            this.kq = Files.createUniqueFd(kqf.kqueue());
            if (kq < 0) {
                throw NetworkError.instance(kqf.getNetworkFacade().errno(), "could not create kqueue");
            }
        } catch (Throwable t) {
            close();
            throw t;
        }
    }

    @Override
    public void close() {