Class IOUringRecvByteAllocatorHandle

java.lang.Object
io.netty.channel.RecvByteBufAllocator.DelegatingHandle
io.netty.incubator.channel.uring.IOUringRecvByteAllocatorHandle
All Implemented Interfaces:
io.netty.channel.RecvByteBufAllocator.ExtendedHandle, io.netty.channel.RecvByteBufAllocator.Handle
final class IOUringRecvByteAllocatorHandle extends io.netty.channel.RecvByteBufAllocator.DelegatingHandle implements io.netty.channel.RecvByteBufAllocator.ExtendedHandle

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final io.netty.channel.unix.PreferredDirectByteBufAllocator
    preferredDirectByteBufAllocator
     
    private boolean
    rdHupReceived
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    IOUringRecvByteAllocatorHandle(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.netty.buffer.ByteBuf
    allocate(io.netty.buffer.ByteBufAllocator alloc)
     
    boolean
    continueReading()
     
    boolean
    continueReading(io.netty.util.UncheckedBooleanSupplier maybeMoreDataSupplier)
     
    (package private) void
    rdHupReceived()
     

    Methods inherited from class io.netty.channel.RecvByteBufAllocator.DelegatingHandle

    attemptedBytesRead, attemptedBytesRead, delegate, guess, incMessagesRead, lastBytesRead, lastBytesRead, readComplete, reset

    Methods inherited from class Object

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

    Methods inherited from interface io.netty.channel.RecvByteBufAllocator.Handle

    attemptedBytesRead, attemptedBytesRead, guess, incMessagesRead, lastBytesRead, lastBytesRead, readComplete, reset

  • Field Details

    • preferredDirectByteBufAllocator

      private final io.netty.channel.unix.PreferredDirectByteBufAllocator preferredDirectByteBufAllocator

    • rdHupReceived

      private boolean rdHupReceived

  • Constructor Details

    • IOUringRecvByteAllocatorHandle

      IOUringRecvByteAllocatorHandle(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle)

  • Method Details

    • rdHupReceived

      void rdHupReceived()

    • allocate

      public io.netty.buffer.ByteBuf allocate(io.netty.buffer.ByteBufAllocator alloc)
      Specified by:
      allocate in interface io.netty.channel.RecvByteBufAllocator.Handle
      Overrides:
      allocate in class io.netty.channel.RecvByteBufAllocator.DelegatingHandle

    • continueReading

      public boolean continueReading()
      Specified by:
      continueReading in interface io.netty.channel.RecvByteBufAllocator.Handle
      Overrides:
      continueReading in class io.netty.channel.RecvByteBufAllocator.DelegatingHandle

    • continueReading

      public boolean continueReading(io.netty.util.UncheckedBooleanSupplier maybeMoreDataSupplier)
      Specified by:
      continueReading in interface io.netty.channel.RecvByteBufAllocator.ExtendedHandle