Modifier and Type	Class and Description
pack-priv static class	PendingWriteQueue.PendingWrite Holds all meta-data and construct the linked-list structure.

Modifier and Type	Field and Description
private long	bytes
private final EventExecutor	executor
private PendingWriteQueue.PendingWrite	head
private final ChannelOutboundInvoker	invoker
private static final InternalLogger	logger
private static final int	PENDING_WRITE_OVERHEAD
private int	size
private PendingWriteQueue.PendingWrite	tail
private final PendingBytesTracker	tracker

Access	Constructor and Description
public	PendingWriteQueue(ChannelHandlerContext ctx)
public	PendingWriteQueue(Channel channel)

Method Summary

Modifier and Type	Method and Description
public void	add(Object msg, ChannelPromise promise) Add the given `msg` and `ChannelPromise`.
private void	assertEmpty()
public long	bytes() Returns the total number of bytes that are pending because of pending messages.
public Object	current() Return the current message or `null` if empty.
public boolean	isEmpty() Returns `true` if there are no pending write operations left in this queue.
private void	recycle(PendingWriteQueue.PendingWrite write, boolean update)
public ChannelPromise	Returns: `ChannelPromise` of the pending write or `null` if the queue is empty. remove() Removes a pending write operation and release it's message via `ReferenceCountUtil#safeRelease(Object)`.
public void	removeAndFail(Throwable cause) Remove a pending write operation and fail it with the given `Throwable`.
public void	removeAndFailAll(Throwable cause) Remove all pending write operation and fail them with the given `Throwable`.
public ChannelFuture	Returns: `ChannelFuture` if something was written and `null` if the `PendingWriteQueue` is empty. removeAndWrite() Removes a pending write operation and performs it via `ChannelHandlerContext#write(Object, ChannelPromise)`.
public ChannelFuture	Returns: `ChannelFuture` if something was written and `null` if the `PendingWriteQueue` is empty. removeAndWriteAll() Remove all pending write operation and performs them via `ChannelHandlerContext#write(Object, ChannelPromise)`.
private static void	safeFail(ChannelPromise promise, Throwable cause)
public int	size() Returns the number of pending write operations.
private int	size(Object msg)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

bytes	back to summary
private long bytes

executor	back to summary
private final EventExecutor executor

head	back to summary
private PendingWriteQueue.PendingWrite head

invoker	back to summary
private final ChannelOutboundInvoker invoker

logger	back to summary
private static final InternalLogger logger

PENDING_WRITE_OVERHEAD	back to summary
private static final int PENDING_WRITE_OVERHEAD

size	back to summary
private int size

tail	back to summary
private PendingWriteQueue.PendingWrite tail

tracker	back to summary
private final PendingBytesTracker tracker

Constructor Detail

PendingWriteQueue	back to summary
public PendingWriteQueue(ChannelHandlerContext ctx)

PendingWriteQueue	back to summary
public PendingWriteQueue(Channel channel)

Method Detail

add	back to summary
public void add(Object msg, ChannelPromise promise) Add the given `msg` and `ChannelPromise`.

assertEmpty	back to summary
private void assertEmpty()

bytes	back to summary
public long bytes() Returns the total number of bytes that are pending because of pending messages. This is only an estimate so it should only be treated as a hint.

current	back to summary
public Object current() Return the current message or `null` if empty.

isEmpty	back to summary
public boolean isEmpty() Returns `true` if there are no pending write operations left in this queue.

recycle	back to summary
private void recycle(PendingWriteQueue.PendingWrite write, boolean update)

remove back to summary

remove	back to summary
public ChannelPromise remove() Removes a pending write operation and release it's message via `ReferenceCountUtil#safeRelease(Object)`. Returns:ChannelPromise `ChannelPromise` of the pending write or `null` if the queue is empty.

public ChannelPromise remove()

Removes a pending write operation and release it's message via ReferenceCountUtil#safeRelease(Object).

Returns:ChannelPromise: ChannelPromise of the pending write or null if the queue is empty.

removeAndFail	back to summary
public void removeAndFail(Throwable cause) Remove a pending write operation and fail it with the given `Throwable`. The message will be released via `ReferenceCountUtil#safeRelease(Object)`.

removeAndFailAll	back to summary
public void removeAndFailAll(Throwable cause) Remove all pending write operation and fail them with the given `Throwable`. The message will be released via `ReferenceCountUtil#safeRelease(Object)`.

removeAndWrite back to summary

removeAndWrite	back to summary
public ChannelFuture removeAndWrite() Removes a pending write operation and performs it via `ChannelHandlerContext#write(Object, ChannelPromise)`. Returns:ChannelFuture `ChannelFuture` if something was written and `null` if the `PendingWriteQueue` is empty.

public ChannelFuture removeAndWrite()

Removes a pending write operation and performs it via ChannelHandlerContext#write(Object, ChannelPromise).

Returns:ChannelFuture: ChannelFuture if something was written and null if the PendingWriteQueue is empty.

removeAndWriteAll back to summary

removeAndWriteAll	back to summary
public ChannelFuture removeAndWriteAll() Remove all pending write operation and performs them via `ChannelHandlerContext#write(Object, ChannelPromise)`. Returns:ChannelFuture `ChannelFuture` if something was written and `null` if the `PendingWriteQueue` is empty.

public ChannelFuture removeAndWriteAll()

Remove all pending write operation and performs them via ChannelHandlerContext#write(Object, ChannelPromise).

Returns:ChannelFuture: ChannelFuture if something was written and null if the PendingWriteQueue is empty.

safeFail	back to summary
private static void safeFail(ChannelPromise promise, Throwable cause)

size	back to summary
public int size() Returns the number of pending write operations.

size	back to summary
private int size(Object msg)

io.netty.channel back to summary

pack-priv final Class PendingWriteQueue.PendingWrite

Class Inheritance

extends Object

java.lang.Object
io.netty.channel.PendingWriteQueue.PendingWrite

Holds all meta-data and construct the linked-list structure.

Field Summary

Modifier and Type	Field and Description
private final ObjectPool.Handle<PendingWriteQueue.PendingWrite>	handle
private Object	msg
private PendingWriteQueue.PendingWrite	next
private ChannelPromise	promise
private static final ObjectPool<PendingWriteQueue.PendingWrite>	RECYCLER
private long	size

Constructor Summary

Access	Constructor and Description
private	PendingWrite(ObjectPool.Handle<PendingWriteQueue.PendingWrite> handle)

Method Summary

Modifier and Type	Method and Description
pack-priv static PendingWriteQueue.PendingWrite	newInstance(Object msg, int size, ChannelPromise promise)
private void	recycle()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

handle	back to summary
private final ObjectPool.Handle<PendingWriteQueue.PendingWrite> handle

msg	back to summary
private Object msg

next	back to summary
private PendingWriteQueue.PendingWrite next

promise	back to summary
private ChannelPromise promise

RECYCLER	back to summary
private static final ObjectPool<PendingWriteQueue.PendingWrite> RECYCLER

size	back to summary
private long size

Constructor Detail

PendingWrite	back to summary
private PendingWrite(ObjectPool.Handle<PendingWriteQueue.PendingWrite> handle)

Method Detail

newInstance	back to summary
pack-priv static PendingWriteQueue.PendingWrite newInstance(Object msg, int size, ChannelPromise promise)

recycle	back to summary
private void recycle()

public final Class PendingWriteQueue

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class PendingWriteQueue.PendingWrite

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail