Netty/Codec/HTTP2 4.1.107.Final · io.netty.handler.codec.http2.AbstractHttp2StreamChannel

Modifier and Type	Class and Description
private static class	AbstractHttp2StreamChannel.FlowControlledFrameSizeEstimator Returns the flow-control size for DATA frames, and 9 for all other frames.
private class	AbstractHttp2StreamChannel.Http2ChannelUnsafe
private static 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 class	AbstractHttp2StreamChannel.UserEventStreamVisitor `Http2FrameStreamVisitor` that fires the user event for every active stream pipeline.

Modifier and Type	Field and Description
pack-priv static final Http2FrameStreamVisitor	CHANNEL_INPUT_SHUTDOWN_READ_COMPLETE_VISITOR
pack-priv static final Http2FrameStreamVisitor	CHANNEL_OUTPUT_SHUTDOWN_EVENT_VISITOR
private final ChannelId	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 volatile boolean	registered
pack-priv static final Http2FrameStreamVisitor	SSL_CLOSE_COMPLETION_EVENT_VISITOR
private final Http2FrameCodec.DefaultHttp2FrameStream	stream
private static final AtomicLongFieldUpdater<AbstractHttp2StreamChannel>	TOTAL_PENDING_SIZE_UPDATER
private volatile long	totalPendingSize
private final AbstractHttp2StreamChannel.Http2ChannelUnsafe	unsafe
private volatile int	unwritable
private static final AtomicIntegerFieldUpdater<AbstractHttp2StreamChannel>	UNWRITABLE_UPDATER
private final ChannelFutureListener	windowUpdateFrameWriteListener
pack-priv static final Http2FrameStreamVisitor	WRITABLE_VISITOR

Access	Constructor and Description
pack-priv	AbstractHttp2StreamChannel(Http2FrameCodec.DefaultHttp2FrameStream stream, int id, ChannelHandler inboundHandler)

Method Summary

