Class AbstractHttp2StreamChannel
- java.lang.Object
-
- io.netty.util.DefaultAttributeMap
-
- io.netty.handler.codec.http2.AbstractHttp2StreamChannel
-
- All Implemented Interfaces:
Channel,ChannelOutboundInvoker,Http2StreamChannel,AttributeMap,java.lang.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 classAbstractHttp2StreamChannel.FlowControlledFrameSizeEstimatorReturns the flow-control size for DATA frames, and 9 for all other frames.private classAbstractHttp2StreamChannel.Http2ChannelUnsafeprivate static classAbstractHttp2StreamChannel.Http2StreamChannelConfigChannelConfigso that the high and low writebuffer watermarks can reflect the outbound flow control window, without having to create a newWriteBufferWaterMarkobject whenever the flow control window changes.private static classAbstractHttp2StreamChannel.ReadStatusThe current status of the read-processing for aAbstractHttp2StreamChannel.-
Nested classes/interfaces inherited from interface io.netty.channel.Channel
Channel.Unsafe
-
-
Field Summary
Fields Modifier and Type Field Description private ChannelIdchannelIdprivate ChannelPromiseclosePromiseprivate AbstractHttp2StreamChannel.Http2StreamChannelConfigconfigprivate java.lang.RunnablefireChannelWritabilityChangedTaskprivate booleanfirstFrameWrittentrueafter the first HEADERS frame has been writtenprivate intflowControlledBytesprivate java.util.Queue<java.lang.Object>inboundBufferprivate static InternalLoggerloggerprivate static ChannelMetadataMETADATAprivate static intMIN_HTTP2_FRAME_SIZENumber of bytes to consider non-payload messages.private booleanoutboundClosedprivate ChannelPipelinepipelineprivate booleanreadCompletePendingprivate AbstractHttp2StreamChannel.ReadStatusreadStatusThis variable represents if a read is in progress for the current channel or was requested.private booleanregisteredprivate Http2FrameCodec.DefaultHttp2FrameStreamstreamprivate static java.util.concurrent.atomic.AtomicLongFieldUpdater<AbstractHttp2StreamChannel>TOTAL_PENDING_SIZE_UPDATERprivate longtotalPendingSizeprivate AbstractHttp2StreamChannel.Http2ChannelUnsafeunsafeprivate intunwritableprivate static java.util.concurrent.atomic.AtomicIntegerFieldUpdater<AbstractHttp2StreamChannel>UNWRITABLE_UPDATERprivate ChannelFutureListenerwindowUpdateFrameWriteListener(package private) static Http2FrameStreamVisitorWRITABLE_VISITOR
-
Constructor Summary
Constructors Constructor Description AbstractHttp2StreamChannel(Http2FrameCodec.DefaultHttp2FrameStream stream, int id, ChannelHandler inboundHandler)
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract voidaddChannelToReadCompletePendingQueue()ByteBufAllocatoralloc()Return the assignedByteBufAllocatorwhich will be used to allocateByteBufs.ChannelFuturebind(java.net.SocketAddress localAddress)Request to bind to the givenSocketAddressand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.ChannelFuturebind(java.net.SocketAddress localAddress, ChannelPromise promise)Request to bind to the givenSocketAddressand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.longbytesBeforeUnwritable()Get how many bytes can be written untilChannel.isWritable()returnsfalse.longbytesBeforeWritable()Get how many bytes must be drained from underlying buffers untilChannel.isWritable()returnstrue.ChannelFutureclose()Request to close theChanneland notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.ChannelFutureclose(ChannelPromise promise)Request to close theChanneland notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.ChannelFuturecloseFuture()Returns theChannelFuturewhich will be notified when this channel is closed.(package private) voidcloseOutbound()intcompareTo(Channel o)ChannelConfigconfig()Returns the configuration of this channel.ChannelFutureconnect(java.net.SocketAddress remoteAddress)Request to connect to the givenSocketAddressand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.ChannelFutureconnect(java.net.SocketAddress remoteAddress, ChannelPromise promise)Request to connect to the givenSocketAddressand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.ChannelFutureconnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)Request to connect to the givenSocketAddresswhile bind to the localAddress and notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.ChannelFutureconnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)Request to connect to the givenSocketAddresswhile bind to the localAddress and notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.private voiddecrementPendingOutboundBytes(long size, boolean invokeLater)ChannelFuturederegister()Request to deregister from the previous assignedEventExecutorand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.ChannelFuturederegister(ChannelPromise promise)Request to deregister from the previous assignedEventExecutorand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.ChannelFuturedisconnect()Request to disconnect from the remote peer and notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.ChannelFuturedisconnect(ChannelPromise promise)Request to disconnect from the remote peer and notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.booleanequals(java.lang.Object o)EventLoopeventLoop()private voidfireChannelWritabilityChanged(boolean invokeLater)(package private) voidfireChildRead(Http2Frame frame)Receive a read message.(package private) voidfireChildReadComplete()Channelflush()Request to flush all pending messages via this ChannelOutboundInvoker.protected voidflush0(ChannelHandlerContext ctx)inthashCode()ChannelIdid()Returns the globally unique identifier of thisChannel.private voidincrementPendingOutboundBytes(long size, boolean invokeLater)booleanisActive()Returntrueif theChannelis active and so connected.booleanisOpen()Returnstrueif theChannelis open and may get active laterprotected abstract booleanisParentReadInProgress()booleanisRegistered()booleanisWritable()Returnstrueif and only if the I/O thread will perform the requested write operation immediately.java.net.SocketAddresslocalAddress()Returns the local address where this channel is bound to.private voidmaybeAddChannelToReadCompletePendingQueue()ChannelMetadatametadata()ChannelFuturenewFailedFuture(java.lang.Throwable cause)Create a newChannelFuturewhich is marked as failed already.ChannelProgressivePromisenewProgressivePromise()Return an newChannelProgressivePromiseChannelPromisenewPromise()Return a newChannelPromise.ChannelFuturenewSucceededFuture()Create a newChannelFuturewhich is marked as succeeded already.Channelparent()Returns the parent of this channel.protected abstract ChannelHandlerContextparentContext()ChannelPipelinepipeline()Return the assignedChannelPipeline.Channelread()Request to Read data from theChannelinto the first inbound buffer, triggers anChannelInboundHandler.channelRead(ChannelHandlerContext, Object)event if data was read, and triggers achannelReadCompleteevent so the handler can decide to continue reading.java.net.SocketAddressremoteAddress()Returns the remote address where this channel is connected to.private voidsetUnwritable(boolean invokeLater)private voidsetWritable(boolean invokeLater)Http2FrameStreamstream()Returns theHttp2FrameStreamthat belongs to this channel.(package private) voidstreamClosed()java.lang.StringtoString()(package private) voidtrySetWritable()Channel.Unsafeunsafe()Returns an internal-use-only object that provides unsafe operations.ChannelPromisevoidPromise()Return a special ChannelPromise which can be reused for different operations.private static voidwindowUpdateFrameWriteComplete(ChannelFuture future, Channel streamChannel)ChannelFuturewrite(java.lang.Object msg)Request to write a message via thisChannelHandlerContextthrough theChannelPipeline.ChannelFuturewrite(java.lang.Object msg, ChannelPromise promise)Request to write a message via thisChannelHandlerContextthrough theChannelPipeline.protected ChannelFuturewrite0(ChannelHandlerContext ctx, java.lang.Object msg)ChannelFuturewriteAndFlush(java.lang.Object msg)Shortcut for callChannelOutboundInvoker.write(Object)andChannelOutboundInvoker.flush().ChannelFuturewriteAndFlush(java.lang.Object msg, ChannelPromise promise)Shortcut for callChannelOutboundInvoker.write(Object, ChannelPromise)andChannelOutboundInvoker.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 Detail
-
WRITABLE_VISITOR
static final Http2FrameStreamVisitor WRITABLE_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 java.util.concurrent.atomic.AtomicLongFieldUpdater<AbstractHttp2StreamChannel> TOTAL_PENDING_SIZE_UPDATER
-
UNWRITABLE_UPDATER
private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<AbstractHttp2StreamChannel> UNWRITABLE_UPDATER
-
windowUpdateFrameWriteListener
private final ChannelFutureListener windowUpdateFrameWriteListener
-
config
private final AbstractHttp2StreamChannel.Http2StreamChannelConfig config
-
unsafe
private final AbstractHttp2StreamChannel.Http2ChannelUnsafe unsafe
-
channelId
private final ChannelId 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 java.lang.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 theRecvByteBufAllocatorbehavior a read may extend beyond theAbstractHttp2StreamChannel.Http2ChannelUnsafe.beginRead()method scope. TheAbstractHttp2StreamChannel.Http2ChannelUnsafe.beginRead()loop may drain all pending data, and then if the parent channel is reading this channel may still accept frames.
-
inboundBuffer
private java.util.Queue<java.lang.Object> inboundBuffer
-
firstFrameWritten
private boolean firstFrameWritten
trueafter the first HEADERS frame has been written
-
readCompletePending
private boolean readCompletePending
-
-
Constructor Detail
-
AbstractHttp2StreamChannel
AbstractHttp2StreamChannel(Http2FrameCodec.DefaultHttp2FrameStream stream, int id, ChannelHandler inboundHandler)
-
-
Method Detail
-
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:Http2StreamChannelReturns theHttp2FrameStreamthat belongs to this channel.- Specified by:
streamin interfaceHttp2StreamChannel
-
closeOutbound
void closeOutbound()
-
streamClosed
void streamClosed()
-
metadata
public ChannelMetadata metadata()
Description copied from interface:Channel
-
config
public ChannelConfig config()
Description copied from interface:ChannelReturns the configuration of this channel.
-
isOpen
public boolean isOpen()
Description copied from interface:ChannelReturnstrueif theChannelis open and may get active later
-
isActive
public boolean isActive()
Description copied from interface:ChannelReturntrueif theChannelis active and so connected.
-
isWritable
public boolean isWritable()
Description copied from interface:ChannelReturnstrueif and only if the I/O thread will perform the requested write operation immediately. Any write requests made when this method returnsfalseare queued until the I/O thread is ready to process the queued write requests.- Specified by:
isWritablein interfaceChannel
-
id
public ChannelId id()
Description copied from interface:ChannelReturns the globally unique identifier of thisChannel.
-
parent
public Channel parent()
Description copied from interface:ChannelReturns the parent of this channel.
-
isRegistered
public boolean isRegistered()
Description copied from interface:Channel- Specified by:
isRegisteredin interfaceChannel
-
localAddress
public java.net.SocketAddress localAddress()
Description copied from interface:ChannelReturns the local address where this channel is bound to. The returnedSocketAddressis supposed to be down-cast into more concrete type such asInetSocketAddressto retrieve the detailed information.- Specified by:
localAddressin interfaceChannel- Returns:
- the local address of this channel.
nullif this channel is not bound.
-
remoteAddress
public java.net.SocketAddress remoteAddress()
Description copied from interface:ChannelReturns the remote address where this channel is connected to. The returnedSocketAddressis supposed to be down-cast into more concrete type such asInetSocketAddressto retrieve the detailed information.- Specified by:
remoteAddressin interfaceChannel- Returns:
- the remote address of this channel.
nullif this channel is not connected. If this channel is not connected but it can receive messages from arbitrary remote addresses (e.g.DatagramChannel, useDefaultAddressedEnvelope.recipient()to determine the origination of the received message as this method will returnnull.
-
closeFuture
public ChannelFuture closeFuture()
Description copied from interface:ChannelReturns theChannelFuturewhich will be notified when this channel is closed. This method always returns the same future instance.- Specified by:
closeFuturein interfaceChannel
-
bytesBeforeUnwritable
public long bytesBeforeUnwritable()
Description copied from interface:ChannelGet how many bytes can be written untilChannel.isWritable()returnsfalse. This quantity will always be non-negative. IfChannel.isWritable()isfalsethen 0.- Specified by:
bytesBeforeUnwritablein interfaceChannel
-
bytesBeforeWritable
public long bytesBeforeWritable()
Description copied from interface:ChannelGet how many bytes must be drained from underlying buffers untilChannel.isWritable()returnstrue. This quantity will always be non-negative. IfChannel.isWritable()istruethen 0.- Specified by:
bytesBeforeWritablein interfaceChannel
-
unsafe
public Channel.Unsafe unsafe()
Description copied from interface:ChannelReturns an internal-use-only object that provides unsafe operations.
-
pipeline
public ChannelPipeline pipeline()
Description copied from interface:ChannelReturn the assignedChannelPipeline.
-
alloc
public ByteBufAllocator alloc()
Description copied from interface:ChannelReturn the assignedByteBufAllocatorwhich will be used to allocateByteBufs.
-
read
public Channel read()
Description copied from interface:ChannelOutboundInvokerRequest to Read data from theChannelinto the first inbound buffer, triggers anChannelInboundHandler.channelRead(ChannelHandlerContext, Object)event if data was read, and triggers achannelReadCompleteevent 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 nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
readin interfaceChannel- Specified by:
readin interfaceChannelOutboundInvoker
-
flush
public Channel flush()
Description copied from interface:ChannelOutboundInvokerRequest to flush all pending messages via this ChannelOutboundInvoker.- Specified by:
flushin interfaceChannel- Specified by:
flushin interfaceChannelOutboundInvoker
-
bind
public ChannelFuture bind(java.net.SocketAddress localAddress)
Description copied from interface:ChannelOutboundInvokerRequest to bind to the givenSocketAddressand notify theChannelFutureonce 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 nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
bindin interfaceChannelOutboundInvoker
-
connect
public ChannelFuture connect(java.net.SocketAddress remoteAddress)
Description copied from interface:ChannelOutboundInvokerRequest to connect to the givenSocketAddressand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error.If the connection fails because of a connection timeout, the
ChannelFuturewill get failed with aConnectTimeoutException. If it fails because of connection refused aConnectExceptionwill be used.This will result in having the
ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)method called of the nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
connectin interfaceChannelOutboundInvoker
-
connect
public ChannelFuture connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
Description copied from interface:ChannelOutboundInvokerRequest to connect to the givenSocketAddresswhile bind to the localAddress and notify theChannelFutureonce 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 nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
connectin interfaceChannelOutboundInvoker
-
disconnect
public ChannelFuture disconnect()
Description copied from interface:ChannelOutboundInvokerRequest to disconnect from the remote peer and notify theChannelFutureonce 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 nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
disconnectin interfaceChannelOutboundInvoker
-
close
public ChannelFuture close()
Description copied from interface:ChannelOutboundInvokerRequest to close theChanneland notify theChannelFutureonce 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 nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
closein interfaceChannelOutboundInvoker
-
deregister
public ChannelFuture deregister()
Description copied from interface:ChannelOutboundInvokerRequest to deregister from the previous assignedEventExecutorand notify theChannelFutureonce 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 nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
deregisterin interfaceChannelOutboundInvoker
-
bind
public ChannelFuture bind(java.net.SocketAddress localAddress, ChannelPromise promise)
Description copied from interface:ChannelOutboundInvokerRequest to bind to the givenSocketAddressand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error. The givenChannelPromisewill be notified.This will result in having the
ChannelOutboundHandler.bind(ChannelHandlerContext, SocketAddress, ChannelPromise)method called of the nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
bindin interfaceChannelOutboundInvoker
-
connect
public ChannelFuture connect(java.net.SocketAddress remoteAddress, ChannelPromise promise)
Description copied from interface:ChannelOutboundInvokerRequest to connect to the givenSocketAddressand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error. The givenChannelFuturewill be notified.If the connection fails because of a connection timeout, the
ChannelFuturewill get failed with aConnectTimeoutException. If it fails because of connection refused aConnectExceptionwill be used.This will result in having the
ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)method called of the nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
connectin interfaceChannelOutboundInvoker
-
connect
public ChannelFuture connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
Description copied from interface:ChannelOutboundInvokerRequest to connect to the givenSocketAddresswhile bind to the localAddress and notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error. The givenChannelPromisewill be notified and also returned.This will result in having the
ChannelOutboundHandler.connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)method called of the nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
connectin interfaceChannelOutboundInvoker
-
disconnect
public ChannelFuture disconnect(ChannelPromise promise)
Description copied from interface:ChannelOutboundInvokerRequest to disconnect from the remote peer and notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error. The givenChannelPromisewill be notified.This will result in having the
ChannelOutboundHandler.disconnect(ChannelHandlerContext, ChannelPromise)method called of the nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
disconnectin interfaceChannelOutboundInvoker
-
close
public ChannelFuture close(ChannelPromise promise)
Description copied from interface:ChannelOutboundInvokerRequest to close theChanneland notify theChannelFutureonce 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 givenChannelPromisewill be notified.This will result in having the
ChannelOutboundHandler.close(ChannelHandlerContext, ChannelPromise)method called of the nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
closein interfaceChannelOutboundInvoker
-
deregister
public ChannelFuture deregister(ChannelPromise promise)
Description copied from interface:ChannelOutboundInvokerRequest to deregister from the previous assignedEventExecutorand notify theChannelFutureonce the operation completes, either because the operation was successful or because of an error. The givenChannelPromisewill be notified.This will result in having the
ChannelOutboundHandler.deregister(ChannelHandlerContext, ChannelPromise)method called of the nextChannelOutboundHandlercontained in theChannelPipelineof theChannel.- Specified by:
deregisterin interfaceChannelOutboundInvoker
-
write
public ChannelFuture write(java.lang.Object msg)
Description copied from interface:ChannelOutboundInvokerRequest to write a message via thisChannelHandlerContextthrough theChannelPipeline. This method will not request to actual flush, so be sure to callChannelOutboundInvoker.flush()once you want to request to flush all pending data to the actual transport.- Specified by:
writein interfaceChannelOutboundInvoker
-
write
public ChannelFuture write(java.lang.Object msg, ChannelPromise promise)
Description copied from interface:ChannelOutboundInvokerRequest to write a message via thisChannelHandlerContextthrough theChannelPipeline. This method will not request to actual flush, so be sure to callChannelOutboundInvoker.flush()once you want to request to flush all pending data to the actual transport.- Specified by:
writein interfaceChannelOutboundInvoker
-
writeAndFlush
public ChannelFuture writeAndFlush(java.lang.Object msg, ChannelPromise promise)
Description copied from interface:ChannelOutboundInvokerShortcut for callChannelOutboundInvoker.write(Object, ChannelPromise)andChannelOutboundInvoker.flush().- Specified by:
writeAndFlushin interfaceChannelOutboundInvoker
-
writeAndFlush
public ChannelFuture writeAndFlush(java.lang.Object msg)
Description copied from interface:ChannelOutboundInvokerShortcut for callChannelOutboundInvoker.write(Object)andChannelOutboundInvoker.flush().- Specified by:
writeAndFlushin interfaceChannelOutboundInvoker
-
newPromise
public ChannelPromise newPromise()
Description copied from interface:ChannelOutboundInvokerReturn a newChannelPromise.- Specified by:
newPromisein interfaceChannelOutboundInvoker
-
newProgressivePromise
public ChannelProgressivePromise newProgressivePromise()
Description copied from interface:ChannelOutboundInvokerReturn an newChannelProgressivePromise- Specified by:
newProgressivePromisein interfaceChannelOutboundInvoker
-
newSucceededFuture
public ChannelFuture newSucceededFuture()
Description copied from interface:ChannelOutboundInvokerCreate a newChannelFuturewhich is marked as succeeded already. SoFuture.isSuccess()will returntrue. AllFutureListeneradded to it will be notified directly. Also every call of blocking methods will just return without blocking.- Specified by:
newSucceededFuturein interfaceChannelOutboundInvoker
-
newFailedFuture
public ChannelFuture newFailedFuture(java.lang.Throwable cause)
Description copied from interface:ChannelOutboundInvokerCreate a newChannelFuturewhich is marked as failed already. SoFuture.isSuccess()will returnfalse. AllFutureListeneradded to it will be notified directly. Also every call of blocking methods will just return without blocking.- Specified by:
newFailedFuturein interfaceChannelOutboundInvoker
-
voidPromise
public ChannelPromise voidPromise()
Description copied from interface:ChannelOutboundInvokerReturn 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
Be aware this is an expert feature and should be used with care!ChannelPromisewill 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 callChannelPipeline.fireExceptionCaught(Throwable)in this case.- Specified by:
voidPromisein interfaceChannelOutboundInvoker
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equalsin classjava.lang.Object
-
compareTo
public int compareTo(Channel o)
- Specified by:
compareToin interfacejava.lang.Comparable<Channel>
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.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()
-
maybeAddChannelToReadCompletePendingQueue
private void maybeAddChannelToReadCompletePendingQueue()
-
flush0
protected void flush0(ChannelHandlerContext ctx)
-
write0
protected ChannelFuture write0(ChannelHandlerContext ctx, java.lang.Object msg)
-
isParentReadInProgress
protected abstract boolean isParentReadInProgress()
-
addChannelToReadCompletePendingQueue
protected abstract void addChannelToReadCompletePendingQueue()
-
parentContext
protected abstract ChannelHandlerContext parentContext()
-
-