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 static final InternalLogger	logger
private static final int	PENDING_WRITE_OVERHEAD
private int	size
private final MessageSizeEstimator.Handle	sizeEstimatorHandle
private PendingWriteQueue.PendingWrite	tail

Access	Constructor and Description
public	PendingWriteQueue(EventExecutor executor, MessageSizeEstimator.Handle handle)

Method Summary

Modifier and Type	Method and Description
public void	add(Object msg, Promise<Void> promise) Add the given `msg` and `Promise`.
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 Promise<Void>	Returns: `Promise` of the pending write or `null` if the queue is empty. remove() Removes a pending write operation and release its message via `Resource#dispose(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 Future<Void>	Returns: `Future` if something was transfered and `null` if the `PendingWriteQueue` is empty. removeAndTransfer(Function<Object, Future<Void>> transferFunc) Removes a pending write operation and performs it via `Function#apply(Object)`.
public Future<Void>	Returns: `Future` if something was transferred and `null` if the `PendingWriteQueue` is empty. removeAndTransferAll(Function<Object, Future<Void>> transferFunc) Remove all pending write operation and performs them via `Function#apply(Object)`.
private static void	safeFail(Promise<Void> 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

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

sizeEstimatorHandle	back to summary
private final MessageSizeEstimator.Handle sizeEstimatorHandle

tail	back to summary
private PendingWriteQueue.PendingWrite tail

Constructor Detail

PendingWriteQueue	back to summary
public PendingWriteQueue(EventExecutor executor, MessageSizeEstimator.Handle handle)

Method Detail

add	back to summary
public void add(Object msg, Promise<Void> promise) Add the given `msg` and `Promise`.

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 Promise<Void> remove() Removes a pending write operation and release its message via `Resource#dispose(Object)`. Returns:Promise<Void> `Promise` of the pending write or `null` if the queue is empty.

public Promise<Void> remove()

Removes a pending write operation and release its message via Resource#dispose(Object).

Returns:Promise<Void>: Promise 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 `Resource#dispose(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 `Resource#dispose(Object)`.

removeAndTransfer back to summary

removeAndTransfer	back to summary
public Future<Void> removeAndTransfer(Function<Object, Future<Void>> transferFunc) Removes a pending write operation and performs it via `Function#apply(Object)`. Returns:Future<Void> `Future` if something was transfered and `null` if the `PendingWriteQueue` is empty.

public Future<Void> removeAndTransfer(Function<Object, Future<Void>> transferFunc)

Removes a pending write operation and performs it via Function#apply(Object).

Returns:Future<Void>: Future if something was transfered and null if the PendingWriteQueue is empty.

removeAndTransferAll back to summary

removeAndTransferAll	back to summary
public Future<Void> removeAndTransferAll(Function<Object, Future<Void>> transferFunc) Remove all pending write operation and performs them via `Function#apply(Object)`. Returns:Future<Void> `Future` if something was transferred and `null` if the `PendingWriteQueue` is empty.

public Future<Void> removeAndTransferAll(Function<Object, Future<Void>> transferFunc)

Remove all pending write operation and performs them via Function#apply(Object).

Returns:Future<Void>: Future if something was transferred and null if the PendingWriteQueue is empty.

safeFail	back to summary
private static void safeFail(Promise<Void> 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.netty5.channel back to summary

pack-priv final Class PendingWriteQueue.PendingWrite

Class Inheritance

extends Object

java.lang.Object
io.netty5.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 Promise<Void>	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, Promise<Void> 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 Promise<Void> 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, Promise<Void> 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