IoRegistration() — netty Function Reference

Source Code

transport/src/main/java/io/netty/channel/nio/NioIoHandler.java lines 392–416

    @Override
    public IoRegistration register(IoHandle handle)
            throws Exception {
        NioIoHandle nioHandle = nioHandle(handle);
        NioIoOps ops = NioIoOps.NONE;
        boolean selected = false;
        for (;;) {
            try {
                IoRegistration registration = new DefaultNioRegistration(executor, nioHandle, ops, unwrappedSelector());
                handle.registered();
                return registration;
            } catch (CancelledKeyException e) {
                if (!selected) {
                    // Force the Selector to select now as the "canceled" SelectionKey may still be
                    // cached and not removed because no Select.select(..) operation was called yet.
                    selectNow();
                    selected = true;
                } else {
                    // We forced a select operation on the selector before but the SelectionKey is still cached
                    // for whatever reason. JDK bug ?
                    throw e;
                }
            }
        }
    }