Class KQueueIoHandler.DefaultKqueueIoRegistration

java.lang.Object
io.netty.channel.kqueue.KQueueIoHandler.DefaultKqueueIoRegistration
All Implemented Interfaces:
IoRegistration
Enclosing class:
KQueueIoHandler
private final class KQueueIoHandler.DefaultKqueueIoRegistration extends java.lang.Object implements IoRegistration

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final java.util.concurrent.atomic.AtomicBoolean
    canceled
     
    private boolean
    cancellationPending
     
    private final KQueueIoEvent
    event
     
    private final ThreadAwareExecutor
    executor
     
    (package private) final KQueueIoHandle
    handle
     
    (package private) final long
    id
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultKqueueIoRegistration(ThreadAwareExecutor executor, KQueueIoHandle handle)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    <T> T
    attachment()
    Implementation specific attachment, which might be null.
    boolean
    cancel()
    Cancel the registration.
    private void
    cancel0()
     
    (package private) void
    close()
     
    private void
    evSet(short filter, short flags, int fflags, long data)
     
    (package private) void
    handle(int ident, short filter, short flags, int fflags, long data, long udata)
     
    (package private) boolean
    isHandleForChannel()
     
    boolean
    isValid()
    Returns true if the registration is still valid.
    long
    submit(IoOps ops)
    Submit the IoOps to the registration.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • cancellationPending

      private boolean cancellationPending

    • canceled

      private final java.util.concurrent.atomic.AtomicBoolean canceled

    • event

      private final KQueueIoEvent event

    • handle

      final KQueueIoHandle handle

    • id

      final long id

    • executor

      private final ThreadAwareExecutor executor

  • Constructor Details

  • Method Details

    • isHandleForChannel

      boolean isHandleForChannel()

    • attachment

      public <T> T attachment()
      Description copied from interface: IoRegistration
      Implementation specific attachment, which might be null.
      Specified by:
      attachment in interface IoRegistration
      Returns:
      attachment.

    • submit

      public long submit(IoOps ops)
      Description copied from interface: IoRegistration
      Submit the IoOps to the registration.
      Specified by:
      submit in interface IoRegistration
      Parameters:
      ops - ops.
      Returns:
      an identifier for the operation, which might be unique or not (depending on the implementation).

    • handle

      void handle(int ident, short filter, short flags, int fflags, long data, long udata)

    • evSet

      private void evSet(short filter, short flags, int fflags, long data)

    • isValid

      public boolean isValid()
      Description copied from interface: IoRegistration
      Returns true if the registration is still valid. Once IoRegistration.cancel() is called this will return false.
      Specified by:
      isValid in interface IoRegistration
      Returns:
      valid.

    • cancel

      public boolean cancel()
      Description copied from interface: IoRegistration
      Cancel the registration.
      Specified by:
      cancel in interface IoRegistration
      Returns:
      true if cancellation was successful, false otherwise.

    • cancel0

      private void cancel0()

    • close

      void close()