Package io.netty.handler.codec.http2

Class AbstractHttp2StreamChannel

java.lang.Object

io.netty.util.DefaultAttributeMap

io.netty.handler.codec.http2.AbstractHttp2StreamChannel

All Implemented Interfaces:

Channel, ChannelOutboundInvoker, Http2StreamChannel, AttributeMap, Comparable<Channel>

Direct Known Subclasses:

Http2MultiplexCodec.Http2MultiplexCodecStreamChannel, Http2MultiplexHandler.Http2MultiplexHandlerStreamChannel

abstract class AbstractHttp2StreamChannel
extends DefaultAttributeMap
implements Http2StreamChannel

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	AbstractHttp2StreamChannel.FlowControlledFrameSizeEstimator	Returns the flow-control size for DATA frames, and 9 for all other frames.
private final class	AbstractHttp2StreamChannel.Http2ChannelUnsafe
private static final class	AbstractHttp2StreamChannel.Http2StreamChannelConfig	ChannelConfig so that the high and low writebuffer watermarks can reflect the outbound flow control window, without having to create a new WriteBufferWaterMark object whenever the flow control window changes.
private static enum	AbstractHttp2StreamChannel.ReadStatus	The current status of the read-processing for a AbstractHttp2StreamChannel.
private static final class	AbstractHttp2StreamChannel.UserEventStreamVisitor	Http2FrameStreamVisitor that fires the user event for every active stream pipeline.

Nested classes/interfaces inherited from interface io.netty.channel.Channel

Channel.Unsafe

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final Http2FrameStreamVisitor	CHANNEL_INPUT_SHUTDOWN_READ_COMPLETE_VISITOR
(package private) static final Http2FrameStreamVisitor	CHANNEL_OUTPUT_SHUTDOWN_EVENT_VISITOR
private final Http2StreamChannelId	channelId
private final ChannelPromise	closePromise
private final AbstractHttp2StreamChannel.Http2StreamChannelConfig	config
private Runnable	fireChannelWritabilityChangedTask
private boolean	firstFrameWritten	true after the first HEADERS frame has been written
private int	flowControlledBytes
private Queue<Object>	inboundBuffer
private static final InternalLogger	logger
private static final ChannelMetadata	METADATA
private static final int	MIN_HTTP2_FRAME_SIZE	Number of bytes to consider non-payload messages.
private boolean	outboundClosed
private final ChannelPipeline	pipeline
private boolean	readCompletePending
private AbstractHttp2StreamChannel.ReadStatus	readStatus	This variable represents if a read is in progress for the current channel or was requested.
private boolean	registered
(package private) static final Http2FrameStreamVisitor	SSL_CLOSE_COMPLETION_EVENT_VISITOR
private final Http2FrameCodec.DefaultHttp2FrameStream	stream
private static final AtomicLongFieldUpdater<AbstractHttp2StreamChannel>	TOTAL_PENDING_SIZE_UPDATER
private long	totalPendingSize
private final AbstractHttp2StreamChannel.Http2ChannelUnsafe	unsafe
private int	unwritable
private static final AtomicIntegerFieldUpdater<AbstractHttp2StreamChannel>	UNWRITABLE_UPDATER
private final ChannelFutureListener	windowUpdateFrameWriteListener
(package private) static final Http2FrameStreamVisitor	WRITABLE_VISITOR

Constructor Summary

Constructors

Constructor	Description
AbstractHttp2StreamChannel(Http2FrameCodec.DefaultHttp2FrameStream stream, int id, ChannelHandler inboundHandler)

Method Summary

