Class EpollServerDomainSocketChannel

    • Field Detail

      • active

        protected volatile boolean active
    • Constructor Detail

      • EpollServerDomainSocketChannel

        public EpollServerDomainSocketChannel()
      • EpollServerDomainSocketChannel

        public EpollServerDomainSocketChannel​(int fd)
      • EpollServerDomainSocketChannel

        public EpollServerDomainSocketChannel​(int fd,
                                              boolean active)
    • Method Detail

      • doBind

        protected void doBind​(java.net.SocketAddress localAddress)
                       throws java.lang.Exception
        Description copied from class: AbstractChannel
        Bind the Channel to the SocketAddress
        Throws:
        java.lang.Exception
      • doClose

        protected void doClose()
                        throws java.lang.Exception
        Description copied from class: AbstractChannel
        Close the Channel
        Throws:
        java.lang.Exception
      • localAddress

        public DomainSocketAddress localAddress()
        Description copied from interface: Channel
        Returns the local address where this channel is bound to. The returned SocketAddress is supposed to be down-cast into more concrete type such as InetSocketAddress to retrieve the detailed information.
        Specified by:
        localAddress in interface Channel
        Specified by:
        localAddress in interface ServerDomainSocketChannel
        Overrides:
        localAddress in class AbstractChannel
        Returns:
        the local address of this channel. null if this channel is not bound.
      • setFlag

        protected void setFlag​(int flag)
                        throws java.io.IOException
        Throws:
        java.io.IOException
      • 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 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