Class AbstractEpollChannel.AbstractEpollUnsafe

    • Field Detail

      • readPending

        boolean readPending
      • maybeMoreDataToRead

        boolean maybeMoreDataToRead
      • epollInReadyRunnable

        private final java.lang.Runnable epollInReadyRunnable
    • Constructor Detail

      • AbstractEpollUnsafe

        protected AbstractEpollUnsafe()
    • Method Detail

      • epollInReady

        abstract void epollInReady()
        Called once EPOLLIN event is ready to be processed
      • epollInBefore

        final void epollInBefore()
      • epollInFinally

        final void epollInFinally​(ChannelConfig config)
      • executeEpollInReadyRunnable

        final void executeEpollInReadyRunnable​(ChannelConfig config)
      • epollRdHupReady

        final void epollRdHupReady()
        Called once EPOLLRDHUP event is ready to be processed
      • clearEpollRdHup

        private void clearEpollRdHup()
        Clear the Native.EPOLLRDHUP flag from EPOLL, and close on failure.
      • shutdownInput

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

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

        final void epollOutReady()
        Called once a EPOLLOUT event is ready to be processed
      • clearEpollIn0

        protected final void clearEpollIn0()
      • 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
        Finish the connect
        Throws:
        java.lang.Exception