Modifier and Type	Method	Description
protected abstract void	addChannelToReadCompletePendingQueue()
ByteBufAllocator	alloc()	Return the assigned ByteBufAllocator which will be used to allocate ByteBufs.
ChannelFuture	bind(SocketAddress localAddress)	Request to bind to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
ChannelFuture	bind(SocketAddress localAddress, ChannelPromise promise)	Request to bind to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
long	bytesBeforeUnwritable()	Get how many bytes can be written until Channel.isWritable() returns false.
long	bytesBeforeWritable()	Get how many bytes must be drained from underlying buffers until Channel.isWritable() returns true.
ChannelFuture	close()	Request to close the Channel and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
ChannelFuture	close(ChannelPromise promise)	Request to close the Channel and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
ChannelFuture	closeFuture()	Returns the ChannelFuture which will be notified when this channel is closed.
(package private) void	closeOutbound()
(package private) final void	closeWithError(Http2Error error)
int	compareTo(Channel o)
ChannelConfig	config()	Returns the configuration of this channel.
ChannelFuture	connect(SocketAddress remoteAddress)	Request to connect to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
ChannelFuture	connect(SocketAddress remoteAddress, ChannelPromise promise)	Request to connect to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
ChannelFuture	connect(SocketAddress remoteAddress, SocketAddress localAddress)	Request to connect to the given SocketAddress while bind to the localAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
ChannelFuture	connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)	Request to connect to the given SocketAddress while bind to the localAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
private void	decrementPendingOutboundBytes(long size, boolean invokeLater)
ChannelFuture	deregister()	Request to deregister from the previous assigned EventExecutor and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
ChannelFuture	deregister(ChannelPromise promise)	Request to deregister from the previous assigned EventExecutor and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
ChannelFuture	disconnect()	Request to disconnect from the remote peer and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
ChannelFuture	disconnect(ChannelPromise promise)	Request to disconnect from the remote peer and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.
boolean	equals(Object o)
EventLoop	eventLoop()	Return the EventLoop this Channel was registered to.
private void	fireChannelWritabilityChanged(boolean invokeLater)
(package private) void	fireChildRead(Http2Frame frame)	Receive a read message.
(package private) void	fireChildReadComplete()
Channel	flush()	Request to flush all pending messages via this ChannelOutboundInvoker.
protected void	flush0(ChannelHandlerContext ctx)
int	hashCode()
ChannelId	id()	Returns the globally unique identifier of this Channel.
private void	incrementPendingOutboundBytes(long size, boolean invokeLater)
boolean	isActive()	Return true if the Channel is active and so connected.
boolean	isOpen()	Returns true if the Channel is open and may get active later
protected abstract boolean	isParentReadInProgress()
boolean	isRegistered()	Returns true if the Channel is registered with an EventLoop.
boolean	isWritable()	Returns true if and only if the I/O thread will perform the requested write operation immediately.
SocketAddress	localAddress()	Returns the local address where this channel is bound to.
private void	maybeAddChannelToReadCompletePendingQueue()
ChannelMetadata	metadata()	Return the ChannelMetadata of the Channel which describe the nature of the Channel.
ChannelFuture	newFailedFuture(Throwable cause)	Create a new ChannelFuture which is marked as failed already.
ChannelProgressivePromise	newProgressivePromise()	Return an new ChannelProgressivePromise
ChannelPromise	newPromise()	Return a new ChannelPromise.
ChannelFuture	newSucceededFuture()	Create a new ChannelFuture which is marked as succeeded already.
Channel	parent()	Returns the parent of this channel.
protected abstract ChannelHandlerContext	parentContext()
ChannelPipeline	pipeline()	Return the assigned ChannelPipeline.
Channel	read()	Request to Read data from the Channel into the first inbound buffer, triggers an ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) event if data was read, and triggers a channelReadComplete event so the handler can decide to continue reading.
SocketAddress	remoteAddress()	Returns the remote address where this channel is connected to.
private void	setUnwritable(boolean invokeLater)
private void	setWritable(boolean invokeLater)
Http2FrameStream	stream()	Returns the Http2FrameStream that belongs to this channel.
(package private) void	streamClosed()
String	toString()
(package private) final void	trySetWritable()
Channel.Unsafe	unsafe()	Returns an internal-use-only object that provides unsafe operations.
ChannelPromise	voidPromise()	Return a special ChannelPromise which can be reused for different operations.
private static void	windowUpdateFrameWriteComplete(ChannelFuture future, Channel streamChannel)
ChannelFuture	write(Object msg)	Request to write a message via this ChannelHandlerContext through the ChannelPipeline.
ChannelFuture	write(Object msg, ChannelPromise promise)	Request to write a message via this ChannelHandlerContext through the ChannelPipeline.
protected ChannelFuture	write0(ChannelHandlerContext ctx, Object msg)
ChannelFuture	writeAndFlush(Object msg)	Shortcut for call ChannelOutboundInvoker.write(Object) and ChannelOutboundInvoker.flush().
ChannelFuture	writeAndFlush(Object msg, ChannelPromise promise)	Shortcut for call ChannelOutboundInvoker.write(Object, ChannelPromise) and ChannelOutboundInvoker.flush().

