Netty 5.0.0.Alpha5 · io.netty5.handler.codec.http2.DefaultHttp2StreamChannel

Modifier and Type	Class and Description
private static class	DefaultHttp2StreamChannel.DefaultHttp2ChannelPipeline
private static class	DefaultHttp2StreamChannel.FlowControlledFrameSizeEstimator Returns the flow-control size for DATA frames, and 9 for all other frames.
private static enum	DefaultHttp2StreamChannel.ReadStatus The current status of the read-processing for a `DefaultHttp2StreamChannel`.

Field Summary

Modifier and Type	Field and Description
private volatile boolean	allowHalfClosure
private volatile boolean	autoClose
private volatile int	autoRead
private static final AtomicIntegerFieldUpdater<DefaultHttp2StreamChannel>	AUTOREAD_UPDATER
private volatile BufferAllocator	bufferAllocator
private final ChannelId	channelId
private boolean	closeInitiated
private final Promise<Void>	closePromise
private volatile int	connectTimeoutMillis
private Runnable	fireChannelWritabilityChangedTask
private boolean	firstFrameWritten `true` after the first HEADERS frame has been written
private int	flowControlledBytes
private final Http2MultiplexHandler	handler
private Queue<Object>	inboundBuffer
private volatile boolean	inputShutdown
private static final InternalLogger	logger
private volatile int	maxMessagesPerWrite
private static final int	MIN_HTTP2_FRAME_SIZE Number of bytes to consider non-payload messages.
private volatile boolean	outputShutdown
private final ChannelPipeline	pipeline
private boolean	readCompletePending
private boolean	readEOS
private ReadHandleFactory.ReadHandle	readHandle
private volatile ReadHandleFactory	readHandleFactory
private DefaultHttp2StreamChannel.ReadStatus	readStatus This variable represents if a read is in progress for the current channel or was requested.
private volatile boolean	registered
private final Http2FrameCodec.DefaultHttp2FrameStream	stream
private static final AtomicLongFieldUpdater<DefaultHttp2StreamChannel>	TOTAL_PENDING_SIZE_UPDATER
private volatile long	totalPendingSize
private volatile int	unwritable
private static final AtomicIntegerFieldUpdater<DefaultHttp2StreamChannel>	UNWRITABLE_UPDATER
pack-priv static final Http2FrameStreamVisitor	WRITABLE_VISITOR
private volatile WriteBufferWaterMark	writeBufferWaterMark
private boolean	writeDoneAndNoFlush

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

Method Summary