Modifier and Type	Method and Description
protected abstract void	addChannelToReadCompletePendingQueue()
public ByteBufAllocator	alloc() Implements io.netty.channel.Channel.alloc. Return the assigned `ByteBufAllocator` which will be used to allocate `ByteBuf`s.
public ChannelFuture	bind(SocketAddress localAddress) Implements io.netty.channel.ChannelOutboundInvoker.bind. 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.
public ChannelFuture	bind(SocketAddress localAddress, ChannelPromise promise) Implements io.netty.channel.ChannelOutboundInvoker.bind. 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.
public long	bytesBeforeUnwritable() Implements io.netty.channel.Channel.bytesBeforeUnwritable. Get how many bytes can be written until `isWritable()` returns `false`.
public long	bytesBeforeWritable() Implements io.netty.channel.Channel.bytesBeforeWritable. Get how many bytes must be drained from underlying buffers until `isWritable()` returns `true`.
public ChannelFuture	close() Implements io.netty.channel.ChannelOutboundInvoker.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.
public ChannelFuture	close(ChannelPromise promise) Implements io.netty.channel.ChannelOutboundInvoker.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.
public ChannelFuture	closeFuture() Implements io.netty.channel.Channel.closeFuture. Returns the `ChannelFuture` which will be notified when this channel is closed.
pack-priv void	closeOutbound()
pack-priv final void	closeWithError(Http2Error error)
public int	compareTo(Channel the object to be compared. o) Implements java.lang.Comparable.compareTo. Compares this object with the specified object for order.
public ChannelConfig	config() Implements io.netty.channel.Channel.config. Returns the configuration of this channel.
public ChannelFuture	connect(SocketAddress remoteAddress) Implements io.netty.channel.ChannelOutboundInvoker.connect. 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.
public ChannelFuture	connect(SocketAddress remoteAddress, SocketAddress localAddress) Implements io.netty.channel.ChannelOutboundInvoker.connect. 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.
public ChannelFuture	connect(SocketAddress remoteAddress, ChannelPromise promise) Implements io.netty.channel.ChannelOutboundInvoker.connect. 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.
public ChannelFuture	connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) Implements io.netty.channel.ChannelOutboundInvoker.connect. 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)
public ChannelFuture	deregister() Implements io.netty.channel.ChannelOutboundInvoker.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.
public ChannelFuture	deregister(ChannelPromise promise) Implements io.netty.channel.ChannelOutboundInvoker.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.
public ChannelFuture	disconnect() Implements io.netty.channel.ChannelOutboundInvoker.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.
public ChannelFuture	disconnect(ChannelPromise promise) Implements io.netty.channel.ChannelOutboundInvoker.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.
public boolean	equals(Object the reference object with which to compare. o) Overrides java.lang.Object.equals. Indicates whether some other object is "equal to" this one.
public EventLoop	eventLoop() Implements io.netty.channel.Channel.eventLoop. Return the `EventLoop` this `Channel` was registered to.
private void	fireChannelWritabilityChanged(boolean invokeLater)
pack-priv void	fireChildRead(Http2Frame frame) Receive a read message.
pack-priv void	fireChildReadComplete()
public Channel	flush() Implements io.netty.channel.Channel.flush. Request to flush all pending messages via this ChannelOutboundInvoker.
protected void	flush0(ChannelHandlerContext ctx)
public int	hashCode() Overrides java.lang.Object.hashCode. Returns a hash code value for the object.
public ChannelId	id() Implements io.netty.channel.Channel.id. Returns the globally unique identifier of this `Channel`.
private void	incrementPendingOutboundBytes(long size, boolean invokeLater)
public boolean	isActive() Implements io.netty.channel.Channel.isActive. Return `true` if the `Channel` is active and so connected.
public boolean	isOpen() Implements io.netty.channel.Channel.isOpen. Returns `true` if the `Channel` is open and may get active later
protected abstract boolean	isParentReadInProgress()
public boolean	isRegistered() Implements io.netty.channel.Channel.isRegistered. Returns `true` if the `Channel` is registered with an `EventLoop`.
public boolean	isWritable() Implements io.netty.channel.Channel.isWritable. Returns `true` if and only if the I/O thread will perform the requested write operation immediately.
public SocketAddress	localAddress() Implements io.netty.channel.Channel.localAddress. Returns the local address where this channel is bound to.
private void	maybeAddChannelToReadCompletePendingQueue()
public ChannelMetadata	metadata() Implements io.netty.channel.Channel.metadata. Return the `ChannelMetadata` of the `Channel` which describe the nature of the `Channel`.
public ChannelFuture	newFailedFuture(Throwable cause) Implements io.netty.channel.ChannelOutboundInvoker.newFailedFuture. Create a new `ChannelFuture` which is marked as failed already.
public ChannelProgressivePromise	newProgressivePromise() Implements io.netty.channel.ChannelOutboundInvoker.newProgressivePromise. Return an new `ChannelProgressivePromise`
public ChannelPromise	newPromise() Implements io.netty.channel.ChannelOutboundInvoker.newPromise. Return a new `ChannelPromise`.
public ChannelFuture	newSucceededFuture() Implements io.netty.channel.ChannelOutboundInvoker.newSucceededFuture. Create a new `ChannelFuture` which is marked as succeeded already.
public Channel	parent() Implements io.netty.channel.Channel.parent. Returns the parent of this channel.
protected abstract ChannelHandlerContext	parentContext()
public ChannelPipeline	pipeline() Implements io.netty.channel.Channel.pipeline. Return the assigned `ChannelPipeline`.
public Channel	read() Implements io.netty.channel.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.
public SocketAddress	remoteAddress() Implements io.netty.channel.Channel.remoteAddress. Returns the remote address where this channel is connected to.
private void	setUnwritable(boolean invokeLater)
private void	setWritable(boolean invokeLater)
public Http2FrameStream	stream() Implements io.netty.handler.codec.http2.Http2StreamChannel.stream. Returns the `Http2FrameStream` that belongs to this channel.
pack-priv void	streamClosed()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
pack-priv final void	trySetWritable()
public Channel.Unsafe	unsafe() Implements io.netty.channel.Channel.unsafe. Returns an internal-use-only object that provides unsafe operations.
public ChannelPromise	voidPromise() Implements io.netty.channel.ChannelOutboundInvoker.voidPromise. Return a special ChannelPromise which can be reused for different operations.
private static void	windowUpdateFrameWriteComplete(ChannelFuture future, Channel streamChannel)
public ChannelFuture	write(Object msg) Implements io.netty.channel.ChannelOutboundInvoker.write. Request to write a message via this `ChannelHandlerContext` through the `ChannelPipeline`.
public ChannelFuture	write(Object msg, ChannelPromise promise) Implements io.netty.channel.ChannelOutboundInvoker.write. Request to write a message via this `ChannelHandlerContext` through the `ChannelPipeline`.
protected ChannelFuture	write0(ChannelHandlerContext ctx, Object msg)
public ChannelFuture	writeAndFlush(Object msg, ChannelPromise promise) Implements io.netty.channel.ChannelOutboundInvoker.writeAndFlush. Shortcut for call `write(Object, ChannelPromise)` and `flush()`.
public ChannelFuture	writeAndFlush(Object msg) Implements io.netty.channel.ChannelOutboundInvoker.writeAndFlush. Shortcut for call `write(Object)` and `flush()`.

Inherited from io.netty.util.DefaultAttributeMap:: attr hasAttr

pack-priv abstract Class AbstractHttp2StreamChannel

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary