Package io.netty.channel.uring
Class PendingZeroCopyWrites.PendingWrite
- java.lang.Object
-
- io.netty.channel.uring.PendingZeroCopyWrites.PendingWrite
-
- All Implemented Interfaces:
ChannelOutboundBuffer.MessageProcessor
- Enclosing class:
- PendingZeroCopyWrites
static final class PendingZeroCopyWrites.PendingWrite extends java.lang.Object implements ChannelOutboundBuffer.MessageProcessor
-
-
Field Summary
Fields Modifier and Type Field Description private intcountprivate ReferenceCounted[]referencesprivate intremaining
-
Constructor Summary
Constructors Constructor Description PendingWrite()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) voidadd(ReferenceCounted reference)booleanprocessMessage(java.lang.Object msg)Will be called for each flushed message until it either there are no more flushed messages or this method returnsfalse.private voidrelease()(package private) voidretain(ChannelOutboundBuffer buffer, int iovCount)
-
-
-
Field Detail
-
references
private ReferenceCounted[] references
-
count
private int count
-
remaining
private int remaining
-
-
Method Detail
-
retain
void retain(ChannelOutboundBuffer buffer, int iovCount)
-
processMessage
public boolean processMessage(java.lang.Object msg)
Description copied from interface:ChannelOutboundBuffer.MessageProcessorWill be called for each flushed message until it either there are no more flushed messages or this method returnsfalse.- Specified by:
processMessagein interfaceChannelOutboundBuffer.MessageProcessor
-
add
void add(ReferenceCounted reference)
-
release
private void release()
-
-