Class IoUringServerDomainSocketChannel

    • Field Detail

      • active

        protected volatile boolean active
    • Constructor Detail

      • IoUringServerDomainSocketChannel

        public IoUringServerDomainSocketChannel()
    • Method Detail

      • config

        public ChannelConfig config()
        Description copied from interface: Channel
        Returns the configuration of this channel.
        Specified by:
        config in interface Channel
      • 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.
      • 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 final void doClose()
                              throws java.lang.Exception
        Description copied from class: AbstractChannel
        Close the Channel
        Throws:
        java.lang.Exception
      • cancelOutstandingReads

        protected final void cancelOutstandingReads​(IoRegistration registration,
                                                    int numOutstandingReads)
        Cancel all outstanding reads
        Parameters:
        registration - the IoRegistration.
        numOutstandingReads - the number of outstanding reads, or -1 if multi-shot was used.
      • cancelOutstandingWrites

        protected final void cancelOutstandingWrites​(IoRegistration registration,
                                                     int numOutstandingWrites)
        Cancel all outstanding writes
        Parameters:
        registration - the IoRegistration.
        numOutstandingWrites - the number of outstanding writes.
      • socketIsEmpty

        protected boolean socketIsEmpty​(int flags)
        Return if the socket is guaranteed to be empty when the submitted io was executed and the completion event be created.
        Parameters:
        flags - the flags that were part of the completion
        Returns:
        true if empty.
      • nextOpsId

        protected final short nextOpsId()
        Returns the next id that should be used when submitting IoUringIoOps.
        Returns:
        opsId
      • isOpen

        public final 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
      • 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
      • newDirectBuffer

        protected final ByteBuf newDirectBuffer​(ByteBuf buf)
      • allowMultiShotPollIn

        protected boolean allowMultiShotPollIn()
      • newDirectBuffer

        protected final ByteBuf newDirectBuffer​(java.lang.Object holder,
                                                ByteBuf buf)
      • 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
      • scheduleWriteIfNeeded

        protected void scheduleWriteIfNeeded​(ChannelOutboundBuffer in,
                                             boolean submitAndRunNow)
      • submitAndRunNow

        protected void submitAndRunNow()
      • checkResolvable

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

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