Class AbstractChannelHandlerContext.WriteTask

java.lang.Object

io.netty.channel.AbstractChannelHandlerContext.WriteTask

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

AbstractChannelHandlerContext

static final class AbstractChannelHandlerContext.WriteTask
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private AbstractChannelHandlerContext	ctx
private static final boolean	ESTIMATE_TASK_SIZE_ON_SUBMIT
private final ObjectPool.Handle<AbstractChannelHandlerContext.WriteTask>	handle
private java.lang.Object	msg
private ChannelPromise	promise
private static final Recycler<AbstractChannelHandlerContext.WriteTask>	RECYCLER
private int	size
private static final int	WRITE_TASK_OVERHEAD

Constructor Summary

Constructors

Modifier	Constructor	Description
private	WriteTask(ObjectPool.Handle<AbstractChannelHandlerContext.WriteTask> handle)

Method Summary

Modifier and Type	Method	Description
(package private) void	cancel()
private void	decrementPendingOutboundBytes()
(package private) static void	init(AbstractChannelHandlerContext.WriteTask task, AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)
(package private) static AbstractChannelHandlerContext.WriteTask	newInstance(AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)
private void	recycle()
void	run()

Methods inherited from class java.lang.Object

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

Field Details

RECYCLER

private static final Recycler<AbstractChannelHandlerContext.WriteTask> RECYCLER

ESTIMATE_TASK_SIZE_ON_SUBMIT

private static final boolean ESTIMATE_TASK_SIZE_ON_SUBMIT

WRITE_TASK_OVERHEAD

private static final int WRITE_TASK_OVERHEAD

handle

private final ObjectPool.Handle<AbstractChannelHandlerContext.WriteTask> handle

ctx

private AbstractChannelHandlerContext ctx

msg

private java.lang.Object msg

promise

private ChannelPromise promise

size

private int size

Constructor Details

WriteTask

private WriteTask(ObjectPool.Handle<AbstractChannelHandlerContext.WriteTask> handle)

Method Details

newInstance

static AbstractChannelHandlerContext.WriteTask newInstance(AbstractChannelHandlerContext ctx,
 java.lang.Object msg,
 ChannelPromise promise,
 boolean flush)

init

static void init(AbstractChannelHandlerContext.WriteTask task,
 AbstractChannelHandlerContext ctx,
 java.lang.Object msg,
 ChannelPromise promise,
 boolean flush)

run

public void run()

Specified by:

run in interface java.lang.Runnable

cancel

void cancel()

decrementPendingOutboundBytes

private void decrementPendingOutboundBytes()

recycle

private void recycle()