Methods inherited from class io.netty.util.DefaultAttributeMap

attr, hasAttr

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.netty.util.AttributeMap

attr, hasAttr

Field Details

WRITABLE_VISITOR

static final Http2FrameStreamVisitor WRITABLE_VISITOR

CHANNEL_INPUT_SHUTDOWN_READ_COMPLETE_VISITOR

static final Http2FrameStreamVisitor CHANNEL_INPUT_SHUTDOWN_READ_COMPLETE_VISITOR

CHANNEL_OUTPUT_SHUTDOWN_EVENT_VISITOR

static final Http2FrameStreamVisitor CHANNEL_OUTPUT_SHUTDOWN_EVENT_VISITOR

SSL_CLOSE_COMPLETION_EVENT_VISITOR

static final Http2FrameStreamVisitor SSL_CLOSE_COMPLETION_EVENT_VISITOR

logger

private static final InternalLogger logger

METADATA

private static final ChannelMetadata METADATA

MIN_HTTP2_FRAME_SIZE

private static final int MIN_HTTP2_FRAME_SIZE

Number of bytes to consider non-payload messages. 9 is arbitrary, but also the minimum size of an HTTP/2 frame. Primarily is non-zero.

See Also:

• Constant Field Values

TOTAL_PENDING_SIZE_UPDATER

private static final AtomicLongFieldUpdater<AbstractHttp2StreamChannel> TOTAL_PENDING_SIZE_UPDATER

UNWRITABLE_UPDATER

private static final AtomicIntegerFieldUpdater<AbstractHttp2StreamChannel> UNWRITABLE_UPDATER

windowUpdateFrameWriteListener

private final ChannelFutureListener windowUpdateFrameWriteListener

config

private final AbstractHttp2StreamChannel.Http2StreamChannelConfig config

unsafe

private final AbstractHttp2StreamChannel.Http2ChannelUnsafe unsafe

channelId

private final Http2StreamChannelId channelId

pipeline

private final ChannelPipeline pipeline

stream

private final Http2FrameCodec.DefaultHttp2FrameStream stream

closePromise

private final ChannelPromise closePromise

registered

private volatile boolean registered

totalPendingSize

private volatile long totalPendingSize

unwritable

private volatile int unwritable

fireChannelWritabilityChangedTask

private Runnable fireChannelWritabilityChangedTask

outboundClosed

private boolean outboundClosed

flowControlledBytes

private int flowControlledBytes

readStatus

private AbstractHttp2StreamChannel.ReadStatus readStatus

This variable represents if a read is in progress for the current channel or was requested. Note that depending upon the RecvByteBufAllocator behavior a read may extend beyond the AbstractHttp2StreamChannel.Http2ChannelUnsafe.beginRead() method scope. The AbstractHttp2StreamChannel.Http2ChannelUnsafe.beginRead() loop may drain all pending data, and then if the parent channel is reading this channel may still accept frames.

inboundBuffer

private Queue<Object> inboundBuffer

firstFrameWritten

private boolean firstFrameWritten

true after the first HEADERS frame has been written

readCompletePending

private boolean readCompletePending

Constructor Details

AbstractHttp2StreamChannel

AbstractHttp2StreamChannel(Http2FrameCodec.DefaultHttp2FrameStream stream,
 int id,
 ChannelHandler inboundHandler)

Method Details

windowUpdateFrameWriteComplete

private static void windowUpdateFrameWriteComplete(ChannelFuture future,
 Channel streamChannel)

incrementPendingOutboundBytes

private void incrementPendingOutboundBytes(long size,
 boolean invokeLater)

decrementPendingOutboundBytes

private void decrementPendingOutboundBytes(long size,
 boolean invokeLater)

trySetWritable

final void trySetWritable()

setWritable

private void setWritable(boolean invokeLater)

setUnwritable

private void setUnwritable(boolean invokeLater)

fireChannelWritabilityChanged

