Class AbstractKQueueServerChannel

    • Field Detail

      • active

        protected volatile boolean active
    • Method Detail

      • remoteAddress0

        protected java.net.InetSocketAddress remoteAddress0()
        Description copied from class: AbstractChannel
        Return the SocketAddress which the Channel is connected to.
      • doConnect

        protected boolean doConnect​(java.net.SocketAddress remoteAddress,
                                    java.net.SocketAddress localAddress)
                             throws java.lang.Exception
        Connect to the remote peer
        Throws:
        java.lang.Exception
      • isActive

        public boolean isActive()
        Description copied from interface: Channel
        Return true if the Channel is active and so connected.
        Specified by:
        isActive in interface Channel
      • doDisconnect

        protected void doDisconnect()
                             throws java.lang.Exception
        Description copied from class: AbstractChannel
        Disconnect this Channel from its remote peer
        Specified by:
        doDisconnect in class AbstractChannel
        Throws:
        java.lang.Exception
      • isOpen

        public boolean isOpen()
        Description copied from interface: Channel
        Returns true if the Channel is open and may get active later
        Specified by:
        isOpen in interface Channel
      • doBeginRead

        protected final void doBeginRead()
                                  throws java.lang.Exception
        Description copied from class: AbstractChannel
        Schedule a read operation.
        Specified by:
        doBeginRead in class AbstractChannel
        Throws:
        java.lang.Exception
      • newDirectBuffer

        protected final ByteBuf newDirectBuffer​(ByteBuf buf)
        Returns an off-heap copy of the specified ByteBuf, and releases the original one.
      • newDirectBuffer

        protected final ByteBuf newDirectBuffer​(java.lang.Object holder,
                                                ByteBuf buf)
        Returns an off-heap copy of the specified ByteBuf, and releases the specified holder. The caller must ensure that the holder releases the original ByteBuf when the holder is released by this method.
      • checkResolvable

        protected static void checkResolvable​(java.net.InetSocketAddress addr)
      • doReadBytes

        protected final int doReadBytes​(ByteBuf byteBuf)
                                 throws java.lang.Exception
        Read bytes into the given ByteBuf and return the amount.
        Throws:
        java.lang.Exception
      • doWriteBytes

        protected final int doWriteBytes​(ChannelOutboundBuffer in,
                                         ByteBuf buf)
                                  throws java.lang.Exception
        Throws:
        java.lang.Exception
      • doBind

        protected void doBind​(java.net.SocketAddress local)
                       throws java.lang.Exception
        Description copied from class: AbstractChannel
        Bind the Channel to the SocketAddress
        Specified by:
        doBind in class AbstractChannel
        Throws:
        java.lang.Exception
      • doConnect0

        protected boolean doConnect0​(java.net.SocketAddress remoteAddress,
                                     java.net.SocketAddress localAddress)
                              throws java.lang.Exception
        Throws:
        java.lang.Exception
      • localAddress0

        protected java.net.SocketAddress localAddress0()
        Description copied from class: AbstractChannel
        Returns the SocketAddress which is bound locally.
        Specified by:
        localAddress0 in class AbstractChannel