Class AbstractKQueueChannel.AbstractKQueueUnsafe

    • Field Detail

      • readPending

        boolean readPending
      • maybeMoreDataToRead

        boolean maybeMoreDataToRead
      • readReadyRunnable

        private final java.lang.Runnable readReadyRunnable
    • Constructor Detail

      • AbstractKQueueUnsafe

        public AbstractKQueueUnsafe()
    • Method Detail

      • readReady

        final void readReady​(long numberBytesPending)
      • readReadyBefore

        final void readReadyBefore()
      • readReadyFinally

        final void readReadyFinally​(ChannelConfig config)
      • failConnectPromise

        final boolean failConnectPromise​(java.lang.Throwable cause)
      • writeReady

        final void writeReady()
      • shutdownInput

        void shutdownInput​(boolean readEOF)
        Shutdown the input side of the channel.
      • readEOF

        final void readEOF()
      • executeReadReadyRunnable

        final void executeReadReadyRunnable​(ChannelConfig config)
      • clearReadFilter0

        protected final void clearReadFilter0()
      • fireEventAndClose

        private void fireEventAndClose​(java.lang.Object evt)
      • connect

        public void connect​(java.net.SocketAddress remoteAddress,
                            java.net.SocketAddress localAddress,
                            ChannelPromise promise)
        Description copied from interface: Channel.Unsafe
        Connect the Channel of the given ChannelFuture with the given remote SocketAddress. If a specific local SocketAddress should be used it need to be given as argument. Otherwise just pass null to it. The ChannelPromise will get notified once the connect operation was complete.
      • fulfillConnectPromise

        private void fulfillConnectPromise​(ChannelPromise promise,
                                           boolean wasActive)
      • fulfillConnectPromise

        private void fulfillConnectPromise​(ChannelPromise promise,
                                           java.lang.Throwable cause)
      • finishConnect

        private void finishConnect()
      • doFinishConnect

        private boolean doFinishConnect()
                                 throws java.lang.Exception
        Throws:
        java.lang.Exception