private void fireChannelWritabilityChanged(boolean invokeLater)

stream

public Http2FrameStream stream()

Description copied from interface: Http2StreamChannel

Returns the Http2FrameStream that belongs to this channel.

Specified by:

stream in interface Http2StreamChannel

closeOutbound

void closeOutbound()

streamClosed

void streamClosed()

metadata

public ChannelMetadata metadata()

Description copied from interface: Channel

Return the ChannelMetadata of the Channel which describe the nature of the Channel.

Specified by:

metadata in interface Channel

config

public ChannelConfig config()

Description copied from interface: Channel

Returns the configuration of this channel.

Specified by:

config in interface Channel

isOpen

public boolean isOpen()

Description copied from interface: Channel

Returns true if the Channel is open and may get active later

Specified by:

isOpen in interface Channel

isActive

public boolean isActive()

Description copied from interface: Channel

Return true if the Channel is active and so connected.

Specified by:

isActive in interface Channel

isWritable

public boolean isWritable()

Description copied from interface: Channel

Returns true if and only if the I/O thread will perform the requested write operation immediately. Any write requests made when this method returns false are queued until the I/O thread is ready to process the queued write requests. WriteBufferWaterMark can be used to configure on which condition the write buffer would cause this channel to change writability.

Specified by:

isWritable in interface Channel

id

public ChannelId id()

Description copied from interface: Channel

Returns the globally unique identifier of this Channel.

Specified by:

id in interface Channel

eventLoop

public EventLoop eventLoop()

Description copied from interface: Channel

Return the EventLoop this Channel was registered to.

Specified by:

eventLoop in interface Channel

parent

public Channel parent()

Description copied from interface: Channel

Returns the parent of this channel.

Specified by:

parent in interface Channel

Returns:

the parent channel. null if this channel does not have a parent channel.

isRegistered

public boolean isRegistered()

Description copied from interface: Channel

Returns true if the Channel is registered with an EventLoop.

Specified by:

isRegistered in interface Channel

localAddress

public SocketAddress localAddress()

Description copied from interface: Channel

Returns the local address where this channel is bound to. The returned SocketAddress is supposed to be down-cast into more concrete type such as InetSocketAddress to retrieve the detailed information.

Specified by:

localAddress in interface Channel

Returns:

the local address of this channel. null if this channel is not bound.

remoteAddress

public SocketAddress remoteAddress()

Description copied from interface: Channel

Returns the remote address where this channel is connected to. The returned SocketAddress is supposed to be down-cast into more concrete type such as InetSocketAddress to retrieve the detailed information.

Specified by:

remoteAddress in interface Channel

Returns:

the remote address of this channel. null if this channel is not connected. If this channel is not connected but it can receive messages from arbitrary remote addresses (e.g. DatagramChannel, use DefaultAddressedEnvelope.recipient() to determine the origination of the received message as this method will return null.

closeFuture

public ChannelFuture closeFuture()

Description copied from interface: Channel

Returns the ChannelFuture which will be notified when this channel is closed. This method always returns the same future instance.

Specified by:

closeFuture in interface Channel

bytesBeforeUnwritable

public long bytesBeforeUnwritable()

Description copied from interface: Channel

Get how many bytes can be written until Channel.isWritable() returns false. This quantity will always be non-negative. If Channel.isWritable() is false then 0. WriteBufferWaterMark can be used to define writability settings.

Specified by:

bytesBeforeUnwritable in interface Channel

bytesBeforeWritable

public long bytesBeforeWritable()

Description copied from interface: Channel

Get how many bytes must be drained from underlying buffers until Channel.isWritable() returns true. This quantity will always be non-negative. If Channel.isWritable() is true then 0. WriteBufferWaterMark can be used to define writability settings.

Specified by:

bytesBeforeWritable in interface Channel

unsafe

public Channel.Unsafe unsafe()

Description copied from interface: Channel

Returns an internal-use-only object that provides unsafe operations.

Specified by:

unsafe in interface Channel

pipeline

public ChannelPipeline pipeline()

Description copied from interface: Channel

Return the assigned ChannelPipeline.

Specified by:

pipeline in interface Channel

alloc

public ByteBufAllocator alloc()

Description copied from interface: Channel

Return the assigned ByteBufAllocator which will be used to allocate ByteBufs.

Specified by:

alloc in interface Channel

read

public Channel read()

Description copied from interface: ChannelOutboundInvoker

Request to Read data from the Channel into the first inbound buffer, triggers an ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) event if data was read, and triggers a channelReadComplete event so the handler can decide to continue reading. If there's a pending read operation already, this method does nothing.