Modifier and Type	Method and Description
protected void	autoReadCleared() Is called once `setAutoRead(boolean)` is called with `false` and `isAutoRead()` was `true` before.
private void	bindTransport(SocketAddress localAddress, Promise<Void> promise)
public BufferAllocator	bufferAllocator() Implements io.netty5.channel.Channel.bufferAllocator. Return the assigned `BufferAllocator` which will be used to allocate `Buffer`s.
pack-priv void	closeForcibly()
public Future<Void>	closeFuture() Implements io.netty5.channel.Channel.closeFuture. Returns the `Future` which will be notified when this channel is closed.
pack-priv void	closeOutbound()
private void	closeTransport(final Promise<Void> promise)
public int	compareTo(Channel the object to be compared. o) Implements java.lang.Comparable.compareTo. Compares this object with the specified object for order.
private void	connectTransport(final SocketAddress remoteAddress, SocketAddress localAddress, Promise<Void> promise)
private void	decrementPendingOutboundBytes(long size, boolean invokeLater)
private void	deregisterTransport(Promise<Void> promise)
private void	disconnectTransport(Promise<Void> promise)
pack-priv void	doBeginRead()
private boolean	doRead0(Http2Frame frame, ReadHandleFactory.ReadHandle allocHandle)
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	executor() Implements io.netty5.channel.Channel.executor. Return the `EventLoop` this `Channel` was registered to.
private void	fireChannelInactiveAndDeregister(Promise<Void> promise, final boolean fireChannelInactive)
private void	fireChannelWritabilityChanged(boolean invokeLater)
pack-priv void	fireChildRead(Http2Frame frame) Receive a read message.
pack-priv void	fireChildReadComplete()
private void	firstWriteComplete(Future<?> future, Promise<Void> promise)
private void	flushTransport()
private BufferAllocator	getBufferAllocator()
private int	getConnectTimeoutMillis()
private int	getMaxMessagesPerWrite() Get the maximum number of message to write per eventloop run.
private MessageSizeEstimator	getMessageSizeEstimator()
public <T> T	getOption(ChannelOption<T> the `ChannelOption`. option) Implements io.netty5.channel.Channel.getOption. Return the value of the given `ChannelOption`
private <T extends ReadHandleFactory> T	getReadHandleFactory()
private WriteBufferWaterMark	getWriteBufferWaterMark()
public int	hashCode() Overrides java.lang.Object.hashCode. Returns a hash code value for this object.
public ChannelId	id() Implements io.netty5.channel.Channel.id. Returns the globally unique identifier of this `Channel`.
private void	incrementPendingOutboundBytes(long size, boolean invokeLater)
private void	invokeLater(Runnable task)
public boolean	isActive() Implements io.netty5.channel.Channel.isActive. Return `true` if the `Channel` is active and so connected.
private boolean	isAllowHalfClosure()
private boolean	isAutoClose()
private boolean	isAutoRead()
public boolean	isOpen() Implements io.netty5.channel.Channel.isOpen. Returns `true` if the `Channel` is open and may get active later
public boolean	isOptionSupported(ChannelOption<?> the option. option) Implements io.netty5.channel.Channel.isOptionSupported. Returns `true` if the given `ChannelOption` is supported by this `Channel` implementation.
public boolean	isRegistered() Implements io.netty5.channel.IoHandle.isRegistered. Return true if registered already.
public boolean	isShutdown(ChannelShutdownDirection direction) Implements io.netty5.channel.Channel.isShutdown. Returns `true` if the `ChannelShutdownDirection` of the `Channel` was shutdown before.
private boolean	isShutdownNeeded(Http2Frame frame)
public SocketAddress	localAddress() Implements io.netty5.channel.Channel.localAddress. Returns the local address where this channel is bound to.
private void	maybeAddChannelToReadCompletePendingQueue()
private static ChannelOutputShutdownException	newOutputShutdownException(Class<?> clazz, String method) Creates a new `ChannelOutputShutdownException` which has the origin of the given `Class` and method.
pack-priv void	notifyReadComplete(ReadHandleFactory.ReadHandle allocHandle, boolean forceReadComplete)
public Channel	parent() Implements io.netty5.channel.Channel.parent. Returns the parent of this channel.
public ChannelPipeline	pipeline() Implements io.netty5.channel.Channel.pipeline. Return the assigned `ChannelPipeline`.
private Object	pollQueuedMessage()
pack-priv void	readEOS()
private ReadHandleFactory.ReadHandle	readHandle()
private void	readTransport(ReadBufferAllocator allocator)
private void	registerTransport(Promise<Void> promise)
public SocketAddress	remoteAddress() Implements io.netty5.channel.Channel.remoteAddress. Returns the remote address where this channel is connected to.
private void	safeSetSuccess(Promise<Void> promise)
private void	sendOutboundEventTransport(Object event, Promise<Void> promise)
private void	setAllowHalfClosure(boolean allowHalfClosure)
private void	setAutoClose(boolean autoClose)
private void	setAutoRead(boolean autoRead)
public void	setBufferAllocator(BufferAllocator bufferAllocator)
private void	setConnectTimeoutMillis(int connectTimeoutMillis)
private void	setMaxMessagesPerWrite(int maxMessagesPerWrite) Set the maximum number of message to write per eventloop run.
public <T> Channel	setOption(ChannelOption<T> the `ChannelOption`. option, T the value for the `ChannelOption` value) Implements io.netty5.channel.Channel.setOption. Sets a configuration property with the specified name and value.
private void	setReadHandleFactory(ReadHandleFactory readHandleFactory)
private void	setUnwritable(boolean invokeLater)
private void	setWritable(boolean invokeLater)
private void	setWriteBufferWaterMark(WriteBufferWaterMark writeBufferWaterMark)
private boolean	shutdownOutput(boolean writeFrame, Promise<Void> promise)
private void	shutdownTransport(ChannelShutdownDirection direction, Promise<Void> promise)
public Http2FrameStream	stream() Implements io.netty5.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 void	trySetWritable()
private void	updateLocalWindowIfNeeded()
private <T> void	validate(ChannelOption<T> option, T value)
private Http2StreamFrame	validateStreamFrame(Http2StreamFrame frame)
private static void	windowUpdateFrameWriteComplete(Channel streamChannel, Future<?> future)
private Throwable	wrapStreamClosedError(Throwable cause)
public long	writableBytes() Implements io.netty5.channel.Channel.writableBytes. Returns how many bytes can be written before the `Channel` becomes 'unwritable'.
private void	writeComplete(Future<?> future, Promise<Void> promise)
private void	writeHttp2StreamFrame(Http2StreamFrame frame, Promise<Void> promise)
private void	writeTransport(Object msg, Promise<Void> promise)

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

pack-priv final Class DefaultHttp2StreamChannel

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary