doRegister() — netty Function Reference

Source Code

transport-classes-kqueue/src/main/java/io/netty/channel/kqueue/AbstractKQueueChannel.java lines 201–225

    @Override
    protected void doRegister(ChannelPromise promise) {
        ((IoEventLoop) eventLoop()).register((AbstractKQueueUnsafe) unsafe()).addListener(f -> {
            if (f.isSuccess()) {
                this.registration = (IoRegistration) f.getNow();
                // Just in case the previous EventLoop was shutdown abruptly, or an event is still pending on the old
                // EventLoop make sure the readReadyRunnablePending variable is reset so we will be able to execute
                // the Runnable on the new EventLoop.
                readReadyRunnablePending = false;

                submit(KQueueIoOps.newOps(Native.EVFILT_SOCK, Native.EV_ADD, Native.NOTE_RDHUP));

                // Add the write event first so we get notified of connection refused on the client side!
                if (writeFilterEnabled) {
                    submit(Native.WRITE_ENABLED_OPS);
                }
                if (readFilterEnabled) {
                    submit(Native.READ_ENABLED_OPS);
                }
                promise.setSuccess();
            } else {
                promise.setFailure(f.cause());
            }
        });
    }