Class AbstractIoUringStreamChannel.IovBufferCollector

java.lang.Object
io.netty.channel.uring.AbstractIoUringStreamChannel.IovBufferCollector
All Implemented Interfaces:
ChannelOutboundBuffer.MessageProcessor
Enclosing class:
AbstractIoUringStreamChannel
static final class AbstractIoUringStreamChannel.IovBufferCollector extends java.lang.Object implements ChannelOutboundBuffer.MessageProcessor
Collects and retains the messages backing a submitted iov prefix. Keep the non-empty NIO segment counting aligned with IovArray.add(ByteBuf, int, int). The readable ranges must still match those used at submission; the shared iov memory itself may already have been reused.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private java.util.List<ReferenceCounted>
    buffers
     
    private int
    remaining
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    IovBufferCollector()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) java.util.List<ReferenceCounted>
    collect(ChannelOutboundBuffer buffer, int count)
     
    boolean
    processMessage(java.lang.Object msg)
    Will be called for each flushed message until it either there are no more flushed messages or this method returns false.
    (package private) static int
    remainingIovs(ByteBuf buf, int remaining)
     

    Methods inherited from class java.lang.Object

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