failSpliceIfClosed() — netty Function Reference

Source Code

transport-classes-epoll/src/main/java/io/netty/channel/epoll/AbstractEpollStreamChannel.java lines 226–243

    private void failSpliceIfClosed(ChannelPromise promise) {
        if (!isOpen()) {
            // Seems like the Channel was closed in the meantime try to fail the promise to prevent any
            // cases where a future may not be notified otherwise.
            if (!promise.isDone()) {
                final ClosedChannelException ex = new ClosedChannelException();
                if (promise.tryFailure(ex)) {
                    eventLoop().execute(new Runnable() {
                        @Override
                        public void run() {
                            // Call this via the EventLoop as it is a MPSC queue.
                            clearSpliceQueue(ex);
                        }
                    });
                }
            }
        }
    }