This will result in having the ChannelOutboundHandler.read(ChannelHandlerContext) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

read in interface Channel

Specified by:

read in interface ChannelOutboundInvoker

flush

public Channel flush()

Description copied from interface: ChannelOutboundInvoker

Request to flush all pending messages via this ChannelOutboundInvoker.

Specified by:

flush in interface Channel

Specified by:

flush in interface ChannelOutboundInvoker

bind

public ChannelFuture bind(SocketAddress localAddress)

Description copied from interface: ChannelOutboundInvoker

Request to bind to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.

This will result in having the ChannelOutboundHandler.bind(ChannelHandlerContext, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

bind in interface ChannelOutboundInvoker

connect

public ChannelFuture connect(SocketAddress remoteAddress)

Description copied from interface: ChannelOutboundInvoker

Request to connect to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.

If the connection fails because of a connection timeout, the ChannelFuture will get failed with a ConnectTimeoutException. If it fails because of connection refused a ConnectException will be used.

This will result in having the ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

connect in interface ChannelOutboundInvoker

connect

public ChannelFuture connect(SocketAddress remoteAddress,
 SocketAddress localAddress)

Description copied from interface: ChannelOutboundInvoker

Request to connect to the given SocketAddress while bind to the localAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.

This will result in having the ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

connect in interface ChannelOutboundInvoker

disconnect

public ChannelFuture disconnect()

Description copied from interface: ChannelOutboundInvoker

Request to disconnect from the remote peer and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.

This will result in having the ChannelOutboundHandler.disconnect(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

disconnect in interface ChannelOutboundInvoker

close

public ChannelFuture close()

Description copied from interface: ChannelOutboundInvoker

Request to close the Channel and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. After it is closed it is not possible to reuse it again.

This will result in having the ChannelOutboundHandler.close(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

close in interface ChannelOutboundInvoker

deregister

public ChannelFuture deregister()

Description copied from interface: ChannelOutboundInvoker

Request to deregister from the previous assigned EventExecutor and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error.

This will result in having the ChannelOutboundHandler.deregister(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

deregister in interface ChannelOutboundInvoker

bind

public ChannelFuture bind(SocketAddress localAddress,
 ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to bind to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. The given ChannelPromise will be notified.

This will result in having the ChannelOutboundHandler.bind(ChannelHandlerContext, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

bind in interface ChannelOutboundInvoker

connect

public ChannelFuture connect(SocketAddress remoteAddress,
 ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to connect to the given SocketAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. The given ChannelFuture will be notified.

If the connection fails because of a connection timeout, the ChannelFuture will get failed with a ConnectTimeoutException. If it fails because of connection refused a ConnectException will be used.

This will result in having the ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

connect in interface ChannelOutboundInvoker

connect

public ChannelFuture connect(SocketAddress remoteAddress,
 SocketAddress localAddress,
 ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to connect to the given SocketAddress while bind to the localAddress and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. The given ChannelPromise will be notified and also returned.

This will result in having the ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

connect in interface ChannelOutboundInvoker

disconnect

public ChannelFuture disconnect(ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to disconnect from the remote peer and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. The given ChannelPromise will be notified.

This will result in having the ChannelOutboundHandler.disconnect(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

disconnect in interface ChannelOutboundInvoker

close

public ChannelFuture close(ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to close the Channel and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. After it is closed it is not possible to reuse it again. The given ChannelPromise will be notified.

This will result in having the ChannelOutboundHandler.close(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

close in interface ChannelOutboundInvoker

deregister

public ChannelFuture deregister(ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to deregister from the previous assigned EventExecutor and notify the ChannelFuture once the operation completes, either because the operation was successful or because of an error. The given ChannelPromise will be notified.

This will result in having the ChannelOutboundHandler.deregister(ChannelHandlerContext, ChannelPromise) method called of the next ChannelOutboundHandler contained in the ChannelPipeline of the Channel.

Specified by:

deregister in interface ChannelOutboundInvoker

write

public ChannelFuture write(Object msg)

Description copied from interface: ChannelOutboundInvoker

Request to write a message via this ChannelHandlerContext through the ChannelPipeline. This method will not request to actual flush, so be sure to call ChannelOutboundInvoker.flush() once you want to request to flush all pending data to the actual transport.

Specified by:

write in interface ChannelOutboundInvoker

write

public ChannelFuture write(Object msg,
 ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Request to write a message via this ChannelHandlerContext through the ChannelPipeline. This method will not request to actual flush, so be sure to call ChannelOutboundInvoker.flush() once you want to request to flush all pending data to the actual transport.

Specified by:

write in interface ChannelOutboundInvoker

writeAndFlush

public ChannelFuture writeAndFlush(Object msg,
 ChannelPromise promise)

Description copied from interface: ChannelOutboundInvoker

Shortcut for call ChannelOutboundInvoker.write(Object, ChannelPromise) and ChannelOutboundInvoker.flush().

Specified by:

writeAndFlush in interface ChannelOutboundInvoker

writeAndFlush

public ChannelFuture writeAndFlush(Object msg)

Description copied from interface: ChannelOutboundInvoker

Shortcut for call ChannelOutboundInvoker.write(Object) and ChannelOutboundInvoker.flush().

Specified by:

writeAndFlush in interface ChannelOutboundInvoker

newPromise

public ChannelPromise newPromise()

Description copied from interface: ChannelOutboundInvoker

Return a new ChannelPromise.

Specified by:

newPromise in interface ChannelOutboundInvoker

newProgressivePromise

public ChannelProgressivePromise newProgressivePromise()

Description copied from interface: ChannelOutboundInvoker

Return an new ChannelProgressivePromise

Specified by:

newProgressivePromise in interface ChannelOutboundInvoker

newSucceededFuture

public ChannelFuture newSucceededFuture()

Description copied from interface: ChannelOutboundInvoker

Create a new ChannelFuture which is marked as succeeded already. So Future.isSuccess() will return true. All FutureListener added to it will be notified directly. Also every call of blocking methods will just return without blocking.

Specified by:

newSucceededFuture in interface ChannelOutboundInvoker

newFailedFuture

public ChannelFuture newFailedFuture(Throwable cause)

Description copied from interface: ChannelOutboundInvoker

Create a new ChannelFuture which is marked as failed already. So Future.isSuccess() will return false. All FutureListener added to it will be notified directly. Also every call of blocking methods will just return without blocking.

Specified by:

newFailedFuture in interface ChannelOutboundInvoker

voidPromise

public ChannelPromise voidPromise()

Description copied from interface: ChannelOutboundInvoker

Return a special ChannelPromise which can be reused for different operations.

It's only supported to use it for ChannelOutboundInvoker.write(Object, ChannelPromise).

Be aware that the returned ChannelPromise will not support most operations and should only be used if you want to save an object allocation for every write operation. You will not be able to detect if the operation was complete, only if it failed as the implementation will call ChannelPipeline.fireExceptionCaught(Throwable) in this case.

Be aware this is an expert feature and should be used with care!

Specified by:

voidPromise in interface ChannelOutboundInvoker

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

compareTo

public int compareTo(Channel o)

Specified by:

compareTo in interface Comparable<Channel>

toString

public String toString()

Overrides:

toString in class Object

fireChildRead

void fireChildRead(Http2Frame frame)

Receive a read message. This does not notify handlers unless a read is in progress on the channel.

fireChildReadComplete

void fireChildReadComplete()

closeWithError

final void closeWithError(Http2Error error)

maybeAddChannelToReadCompletePendingQueue

private void maybeAddChannelToReadCompletePendingQueue()

flush0

protected void flush0(ChannelHandlerContext ctx)

write0

protected ChannelFuture write0(ChannelHandlerContext ctx,
 Object msg)

isParentReadInProgress

protected abstract boolean isParentReadInProgress()

addChannelToReadCompletePendingQueue

protected abstract void addChannelToReadCompletePendingQueue()

parentContext

protected abstract ChannelHandlerContext parentContext()