Package | Description |
---|---|
io.netty.bootstrap |
The helper classes with fluent API which enable an easy implementation of
typical client side and server side channel initialization.
|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.handler.codec |
Extensible decoder and its common implementations which deal with the
packet fragmentation and reassembly issue found in a stream-based transport
such as TCP/IP.
|
io.netty.handler.codec.base64 | |
io.netty.handler.codec.bytes |
Encoder and decoder which transform an array of bytes into a
ByteBuf and vice versa. |
io.netty.handler.codec.compression | |
io.netty.handler.codec.dns |
DNS codec.
|
io.netty.handler.codec.haproxy |
Decodes an HAProxy proxy protocol header
|
io.netty.handler.codec.http |
Encoder, decoder and their related message types for HTTP.
|
io.netty.handler.codec.http.cors |
This package contains Cross Origin Resource Sharing (CORS) related classes.
|
io.netty.handler.codec.http.multipart |
HTTP multipart support.
|
io.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
io.netty.handler.codec.http.websocketx.extensions |
Encoder, decoder, handshakers to handle
WebSocket Extensions.
|
io.netty.handler.codec.http.websocketx.extensions.compression |
Encoder, decoder, handshakers to handle most common WebSocket Compression Extensions.
|
io.netty.handler.codec.http2 |
Handlers for sending and receiving HTTP/2 frames.
|
io.netty.handler.codec.json |
JSON specific codecs.
|
io.netty.handler.codec.memcache |
Common superset of ascii and binary classes.
|
io.netty.handler.codec.memcache.binary |
Implementations and Interfaces for the Memcache Binary protocol.
|
io.netty.handler.codec.mqtt |
Encoder, decoder and different Message Types for MQTT.
|
io.netty.handler.codec.redis |
Encoder, decoder for Redis.
|
io.netty.handler.codec.sctp |
Decoder and encoders to manage message completion and multi-streaming codec in SCTP/IP.
|
io.netty.handler.codec.serialization |
Encoder, decoder and their compatibility stream implementations which
transform a
Serializable object into a byte buffer and
vice versa. |
io.netty.handler.codec.smtp |
SMTP codec.
|
io.netty.handler.codec.socks |
Encoder, decoder and their related message types for Socks.
|
io.netty.handler.codec.socksx |
Encoder, decoder and their related message types for SOCKS protocol.
|
io.netty.handler.codec.socksx.v4 |
Encoder, decoder and their related message types for SOCKSv4 protocol.
|
io.netty.handler.codec.socksx.v5 |
Encoder, decoder and their related message types for SOCKSv5 protocol.
|
io.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
io.netty.handler.codec.stomp |
STOMP codec
|
io.netty.handler.codec.string |
Encoder and decoder which transform a
String into a
ByteBuf and vice versa. |
io.netty.handler.codec.xml |
Xml specific codecs.
|
io.netty.handler.flow |
Package to control the flow of messages.
|
io.netty.handler.flush |
Package to control flush behavior.
|
io.netty.handler.ipfilter |
Package to filter IP addresses (allow/deny).
|
io.netty.handler.logging |
Logs the I/O events for debugging purpose.
|
io.netty.handler.proxy |
Adds support for client connections via proxy protocols such as
SOCKS and
HTTP CONNECT tunneling
|
io.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
io.netty.handler.stream |
Writes very large data stream asynchronously neither spending a lot of
memory nor getting
OutOfMemoryError . |
io.netty.handler.timeout |
Adds support for read and write timeout and idle connection notification
using a
Timer . |
io.netty.handler.traffic |
Implementation of a Traffic Shaping Handler and Dynamic Statistics.
|
io.netty.resolver.dns |
An alternative to Java's built-in domain name lookup mechanism that resolves a domain name asynchronously,
which supports the queries of an arbitrary DNS record type as well.
|
Modifier and Type | Method and Description |
---|---|
void |
ServerBootstrap.ServerBootstrapAcceptor.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ServerBootstrap.ServerBootstrapAcceptor.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
AbstractChannelHandlerContext |
private static class |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext |
(package private) class |
DefaultChannelHandlerContext |
(package private) class |
DefaultChannelPipeline.HeadContext |
(package private) class |
DefaultChannelPipeline.TailContext |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.ctx |
private ChannelHandlerContext |
PendingWriteQueue.ctx |
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ConcurrentMap<ChannelHandlerContext,java.lang.Boolean> |
ChannelInitializer.initMap |
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
ChannelPipeline.context(ChannelHandler handler)
Returns the context object of the specified
ChannelHandler in
this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(ChannelHandler handler) |
ChannelHandlerContext |
ChannelPipeline.context(java.lang.Class<? extends ChannelHandler> handlerType)
Returns the context object of the
ChannelHandler of the
specified type in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(java.lang.Class<? extends ChannelHandler> handlerType) |
ChannelHandlerContext |
ChannelPipeline.context(java.lang.String name)
Returns the context object of the
ChannelHandler with the
specified name in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.context(java.lang.String name) |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelActive() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelActive() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelActive() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelInactive() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelInactive() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelInactive() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRead(java.lang.Object msg) |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelRead(java.lang.Object msg) |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelRead(java.lang.Object msg) |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelReadComplete() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelReadComplete() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelReadComplete() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRegistered() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelRegistered() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelRegistered() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelUnregistered() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelUnregistered() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelUnregistered() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelWritabilityChanged() |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelWritabilityChanged() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelWritabilityChanged() |
ChannelHandlerContext |
ChannelHandlerContext.fireExceptionCaught(java.lang.Throwable cause) |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireExceptionCaught(java.lang.Throwable cause) |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireExceptionCaught(java.lang.Throwable cause) |
ChannelHandlerContext |
ChannelHandlerContext.fireUserEventTriggered(java.lang.Object evt) |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireUserEventTriggered(java.lang.Object event) |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireUserEventTriggered(java.lang.Object event) |
ChannelHandlerContext |
ChannelPipeline.firstContext()
Returns the context of the first
ChannelHandler in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.firstContext() |
ChannelHandlerContext |
ChannelHandlerContext.flush() |
ChannelHandlerContext |
AbstractChannelHandlerContext.flush() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.flush() |
ChannelHandlerContext |
ChannelPipeline.lastContext()
Returns the context of the last
ChannelHandler in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.lastContext() |
ChannelHandlerContext |
ChannelHandlerContext.read() |
ChannelHandlerContext |
AbstractChannelHandlerContext.read() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.read() |
Modifier and Type | Method and Description |
---|---|
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Called once a bind operation is made.
|
void |
DefaultChannelPipeline.HeadContext.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelInboundHandlerAdapter.channelActive(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelActive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelActive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext is now active |
void |
DefaultChannelPipeline.TailContext.channelActive(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelActive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelInactive(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelInactive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext was registered is now inactive and reached its
end of lifetime. |
void |
DefaultChannelPipeline.TailContext.channelInactive(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelInactive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg)
|
void |
CombinedChannelDuplexHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg)
Invoked when the current
Channel has read a message from the peer. |
void |
SimpleChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
DefaultChannelPipeline.TailContext.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
DefaultChannelPipeline.HeadContext.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
protected abstract void |
SimpleChannelInboundHandler.channelRead0(ChannelHandlerContext ctx,
I msg)
Please keep in mind that this method will be renamed to
messageReceived(ChannelHandlerContext, I) in 5.0.
Is called for each message of type I . |
void |
ChannelInboundHandlerAdapter.channelReadComplete(ChannelHandlerContext ctx)
Calls
fireChannelReadComplete() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext ctx)
Invoked when the last message read by the current read operation has been consumed by
ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) . |
void |
DefaultChannelPipeline.TailContext.channelReadComplete(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelReadComplete(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelRegistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInitializer.channelRegistered(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelRegistered(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelUnregistered(ChannelHandlerContext ctx)
Calls
fireChannelUnregistered() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelUnregistered(ChannelHandlerContext ctx)
|
void |
DefaultChannelPipeline.TailContext.channelUnregistered(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelUnregistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelWritabilityChanged(ChannelHandlerContext ctx)
Calls
fireChannelWritabilityChanged() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext ctx)
Gets called once the writable state of a
Channel changed. |
void |
DefaultChannelPipeline.TailContext.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a close operation is made.
|
void |
DefaultChannelPipeline.HeadContext.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Called once a connect operation is made.
|
void |
DefaultChannelPipeline.HeadContext.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.deregister(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.close(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a deregister operation is made from the current registered
EventLoop . |
void |
DefaultChannelPipeline.HeadContext.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a disconnect operation is made.
|
void |
DefaultChannelPipeline.HeadContext.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelInboundHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
|
void |
CombinedChannelDuplexHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
ChannelInboundHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Gets called if a
Throwable was thrown. |
void |
ChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Deprecated.
is part of
ChannelInboundHandler |
void |
ChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
|
void |
ChannelInitializer.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Handle the
Throwable by logging and closing the Channel . |
void |
DefaultChannelPipeline.TailContext.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
DefaultChannelPipeline.HeadContext.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
CombinedChannelDuplexHandler.flush(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.flush(ChannelHandlerContext ctx)
|
void |
ChannelDuplexHandler.flush(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.flush(ChannelHandlerContext ctx)
Called once a flush operation is made.
|
void |
DefaultChannelPipeline.HeadContext.flush(ChannelHandlerContext ctx) |
void |
CombinedChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelHandler.handlerAdded(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was added to the actual context and it's ready to handle events. |
void |
ChannelHandlerAdapter.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
ChannelInitializer.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
DefaultChannelPipeline.TailContext.handlerAdded(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.handlerAdded(ChannelHandlerContext ctx) |
void |
CombinedChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelHandler.handlerRemoved(ChannelHandlerContext ctx)
Gets called after the
ChannelHandler was removed from the actual context and it doesn't handle events
anymore. |
void |
ChannelHandlerAdapter.handlerRemoved(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
DefaultChannelPipeline.TailContext.handlerRemoved(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.handlerRemoved(ChannelHandlerContext ctx) |
private boolean |
ChannelInitializer.initChannel(ChannelHandlerContext ctx) |
void |
CombinedChannelDuplexHandler.read(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.read(ChannelHandlerContext ctx)
|
void |
ChannelDuplexHandler.read(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.read(ChannelHandlerContext ctx)
Intercepts
read() . |
void |
DefaultChannelPipeline.HeadContext.read(ChannelHandlerContext ctx) |
private void |
ChannelInitializer.remove(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt)
Calls
fireUserEventTriggered(Object) to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
ChannelInboundHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt)
Gets called if an user event was triggered.
|
void |
DefaultChannelPipeline.TailContext.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
DefaultChannelPipeline.HeadContext.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
ChannelOutboundInvoker.write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
ChannelOutboundHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Called once a write operation is made.
|
void |
DefaultChannelPipeline.HeadContext.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Constructor and Description |
---|
DelegatingChannelHandlerContext(ChannelHandlerContext ctx,
ChannelHandler handler) |
PendingWriteQueue(ChannelHandlerContext ctx) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
MessageAggregator.ctx |
Modifier and Type | Method and Description |
---|---|
protected ChannelHandlerContext |
MessageAggregator.ctx() |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
MessageToByteEncoder.allocateBuffer(ChannelHandlerContext ctx,
I msg,
boolean preferDirect)
Allocate a
ByteBuf which will be used as argument of #encode(ChannelHandlerContext, I, ByteBuf) . |
void |
DatagramPacketEncoder.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected void |
ReplayingDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
ByteToMessageDecoder.callDecode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Called once data should be decoded from the given
ByteBuf . |
void |
DatagramPacketDecoder.channelActive(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
MessageAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelInactive(ChannelHandlerContext ctx) |
private void |
ByteToMessageDecoder.channelInputClosed(ChannelHandlerContext ctx,
boolean callChannelInactive) |
(package private) void |
ReplayingDecoder.channelInputClosed(ChannelHandlerContext ctx,
java.util.List<java.lang.Object> out) |
(package private) void |
ByteToMessageDecoder.channelInputClosed(ChannelHandlerContext ctx,
java.util.List<java.lang.Object> out)
Called when the input of the channel was closed which may be because it changed to inactive or because of
ChannelInputShutdownEvent . |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
DatagramPacketDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
MessageAggregator.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelRegistered(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelUnregistered(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DatagramPacketEncoder.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected java.lang.Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
Create a frame out of the
ByteBuf and return it. |
protected void |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected abstract void |
ByteToMessageCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected abstract void |
ByteToMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
protected void |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
DatagramPacketDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket msg,
java.util.List<java.lang.Object> out) |
protected void |
MessageAggregator.decode(ChannelHandlerContext ctx,
I msg,
java.util.List<java.lang.Object> out) |
protected abstract void |
MessageToMessageDecoder.decode(ChannelHandlerContext ctx,
I msg,
java.util.List<java.lang.Object> out)
Decode from one message to an other.
|
protected abstract void |
MessageToMessageCodec.decode(ChannelHandlerContext ctx,
INBOUND_IN msg,
java.util.List<java.lang.Object> out) |
protected void |
ByteToMessageCodec.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
ByteToMessageDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Is called one last time when the
ChannelHandlerContext goes in-active. |
(package private) void |
ByteToMessageDecoder.decodeRemovalReentryProtection(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Decode the from one
ByteBuf to an other. |
void |
DatagramPacketEncoder.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DatagramPacketEncoder.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
DatagramPacketEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<M,java.net.InetSocketAddress> msg,
java.util.List<java.lang.Object> out) |
protected void |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected abstract void |
ByteToMessageCodec.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
protected void |
ByteToMessageCodec.Encoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out) |
protected abstract void |
MessageToByteEncoder.encode(ChannelHandlerContext ctx,
I msg,
ByteBuf out)
Encode a message into a
ByteBuf . |
protected abstract void |
MessageToMessageEncoder.encode(ChannelHandlerContext ctx,
I msg,
java.util.List<java.lang.Object> out)
Encode from one message to an other.
|
protected abstract void |
MessageToMessageCodec.encode(ChannelHandlerContext ctx,
OUTBOUND_IN msg,
java.util.List<java.lang.Object> out) |
void |
DatagramPacketDecoder.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
DatagramPacketEncoder.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
protected ByteBuf |
LengthFieldBasedFrameDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Extract the sub-region of the specified buffer.
|
private void |
LineBasedFrameDecoder.fail(ChannelHandlerContext ctx,
int length) |
private void |
LineBasedFrameDecoder.fail(ChannelHandlerContext ctx,
java.lang.String length) |
(package private) static void |
ByteToMessageDecoder.fireChannelRead(ChannelHandlerContext ctx,
CodecOutputList msgs,
int numElements)
Get
numElements out of the CodecOutputList and forward these through the pipeline. |
(package private) static void |
ByteToMessageDecoder.fireChannelRead(ChannelHandlerContext ctx,
java.util.List<java.lang.Object> msgs,
int numElements)
Get
numElements out of the List and forward these through the pipeline. |
void |
DatagramPacketEncoder.flush(ChannelHandlerContext ctx) |
protected void |
MessageAggregator.handleOversizedMessage(ChannelHandlerContext ctx,
S oversized)
Invoked when an incoming request exceeds the maximum content length.
|
void |
DatagramPacketDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
MessageAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
MessageAggregator.handlerRemoved(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.handlerRemoved(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ByteToMessageDecoder.handlerRemoved0(ChannelHandlerContext ctx)
Gets called after the
ByteToMessageDecoder was removed from the actual context and it doesn't handle
events anymore. |
private void |
MessageAggregator.invokeHandleOversizedMessage(ChannelHandlerContext ctx,
S oversized) |
void |
DatagramPacketEncoder.read(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
ByteToMessageDecoder.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
MessageToMessageCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ByteToMessageCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToByteEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
Base64Decoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected void |
Base64Encoder.encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
ByteArrayDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected void |
ByteArrayEncoder.encode(ChannelHandlerContext ctx,
byte[] msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
Bzip2Encoder.ctx
Used to interact with its
ChannelPipeline and other handlers. |
private ChannelHandlerContext |
JdkZlibEncoder.ctx |
private ChannelHandlerContext |
JZlibEncoder.ctx |
Modifier and Type | Method and Description |
---|---|
private ChannelHandlerContext |
Bzip2Encoder.ctx() |
private ChannelHandlerContext |
JdkZlibEncoder.ctx() |
private ChannelHandlerContext |
JZlibEncoder.ctx() |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
void |
Bzip2Encoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
FastLzFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Bzip2Decoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
JZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
JdkZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SnappyFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
FastLzFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
Bzip2Encoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf uncompressed,
ByteBuf out) |
protected void |
JZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
SnappyFrameEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
private ChannelFuture |
Bzip2Encoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
private ChannelFuture |
JdkZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
private ChannelFuture |
JZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Bzip2Encoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
protected void |
JdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
DatagramDnsQueryEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsQuery,java.net.InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
protected ByteBuf |
DatagramDnsResponseEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
protected void |
DatagramDnsQueryDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket packet,
java.util.List<java.lang.Object> out) |
protected void |
DatagramDnsResponseDecoder.decode(ChannelHandlerContext ctx,
DatagramPacket packet,
java.util.List<java.lang.Object> out) |
protected void |
DatagramDnsQueryEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<DnsQuery,java.net.InetSocketAddress> in,
java.util.List<java.lang.Object> out) |
protected void |
DatagramDnsResponseEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> in,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
void |
HAProxyMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
protected void |
HAProxyMessageDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private ByteBuf |
HAProxyMessageDecoder.decodeLine(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
private ByteBuf |
HAProxyMessageDecoder.decodeStruct(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
private void |
HAProxyMessageDecoder.fail(ChannelHandlerContext ctx,
java.lang.String errMsg,
java.lang.Throwable t) |
private void |
HAProxyMessageDecoder.failOverLimit(ChannelHandlerContext ctx,
int length) |
private void |
HAProxyMessageDecoder.failOverLimit(ChannelHandlerContext ctx,
java.lang.String length) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
HttpContentCompressor.ctx |
protected ChannelHandlerContext |
HttpContentDecoder.ctx |
Modifier and Type | Method and Description |
---|---|
void |
HttpClientUpgradeHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
HttpContentEncoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpClientCodec.Decoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpServerExpectContinueHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
HttpServerKeepAliveHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
HttpClientUpgradeHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
HttpClientUpgradeHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected void |
HttpObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
HttpServerCodec.HttpServerRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
HttpClientCodec.Decoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
HttpClientUpgradeHandler.decode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpServerUpgradeHandler.decode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpContentDecoder.decode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpContentEncoder.decode(ChannelHandlerContext ctx,
HttpRequest msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpObjectDecoder.decodeLast(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
HttpClientUpgradeHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
HttpClientUpgradeHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
HttpContentEncoder.encode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpObjectEncoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpClientCodec.Encoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
private void |
HttpObjectEncoder.encodeChunkedContent(ChannelHandlerContext ctx,
java.lang.Object msg,
long contentLength,
java.util.List<java.lang.Object> out) |
void |
HttpClientUpgradeHandler.flush(ChannelHandlerContext ctx) |
protected void |
HttpObjectAggregator.handleOversizedMessage(ChannelHandlerContext ctx,
HttpMessage oversized) |
void |
HttpContentCompressor.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpClientUpgradeHandler.SourceCodec.prepareUpgradeFrom(ChannelHandlerContext ctx)
Removes or disables the encoder of this codec so that the
HttpClientUpgradeHandler.UpgradeCodec can send an initial greeting
(if any). |
void |
HttpClientCodec.prepareUpgradeFrom(ChannelHandlerContext ctx)
Prepares to upgrade to another protocol from HTTP.
|
boolean |
HttpServerUpgradeHandler.UpgradeCodec.prepareUpgradeResponse(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest,
HttpHeaders upgradeHeaders)
Prepares the
upgradeHeaders for a protocol update based upon the contents of upgradeRequest . |
void |
HttpClientUpgradeHandler.read(ChannelHandlerContext ctx) |
HttpContent |
HttpChunkedInput.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
private static void |
HttpClientUpgradeHandler.removeThisHandler(ChannelHandlerContext ctx) |
java.util.Collection<java.lang.CharSequence> |
HttpClientUpgradeHandler.UpgradeCodec.setUpgradeHeaders(ChannelHandlerContext ctx,
HttpRequest upgradeRequest)
Sets any protocol-specific headers required to the upgrade request.
|
private void |
HttpClientUpgradeHandler.setUpgradeRequestHeaders(ChannelHandlerContext ctx,
HttpRequest request)
Adds all upgrade request headers necessary for an upgrade to the supported protocols.
|
private boolean |
HttpServerUpgradeHandler.upgrade(ChannelHandlerContext ctx,
FullHttpRequest request)
Attempts to upgrade to the protocol(s) identified by the
HttpHeaderNames.UPGRADE header (if provided
in the request). |
void |
HttpServerCodec.upgradeFrom(ChannelHandlerContext ctx)
Upgrades to another protocol from HTTP.
|
void |
HttpClientUpgradeHandler.SourceCodec.upgradeFrom(ChannelHandlerContext ctx)
Removes this codec (i.e.
|
void |
HttpServerUpgradeHandler.SourceCodec.upgradeFrom(ChannelHandlerContext ctx)
Removes this codec (i.e.
|
void |
HttpClientCodec.upgradeFrom(ChannelHandlerContext ctx)
Upgrades to another protocol from HTTP.
|
void |
HttpServerUpgradeHandler.UpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest)
Performs an HTTP protocol upgrade from the source codec.
|
void |
HttpClientUpgradeHandler.UpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpResponse upgradeResponse)
Performs an HTTP protocol upgrade from the source codec.
|
void |
HttpObjectDecoder.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
HttpClientUpgradeHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
HttpServerKeepAliveHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
CorsHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
private static void |
CorsHandler.forbidden(ChannelHandlerContext ctx,
HttpRequest request) |
private void |
CorsHandler.handlePreflight(ChannelHandlerContext ctx,
HttpRequest request) |
private static void |
CorsHandler.respond(ChannelHandlerContext ctx,
HttpRequest request,
HttpResponse response) |
void |
CorsHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
HttpContent |
HttpPostRequestEncoder.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
WebSocketClientProtocolHandshakeHandler.channelActive(ChannelHandlerContext ctx) |
void |
WebSocketClientProtocolHandshakeHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
WebSocketServerProtocolHandshakeHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
Utf8FrameValidator.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(ChannelHandlerContext ctx,
ByteBuf buffer) |
private void |
Utf8FrameValidator.checkUTF8String(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
WebSocket00FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
WebSocketProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
java.util.List<java.lang.Object> out) |
protected void |
WebSocketClientProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
java.util.List<java.lang.Object> out) |
protected void |
WebSocketServerProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
java.util.List<java.lang.Object> out) |
private WebSocketFrame |
WebSocket00FrameDecoder.decodeBinaryFrame(ChannelHandlerContext ctx,
byte type,
ByteBuf buffer) |
private WebSocketFrame |
WebSocket00FrameDecoder.decodeTextFrame(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
WebSocket00FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
protected void |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
void |
WebSocketProtocolHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
WebSocketServerProtocolHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
WebSocketClientProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketServerProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
private void |
WebSocket08FrameDecoder.protocolViolation(ChannelHandlerContext ctx,
CorruptedFrameException ex) |
private void |
WebSocket08FrameDecoder.protocolViolation(ChannelHandlerContext ctx,
java.lang.String reason) |
WebSocketFrame |
WebSocketChunkedInput.readChunk(ChannelHandlerContext ctx)
Deprecated.
Use
WebSocketChunkedInput.readChunk(ByteBufAllocator) .
Fetches a chunked data from the stream. Once this method returns the last chunk
and thus the stream has reached at its end, any subsequent WebSocketChunkedInput.isEndOfInput()
call must return true . |
private static void |
WebSocketServerProtocolHandshakeHandler.sendHttpResponse(ChannelHandlerContext ctx,
HttpRequest req,
HttpResponse res) |
Modifier and Type | Method and Description |
---|---|
void |
WebSocketClientExtensionHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
WebSocketServerExtensionHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
WebSocketClientExtensionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
WebSocketServerExtensionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
DeflateDecoder.channelInactive(ChannelHandlerContext ctx) |
protected void |
DeflateDecoder.decode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
protected void |
PerMessageDeflateDecoder.decode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
protected void |
DeflateEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
protected void |
PerMessageDeflateEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
void |
DeflateDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
DeflateEncoder.handlerRemoved(ChannelHandlerContext ctx) |
Modifier and Type | Field and Description |
---|---|
(package private) ChannelHandlerContext |
StreamBufferingEncoder.PendingStream.ctx |
private ChannelHandlerContext |
Http2ConnectionHandler.ClosingChannelFutureListener.ctx |
private ChannelHandlerContext |
DefaultHttp2RemoteFlowController.ctx |
private ChannelHandlerContext |
Http2MultiplexCodec.ctx |
private ChannelHandlerContext |
Http2FrameCodec.ctx |
private ChannelHandlerContext |
DefaultHttp2LocalFlowController.ctx |
private ChannelHandlerContext |
Http2FrameCodec.http2HandlerCtx |
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
DefaultHttp2RemoteFlowController.channelHandlerContext() |
ChannelHandlerContext |
Http2RemoteFlowController.channelHandlerContext()
Get the
ChannelHandlerContext for which to apply flow control on. |
Modifier and Type | Method and Description |
---|---|
void |
Http2ConnectionHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
Http2ConnectionHandler.channelActive(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.BaseDecoder.channelActive(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.PrefaceDecoder.channelActive(ChannelHandlerContext ctx) |
void |
DelegatingDecompressorFrameListener.ConsumedBytesConverter.channelHandlerContext(ChannelHandlerContext ctx) |
void |
DefaultHttp2RemoteFlowController.channelHandlerContext(ChannelHandlerContext ctx)
Set the
ChannelHandlerContext for which to apply flow control on. |
void |
Http2FlowController.channelHandlerContext(ChannelHandlerContext ctx)
Set the
ChannelHandlerContext for which to apply flow control on. |
void |
DefaultHttp2LocalFlowController.channelHandlerContext(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.BaseDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.PrefaceDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
InboundHttpToHttp2Adapter.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
Http2MultiplexCodec.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
Http2ConnectionHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
Http2MultiplexCodec.channelReadComplete(ChannelHandlerContext ctx)
Notifies any child streams of the read completion.
|
void |
Http2ConnectionHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
Http2ConnectionHandler.closeConnectionOnError(ChannelHandlerContext ctx,
ChannelFuture future) |
void |
Http2ConnectionHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
private static ByteBuf |
Http2ServerUpgradeCodec.createSettingsFrame(ChannelHandlerContext ctx,
ByteBuf payload)
Creates an HTTP2-Settings header with the given payload.
|
protected void |
CleartextHttp2ServerUpgradeHandler.PriorKnowledgeHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Http2ConnectionHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
abstract void |
Http2ConnectionHandler.BaseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
Http2ConnectionHandler.PrefaceDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
Http2ConnectionHandler.FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Http2ServerDowngrader.decode(ChannelHandlerContext ctx,
Http2StreamFrame frame,
java.util.List<java.lang.Object> out) |
void |
Http2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Called by the
Http2ConnectionHandler to decode the next frame from the input buffer. |
void |
DecoratingHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
DefaultHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private Http2Settings |
Http2ServerUpgradeCodec.decodeSettings(ChannelHandlerContext ctx,
ByteBuf frame)
Decodes the settings frame and returns the settings.
|
private Http2Settings |
Http2ServerUpgradeCodec.decodeSettingsHeader(ChannelHandlerContext ctx,
java.lang.CharSequence settingsHeader)
Decodes the settings header and returns a
Http2Settings object. |
void |
Http2ConnectionHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
Http2ConnectionHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
Http2ConnectionHandler.doGracefulShutdown(ChannelHandlerContext ctx,
ChannelFuture future,
ChannelPromise promise) |
protected void |
Http2ServerDowngrader.encode(ChannelHandlerContext ctx,
HttpObject obj,
java.util.List<java.lang.Object> out) |
void |
DefaultHttp2ConnectionEncoder.FlowControlledData.error(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
DefaultHttp2ConnectionEncoder.FlowControlledHeaders.error(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
Http2RemoteFlowController.FlowControlled.error(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Called to indicate that an error occurred before this object could be completely written.
|
void |
Http2ConnectionHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Handles
Http2Exception objects that were thrown from other handlers. |
void |
Http2MultiplexCodec.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
Http2FrameCodec.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
protected void |
InboundHttp2ToHttpAdapter.fireChannelRead(ChannelHandlerContext ctx,
FullHttpMessage msg,
boolean release,
Http2Stream stream)
Set final headers and fire a channel read event
|
void |
Http2ConnectionHandler.flush(ChannelHandlerContext ctx) |
void |
Http2MultiplexCodec.flush(ChannelHandlerContext ctx) |
private java.lang.CharSequence |
Http2ClientUpgradeCodec.getSettingsHeaderValue(ChannelHandlerContext ctx)
Converts the current settings for the handler to the Base64-encoded representation used in
the HTTP2-Settings upgrade header.
|
private ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx,
Http2Exception cause)
Close the remote endpoint with with a
GO_AWAY frame. |
ChannelFuture |
Http2LifecycleManager.goAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise)
Prevents the peer from creating streams and close the connection if
errorCode is not
Http2Error.NO_ERROR . |
ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
void |
CleartextHttp2ServerUpgradeHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2MultiplexCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2FrameCodec.handlerAdded(ChannelHandlerContext ctx)
Load any dependencies.
|
void |
Http2Codec.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.BaseDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.PrefaceDecoder.handlerRemoved(ChannelHandlerContext ctx)
Releases the
clientPrefaceString . |
void |
Http2FrameCodec.handlerRemoved(ChannelHandlerContext ctx)
Clean up any dependencies.
|
protected void |
Http2ConnectionHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
Http2ConnectionHandler.handleServerHeaderDecodeSizeError(ChannelHandlerContext ctx,
Http2Stream stream)
Notifies client that this server has received headers that are larger than what it is
willing to accept.
|
private void |
DelegatingDecompressorFrameListener.initDecompressor(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
boolean endOfStream)
Checks if a new decompressor object is needed for the stream identified by
streamId . |
boolean |
Http2PromisedRequestVerifier.isAuthoritative(ChannelHandlerContext ctx,
Http2Headers headers)
Determine if a
Http2Headers are authoritative for a particular ChannelHandlerContext . |
void |
Http2FrameLogger.logData(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream) |
void |
Http2FrameLogger.logGoAway(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameLogger.logHeaders(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
Http2FrameLogger.logHeaders(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2FrameLogger.logPing(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameLogger.logPingAck(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameLogger.logPriority(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2FrameLogger.logPushPromise(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2FrameLogger.logRstStream(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameLogger.logSettings(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2FrameLogger.logSettingsAck(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx) |
void |
Http2FrameLogger.logUnknownFrame(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf data) |
void |
Http2FrameLogger.logWindowsUpdate(Http2FrameLogger.Direction direction,
ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
boolean |
DefaultHttp2ConnectionEncoder.FlowControlledData.merge(ChannelHandlerContext ctx,
Http2RemoteFlowController.FlowControlled next) |
boolean |
DefaultHttp2ConnectionEncoder.FlowControlledHeaders.merge(ChannelHandlerContext ctx,
Http2RemoteFlowController.FlowControlled next) |
boolean |
Http2RemoteFlowController.FlowControlled.merge(ChannelHandlerContext ctx,
Http2RemoteFlowController.FlowControlled next)
Merge the contents of the
next message into this message so they can be written out as one unit. |
private EmbeddedChannel |
CompressorHttp2ConnectionEncoder.newCompressionChannel(ChannelHandlerContext ctx,
ZlibWrapper wrapper)
Generate a new instance of an
EmbeddedChannel capable of compressing data |
private EmbeddedChannel |
CompressorHttp2ConnectionEncoder.newCompressor(ChannelHandlerContext ctx,
Http2Headers headers,
boolean endOfStream)
Checks if a new compressor object is needed for the stream identified by
streamId . |
protected EmbeddedChannel |
CompressorHttp2ConnectionEncoder.newContentCompressor(ChannelHandlerContext ctx,
java.lang.CharSequence contentEncoding)
Returns a new
EmbeddedChannel that encodes the HTTP2 message content encoded in the specified
contentEncoding . |
protected EmbeddedChannel |
DelegatingDecompressorFrameListener.newContentDecompressor(ChannelHandlerContext ctx,
java.lang.CharSequence contentEncoding)
Returns a new
EmbeddedChannel that decodes the HTTP2 message content encoded in the specified
contentEncoding . |
protected void |
Http2ConnectionHandler.onConnectionError(ChannelHandlerContext ctx,
java.lang.Throwable cause,
Http2Exception http2Ex)
Handler for a connection error.
|
int |
DelegatingDecompressorFrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2EventAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2FrameAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2FrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream)
Handles an inbound
DATA frame. |
int |
Http2FrameListenerDecorator.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
InboundHttp2ToHttpAdapter.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
DefaultHttp2ConnectionDecoder.FrameReadListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
int |
Http2FrameCodec.FrameListener.onDataRead(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream) |
void |
Http2LifecycleManager.onError(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Processes the given error.
|
void |
Http2ConnectionHandler.onError(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Central handler for all exceptions caught during HTTP/2 processing.
|
void |
Http2EventAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameAdapter.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
Http2FrameListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData)
Handles an inbound
GO_AWAY frame. |
void |
Http2FrameListenerDecorator.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onGoAwayRead(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
(package private) void |
DefaultHttp2ConnectionDecoder.onGoAwayRead0(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData) |
void |
DelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
Http2EventAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
Http2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
Http2FrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream)
Handles an inbound
HEADERS frame. |
void |
Http2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream) |
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
void |
Http2FrameCodec.FrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endOfStream) |
void |
DelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2EventAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2FrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream)
Handles an inbound
HEADERS frame with priority information specified. |
void |
Http2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream) |
void |
Http2FrameCodec.FrameListener.onHeadersRead(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream) |
void |
Http2EventAdapter.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameAdapter.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListener.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data)
Handles an inbound
PING acknowledgment. |
void |
Http2FrameListenerDecorator.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingAckRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2EventAdapter.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameAdapter.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2FrameListener.onPingRead(ChannelHandlerContext ctx,
ByteBuf data)
Handles an inbound
PING frame. |
void |
Http2FrameListenerDecorator.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPingRead(ChannelHandlerContext ctx,
ByteBuf data) |
void |
Http2EventAdapter.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2FrameAdapter.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2FrameListener.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive)
Handles an inbound
PRIORITY frame. |
void |
Http2FrameListenerDecorator.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPriorityRead(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive) |
void |
Http2EventAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2FrameAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2FrameListener.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding)
Handles an inbound
PUSH_PROMISE frame. |
void |
Http2FrameListenerDecorator.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
InboundHttp2ToHttpAdapter.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onPushPromiseRead(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding) |
void |
Http2EventAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode)
Handles an inbound
RST_STREAM frame. |
void |
Http2FrameListenerDecorator.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
InboundHttp2ToHttpAdapter.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2FrameCodec.FrameListener.onRstStreamRead(ChannelHandlerContext ctx,
int streamId,
long errorCode) |
void |
Http2EventAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2FrameAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2FrameListener.onSettingsAckRead(ChannelHandlerContext ctx)
Handles an inbound
SETTINGS acknowledgment frame. |
void |
Http2FrameListenerDecorator.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2EventAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2FrameAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
Http2FrameListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings)
Handles an inbound
SETTINGS frame. |
void |
Http2FrameListenerDecorator.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
InboundHttp2ToHttpAdapter.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onSettingsRead(ChannelHandlerContext ctx,
Http2Settings settings) |
protected void |
Http2ConnectionHandler.onStreamError(ChannelHandlerContext ctx,
java.lang.Throwable cause,
Http2Exception.StreamException http2Ex)
Handler for a stream error.
|
protected void |
Http2FrameCodec.InternalHttp2ConnectionHandler.onStreamError(ChannelHandlerContext ctx,
java.lang.Throwable cause,
Http2Exception.StreamException http2Ex) |
void |
Http2EventAdapter.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2FrameAdapter.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2FrameListener.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload)
Handler for a frame not defined by the HTTP/2 spec.
|
void |
Http2FrameListenerDecorator.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onUnknownFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
(package private) void |
DefaultHttp2ConnectionDecoder.onUnknownFrame0(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload) |
void |
Http2EventAdapter.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2FrameAdapter.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
Http2FrameListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement)
Handles an inbound
WINDOW_UPDATE frame. |
void |
Http2FrameListenerDecorator.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
DefaultHttp2ConnectionDecoder.FrameReadListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
void |
DefaultHttp2ConnectionDecoder.PrefaceFrameListener.onWindowUpdateRead(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement) |
boolean |
Http2ServerUpgradeCodec.prepareUpgradeResponse(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest,
HttpHeaders headers) |
private static void |
Http2ConnectionHandler.processGoAwayWriteResult(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelFuture future) |
protected FullHttpMessage |
InboundHttp2ToHttpAdapter.processHeadersBegin(ChannelHandlerContext ctx,
Http2Stream stream,
Http2Headers headers,
boolean endOfStream,
boolean allowAppend,
boolean appendToTrailer)
Provides translation between HTTP/2 and HTTP header objects while ensuring the stream
is in a valid state for additional headers.
|
private void |
InboundHttp2ToHttpAdapter.processHeadersEnd(ChannelHandlerContext ctx,
Http2Stream stream,
FullHttpMessage msg,
boolean endOfStream)
After HTTP/2 headers have been processed by
InboundHttp2ToHttpAdapter.processHeadersBegin(io.netty.channel.ChannelHandlerContext, io.netty.handler.codec.http2.Http2Stream, io.netty.handler.codec.http2.Http2Headers, boolean, boolean, boolean) this method either
sends the result up the pipeline or retains the message for future processing. |
private void |
DefaultHttp2FrameReader.processPayloadState(ChannelHandlerContext ctx,
ByteBuf in,
Http2FrameListener listener) |
private void |
Http2ConnectionHandler.processRstStreamWriteResult(ChannelHandlerContext ctx,
Http2Stream stream,
ChannelFuture future) |
void |
Http2ConnectionHandler.read(ChannelHandlerContext ctx) |
private void |
DefaultHttp2FrameReader.readDataFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
void |
Http2FrameReader.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener)
Attempts to read the next frame from the input buffer.
|
void |
Http2InboundFrameLogger.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener) |
void |
DefaultHttp2FrameReader.readFrame(ChannelHandlerContext ctx,
ByteBuf input,
Http2FrameListener listener) |
private static void |
DefaultHttp2FrameReader.readGoAwayFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readHeadersFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readPingFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readPriorityFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readPushPromiseFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readRstStreamFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readSettingsFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readUnknownFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private void |
DefaultHttp2FrameReader.readWindowUpdateFrame(ChannelHandlerContext ctx,
ByteBuf payload,
Http2FrameListener listener) |
private ChannelFuture |
Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx,
Http2Stream stream,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2LifecycleManager.resetStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Ensure the stream identified by
streamId is reset. |
ChannelFuture |
Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
private ChannelFuture |
Http2ConnectionHandler.resetUnknownStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Sends a
RST_STREAM frame even if we don't know about the stream. |
(package private) abstract void |
StreamBufferingEncoder.Frame.send(ChannelHandlerContext ctx,
int streamId) |
(package private) void |
StreamBufferingEncoder.HeadersFrame.send(ChannelHandlerContext ctx,
int streamId) |
(package private) void |
StreamBufferingEncoder.DataFrame.send(ChannelHandlerContext ctx,
int streamId) |
private void |
Http2ConnectionHandler.PrefaceDecoder.sendPreface(ChannelHandlerContext ctx)
Sends the HTTP/2 connection preface upon establishment of the connection, if not already sent.
|
java.util.Collection<java.lang.CharSequence> |
Http2ClientUpgradeCodec.setUpgradeHeaders(ChannelHandlerContext ctx,
HttpRequest upgradeRequest) |
private boolean |
DefaultHttp2ConnectionDecoder.FrameReadListener.shouldIgnoreHeadersOrDataFrame(ChannelHandlerContext ctx,
int streamId,
Http2Stream stream,
java.lang.String frameName)
Helper method to determine if a frame that has the semantics of headers or data should be ignored for the
stream (which may be null ) associated with streamId . |
static ByteBuf |
Http2CodecUtil.toByteBuf(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Creates a buffer containing the error message from the given exception.
|
void |
Http2ServerUpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpRequest upgradeRequest) |
void |
Http2ClientUpgradeCodec.upgradeTo(ChannelHandlerContext ctx,
FullHttpResponse upgradeResponse) |
void |
Http2MultiplexCodec.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
Http2FrameCodec.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt)
Handles the cleartext HTTP upgrade event.
|
void |
DefaultHttp2ConnectionEncoder.FlowControlledData.write(ChannelHandlerContext ctx,
int allowedBytes) |
void |
DefaultHttp2ConnectionEncoder.FlowControlledHeaders.write(ChannelHandlerContext ctx,
int allowedBytes) |
void |
Http2RemoteFlowController.FlowControlled.write(ChannelHandlerContext ctx,
int allowedBytes)
Writes up to
allowedBytes of the encapsulated payload to the stream. |
void |
Http2ConnectionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
HttpToHttp2ConnectionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Handles conversion of
HttpMessage and HttpContent to HTTP/2 frames. |
void |
Http2FrameCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Processes all
Http2Frame s. |
private ChannelFuture |
DefaultHttp2FrameWriter.writeContinuationFrames(ChannelHandlerContext ctx,
int streamId,
ByteBuf headerBlock,
int padding,
Http2CodecUtil.SimpleChannelPromiseAggregator promiseAggregator)
Writes as many continuation frames as needed until
padding and headerBlock are consumed. |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2DataWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a
DATA frame to the remote endpoint. |
ChannelFuture |
StreamBufferingEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeData(ChannelHandlerContext ctx,
int streamId,
ByteBuf data,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise)
Generic write method for any HTTP/2 frame.
|
ChannelFuture |
Http2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise)
Writes the given data to the internal
Http2FrameWriter without performing any
state checks on the connection/stream. |
ChannelFuture |
Http2OutboundFrameLogger.writeFrame(ChannelHandlerContext ctx,
byte frameType,
int streamId,
Http2Flags flags,
ByteBuf payload,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise)
Writes a GO_AWAY frame to the remote endpoint.
|
ChannelFuture |
Http2OutboundFrameLogger.writeGoAway(ChannelHandlerContext ctx,
int lastStreamId,
long errorCode,
ByteBuf debugData,
ChannelPromise promise) |
private static void |
HttpToHttp2ConnectionHandler.writeHeaders(ChannelHandlerContext ctx,
Http2ConnectionEncoder encoder,
int streamId,
HttpHeaders headers,
Http2Headers http2Headers,
boolean endStream,
Http2CodecUtil.SimpleChannelPromiseAggregator promiseAggregator) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a HEADERS frame to the remote endpoint.
|
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise)
Writes a HEADERS frame with priority specified to the remote endpoint.
|
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endOfStream,
ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int streamDependency,
short weight,
boolean exclusive,
int padding,
boolean endStream,
ChannelPromise promise) |
private ChannelFuture |
DefaultHttp2FrameWriter.writeHeadersInternal(ChannelHandlerContext ctx,
int streamId,
Http2Headers headers,
int padding,
boolean endStream,
boolean hasPriority,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise)
Writes a PING frame to the remote endpoint.
|
ChannelFuture |
Http2OutboundFrameLogger.writePing(ChannelHandlerContext ctx,
boolean ack,
ByteBuf data,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise)
Writes a PRIORITY frame to the remote endpoint.
|
ChannelFuture |
Http2OutboundFrameLogger.writePriority(ChannelHandlerContext ctx,
int streamId,
int streamDependency,
short weight,
boolean exclusive,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise)
Writes a PUSH_PROMISE frame to the remote endpoint.
|
ChannelFuture |
Http2OutboundFrameLogger.writePushPromise(ChannelHandlerContext ctx,
int streamId,
int promisedStreamId,
Http2Headers headers,
int padding,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise)
Writes a RST_STREAM frame to the remote endpoint.
|
ChannelFuture |
Http2OutboundFrameLogger.writeRstStream(ChannelHandlerContext ctx,
int streamId,
long errorCode,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise)
Writes a SETTINGS frame to the remote endpoint.
|
ChannelFuture |
Http2OutboundFrameLogger.writeSettings(ChannelHandlerContext ctx,
Http2Settings settings,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise)
Writes a SETTINGS acknowledgment to the remote endpoint.
|
ChannelFuture |
Http2OutboundFrameLogger.writeSettingsAck(ChannelHandlerContext ctx,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
DefaultHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise)
Writes a WINDOW_UPDATE frame to the remote endpoint.
|
ChannelFuture |
Http2OutboundFrameLogger.writeWindowUpdate(ChannelHandlerContext ctx,
int streamId,
int windowSizeIncrement,
ChannelPromise promise) |
Constructor and Description |
---|
ClosingChannelFutureListener(ChannelHandlerContext ctx,
ChannelPromise promise) |
ClosingChannelFutureListener(ChannelHandlerContext ctx,
ChannelPromise promise,
long timeout,
java.util.concurrent.TimeUnit unit) |
DataFrameHeader(ChannelHandlerContext ctx,
int streamId) |
PendingStream(ChannelHandlerContext ctx,
int streamId) |
PrefaceDecoder(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
JsonObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected ByteBuf |
JsonObjectDecoder.extractObject(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length)
Override this method if you want to filter the json objects/arrays that get passed through the pipeline.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMemcacheObjectEncoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
protected abstract ByteBuf |
AbstractMemcacheObjectEncoder.encodeMessage(ChannelHandlerContext ctx,
M msg)
Take the given
MemcacheMessage and encode it into a writable ByteBuf . |
Modifier and Type | Method and Description |
---|---|
void |
AbstractBinaryMemcacheDecoder.channelInactive(ChannelHandlerContext ctx)
When the channel goes inactive, release all frames to prevent data leaks.
|
void |
BinaryMemcacheClientCodec.Decoder.channelInactive(ChannelHandlerContext ctx) |
protected void |
AbstractBinaryMemcacheDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
BinaryMemcacheClientCodec.Decoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
BinaryMemcacheClientCodec.Encoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
protected ByteBuf |
AbstractBinaryMemcacheEncoder.encodeMessage(ChannelHandlerContext ctx,
M msg) |
Modifier and Type | Method and Description |
---|---|
protected void |
MqttDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer,
java.util.List<java.lang.Object> out) |
protected void |
MqttEncoder.encode(ChannelHandlerContext ctx,
MqttMessage msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
RedisDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
RedisArrayAggregator.decode(ChannelHandlerContext ctx,
RedisMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
RedisEncoder.encode(ChannelHandlerContext ctx,
RedisMessage msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SctpInboundByteStreamHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
SctpMessageCompletionHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
SctpOutboundByteStreamHandler.encode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
ObjectDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in) |
protected void |
CompatibleObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
protected void |
ObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected SmtpResponse |
SmtpResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
SmtpRequestEncoder.encode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SocksAuthResponseDecoder.decode(ChannelHandlerContext channelHandlerContext,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksInitResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksMessageEncoder.encode(ChannelHandlerContext ctx,
SocksMessage msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SocksPortUnificationServerHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private static void |
SocksPortUnificationServerHandler.logKnownVersion(ChannelHandlerContext ctx,
SocksVersion version) |
private static void |
SocksPortUnificationServerHandler.logUnknownVersion(ChannelHandlerContext ctx,
byte versionVal) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks4ClientDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks4ServerDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks4ClientEncoder.encode(ChannelHandlerContext ctx,
Socks4CommandRequest msg,
ByteBuf out) |
protected void |
Socks4ServerEncoder.encode(ChannelHandlerContext ctx,
Socks4CommandResponse msg,
ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks5InitialResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5PasswordAuthRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5CommandResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5PasswordAuthResponseDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5CommandRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5InitialRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
Socks5ServerEncoder.encode(ChannelHandlerContext ctx,
Socks5Message msg,
ByteBuf out) |
protected void |
Socks5ClientEncoder.encode(ChannelHandlerContext ctx,
Socks5Message msg,
ByteBuf out) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
SpdyFrameCodec.ctx |
private ChannelHandlerContext |
SpdySessionHandler.ClosingChannelFutureListener.ctx |
Modifier and Type | Method and Description |
---|---|
void |
SpdyFrameCodec.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SpdySessionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SpdyHttpDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
SpdyFrameCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdySessionHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected void |
SpdyFrameCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpResponseStreamIdHandler.decode(ChannelHandlerContext ctx,
java.lang.Object msg,
java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpDecoder.decode(ChannelHandlerContext ctx,
SpdyFrame msg,
java.util.List<java.lang.Object> out) |
void |
SpdyFrameCodec.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SpdyFrameCodec.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
SpdyHttpResponseStreamIdHandler.encode(ChannelHandlerContext ctx,
HttpMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpEncoder.encode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
void |
SpdySessionHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
SpdyFrameCodec.flush(ChannelHandlerContext ctx) |
private void |
SpdySessionHandler.handleOutboundMessage(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
SpdyFrameCodec.handlerAdded(ChannelHandlerContext ctx) |
private void |
SpdySessionHandler.issueSessionError(ChannelHandlerContext ctx,
SpdySessionStatus status) |
private void |
SpdySessionHandler.issueStreamError(ChannelHandlerContext ctx,
int streamId,
SpdyStreamStatus status) |
void |
SpdyFrameCodec.read(ChannelHandlerContext ctx) |
private void |
SpdySessionHandler.sendGoAwayFrame(ChannelHandlerContext ctx,
ChannelPromise future) |
private ChannelFuture |
SpdySessionHandler.sendGoAwayFrame(ChannelHandlerContext ctx,
SpdySessionStatus status) |
private void |
SpdySessionHandler.updateSendWindowSize(ChannelHandlerContext ctx,
int streamId,
int deltaWindowSize) |
void |
SpdyFrameCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
SpdySessionHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Constructor and Description |
---|
ClosingChannelFutureListener(ChannelHandlerContext ctx,
ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
StompSubframeDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
StompSubframeEncoder.encode(ChannelHandlerContext ctx,
StompSubframe msg,
java.util.List<java.lang.Object> out) |
private static ByteBuf |
StompSubframeEncoder.encodeContent(StompContentSubframe content,
ChannelHandlerContext ctx) |
private static ByteBuf |
StompSubframeEncoder.encodeFrame(StompHeadersSubframe frame,
ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
StringDecoder.decode(ChannelHandlerContext ctx,
ByteBuf msg,
java.util.List<java.lang.Object> out) |
protected void |
StringEncoder.encode(ChannelHandlerContext ctx,
java.lang.CharSequence msg,
java.util.List<java.lang.Object> out) |
protected void |
LineEncoder.encode(ChannelHandlerContext ctx,
java.lang.CharSequence msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
XmlFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
private static void |
XmlFrameDecoder.fail(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
FlowControlHandler.channelInactive(ChannelHandlerContext ctx) |
void |
FlowControlHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
FlowControlHandler.channelReadComplete(ChannelHandlerContext ctx) |
private int |
FlowControlHandler.dequeue(ChannelHandlerContext ctx,
int minConsume)
Dequeues one or many (or none) messages depending on the channel's auto
reading state and returns the number of messages that were consumed from
the internal queue.
|
void |
FlowControlHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
FlowControlHandler.read(ChannelHandlerContext ctx) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
FlushConsolidationHandler.ctx |
Modifier and Type | Method and Description |
---|---|
void |
FlushConsolidationHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
FlushConsolidationHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
FlushConsolidationHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
FlushConsolidationHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
FlushConsolidationHandler.flush(ChannelHandlerContext ctx) |
private void |
FlushConsolidationHandler.flushIfNeeded(ChannelHandlerContext ctx) |
private void |
FlushConsolidationHandler.flushNow(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.handlerRemoved(ChannelHandlerContext ctx) |
private void |
FlushConsolidationHandler.resetReadAndFlushIfNeeded(ChannelHandlerContext ctx) |
private void |
FlushConsolidationHandler.scheduleFlush(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
RuleBasedIpFilter.accept(ChannelHandlerContext ctx,
java.net.InetSocketAddress remoteAddress) |
protected boolean |
UniqueIpFilter.accept(ChannelHandlerContext ctx,
java.net.InetSocketAddress remoteAddress) |
protected abstract boolean |
AbstractRemoteAddressFilter.accept(ChannelHandlerContext ctx,
T remoteAddress)
This method is called immediately after a
Channel gets registered. |
protected void |
AbstractRemoteAddressFilter.channelAccepted(ChannelHandlerContext ctx,
T remoteAddress)
This method is called if
remoteAddress gets accepted by
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) . |
void |
AbstractRemoteAddressFilter.channelActive(ChannelHandlerContext ctx) |
void |
AbstractRemoteAddressFilter.channelRegistered(ChannelHandlerContext ctx) |
protected ChannelFuture |
AbstractRemoteAddressFilter.channelRejected(ChannelHandlerContext ctx,
T remoteAddress)
This method is called if
remoteAddress gets rejected by
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) . |
private boolean |
AbstractRemoteAddressFilter.handleNewChannel(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
LoggingHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.channelActive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelInactive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
LoggingHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
LoggingHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
LoggingHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
LoggingHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
LoggingHandler.flush(ChannelHandlerContext ctx) |
protected java.lang.String |
LoggingHandler.format(ChannelHandlerContext ctx,
java.lang.String eventName)
Formats an event and returns the formatted message.
|
protected java.lang.String |
LoggingHandler.format(ChannelHandlerContext ctx,
java.lang.String eventName,
java.lang.Object arg)
Formats an event and returns the formatted message.
|
protected java.lang.String |
LoggingHandler.format(ChannelHandlerContext ctx,
java.lang.String eventName,
java.lang.Object firstArg,
java.lang.Object secondArg)
Formats an event and returns the formatted message.
|
private static java.lang.String |
LoggingHandler.formatByteBuf(ChannelHandlerContext ctx,
java.lang.String eventName,
ByteBuf msg)
Generates the default log message of the specified event whose argument is a
ByteBuf . |
private static java.lang.String |
LoggingHandler.formatByteBufHolder(ChannelHandlerContext ctx,
java.lang.String eventName,
ByteBufHolder msg)
Generates the default log message of the specified event whose argument is a
ByteBufHolder . |
private static java.lang.String |
LoggingHandler.formatSimple(ChannelHandlerContext ctx,
java.lang.String eventName,
java.lang.Object msg)
Generates the default log message of the specified event whose argument is an arbitrary object.
|
void |
LoggingHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
LoggingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
ProxyHandler.ctx |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
ProxyHandler.addCodec(ChannelHandlerContext ctx)
Adds the codec handlers required to communicate with the proxy server.
|
protected void |
Socks5ProxyHandler.addCodec(ChannelHandlerContext ctx) |
protected void |
Socks4ProxyHandler.addCodec(ChannelHandlerContext ctx) |
protected void |
HttpProxyHandler.addCodec(ChannelHandlerContext ctx) |
private void |
ProxyHandler.addPendingWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ProxyHandler.channelActive(ChannelHandlerContext ctx) |
void |
ProxyHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ProxyHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ProxyHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ProxyHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ProxyHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
ProxyHandler.flush(ChannelHandlerContext ctx) |
void |
ProxyHandler.handlerAdded(ChannelHandlerContext ctx) |
protected abstract boolean |
ProxyHandler.handleResponse(ChannelHandlerContext ctx,
java.lang.Object response)
Handles the message received from the proxy server.
|
protected boolean |
Socks5ProxyHandler.handleResponse(ChannelHandlerContext ctx,
java.lang.Object response) |
protected boolean |
Socks4ProxyHandler.handleResponse(ChannelHandlerContext ctx,
java.lang.Object response) |
protected boolean |
HttpProxyHandler.handleResponse(ChannelHandlerContext ctx,
java.lang.Object response) |
protected abstract java.lang.Object |
ProxyHandler.newInitialMessage(ChannelHandlerContext ctx)
Returns a new message that is sent at first time when the connection to the proxy server has been established.
|
protected java.lang.Object |
Socks5ProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected java.lang.Object |
Socks4ProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected java.lang.Object |
HttpProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
private static void |
ProxyHandler.readIfNeeded(ChannelHandlerContext ctx) |
protected abstract void |
ProxyHandler.removeDecoder(ChannelHandlerContext ctx)
Removes the decoders added in
ProxyHandler.addCodec(ChannelHandlerContext) . |
protected void |
Socks5ProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected void |
Socks4ProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected void |
HttpProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected abstract void |
ProxyHandler.removeEncoder(ChannelHandlerContext ctx)
Removes the encoders added in
ProxyHandler.addCodec(ChannelHandlerContext) . |
protected void |
Socks5ProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
protected void |
Socks4ProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
protected void |
HttpProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
private void |
Socks5ProxyHandler.sendConnectCommand(ChannelHandlerContext ctx) |
private void |
ProxyHandler.sendInitialMessage(ChannelHandlerContext ctx)
Sends the initial message to be sent to the proxy server.
|
void |
ProxyHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
SslHandler.ctx |
Modifier and Type | Method and Description |
---|---|
private ByteBuf |
SslHandler.allocate(ChannelHandlerContext ctx,
int capacity)
Always prefer a direct buffer when it's pooled, so that we reduce the number of memory copies
in
OpenSslEngine . |
private ByteBuf |
SslHandler.allocateOutNetBuf(ChannelHandlerContext ctx,
int pendingBytes,
int numComponents)
Allocates an outbound network buffer for
SSLEngine.wrap(ByteBuffer, ByteBuffer) which can encrypt
the specified amount of pending bytes. |
void |
AbstractSniHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.channelActive(ChannelHandlerContext ctx)
Issues an initial TLS handshake once connected when used in client-mode
|
void |
SslHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SslHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
AbstractSniHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
SslHandler.closeOutboundAndChannel(ChannelHandlerContext ctx,
ChannelPromise promise,
boolean disconnect) |
protected abstract void |
ApplicationProtocolNegotiationHandler.configurePipeline(ChannelHandlerContext ctx,
java.lang.String protocol)
Invoked on successful initial SSL/TLS handshake.
|
void |
AbstractSniHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
SslHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected void |
AbstractSniHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SslHandler.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
OptionalSslHandler.decode(ChannelHandlerContext context,
ByteBuf in,
java.util.List<java.lang.Object> out) |
void |
AbstractSniHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
AbstractSniHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
ApplicationProtocolNegotiationHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
private void |
SslHandler.finishWrap(ChannelHandlerContext ctx,
ByteBuf out,
ChannelPromise promise,
boolean inUnwrap,
boolean needUnwrap) |
void |
AbstractSniHandler.flush(ChannelHandlerContext ctx) |
void |
SslHandler.flush(ChannelHandlerContext ctx) |
private void |
SslHandler.flush(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
SslHandler.flushIfNeeded(ChannelHandlerContext ctx) |
private void |
SslHandler.forceFlush(ChannelHandlerContext ctx) |
private void |
OptionalSslHandler.handleNonSsl(ChannelHandlerContext context) |
void |
SslHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
SslHandler.handlerRemoved0(ChannelHandlerContext ctx) |
private void |
OptionalSslHandler.handleSsl(ChannelHandlerContext context) |
protected void |
ApplicationProtocolNegotiationHandler.handshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Invoked on failed initial SSL/TLS handshake.
|
protected abstract Future<T> |
AbstractSniHandler.lookup(ChannelHandlerContext ctx,
java.lang.String hostname)
Kicks off a lookup for the given SNI value and returns a
Future which in turn will
notify the AbstractSniHandler.onLookupComplete(ChannelHandlerContext, String, Future) on completion. |
protected Future<SslContext> |
SniHandler.lookup(ChannelHandlerContext ctx,
java.lang.String hostname)
The default implementation will simply call
AsyncMapping.map(Object, Promise) but
users can override this method to implement custom behavior. |
protected ChannelHandler |
OptionalSslHandler.newNonSslHandler(ChannelHandlerContext context)
Override to configure the ChannelHandler.
|
protected SslHandler |
OptionalSslHandler.newSslHandler(ChannelHandlerContext context,
SslContext sslContext)
Override to configure the SslHandler eg.
|
(package private) static void |
SslUtils.notifyHandshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
protected void |
SniHandler.onLookupComplete(ChannelHandlerContext ctx,
java.lang.String hostname,
Future<SslContext> future) |
protected abstract void |
AbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx,
java.lang.String hostname,
Future<T> future)
Called upon completion of the
AbstractSniHandler.lookup(ChannelHandlerContext, String) Future . |
void |
AbstractSniHandler.read(ChannelHandlerContext ctx) |
void |
SslHandler.read(ChannelHandlerContext ctx) |
private void |
SslHandler.readIfNeeded(ChannelHandlerContext ctx) |
protected void |
SniHandler.replaceHandler(ChannelHandlerContext ctx,
java.lang.String hostname,
SslContext sslContext)
The default implementation of this method will simply replace
this SniHandler
instance with a SslHandler . |
private void |
SslHandler.safeClose(ChannelHandlerContext ctx,
ChannelFuture flushFuture,
ChannelPromise promise) |
private void |
AbstractSniHandler.select(ChannelHandlerContext ctx,
java.lang.String hostname) |
private void |
SslHandler.setHandshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Notify all the handshake futures about the failure during the handshake.
|
private void |
SslHandler.setHandshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause,
boolean closeInbound)
Notify all the handshake futures about the failure during the handshake.
|
private boolean |
SslHandler.unwrap(ChannelHandlerContext ctx,
ByteBuf packet,
int offset,
int length)
Unwraps inbound SSL records.
|
private void |
SslHandler.unwrapNonAppData(ChannelHandlerContext ctx)
Calls
SSLEngine.unwrap(ByteBuffer, ByteBuffer) with an empty buffer to handle handshakes, etc. |
void |
ApplicationProtocolNegotiationHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
private void |
SslHandler.wrap(ChannelHandlerContext ctx,
boolean inUnwrap) |
private void |
SslHandler.wrapAndFlush(ChannelHandlerContext ctx) |
private void |
SslHandler.wrapNonAppData(ChannelHandlerContext ctx,
boolean inUnwrap)
|
void |
AbstractSniHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
SslHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
ChunkedWriteHandler.ctx |
Modifier and Type | Method and Description |
---|---|
void |
ChunkedWriteHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
private void |
ChunkedWriteHandler.doFlush(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.flush(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.handlerAdded(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedNioFile.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
B |
ChunkedInput.readChunk(ChannelHandlerContext ctx)
Deprecated.
Use
ChunkedInput.readChunk(ByteBufAllocator) .
Fetches a chunked data from the stream. Once this method returns the last chunk
and thus the stream has reached at its end, any subsequent |
ByteBuf |
ChunkedFile.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
ByteBuf |
ChunkedStream.readChunk(ChannelHandlerContext ctx)
Deprecated.
|
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
private ChannelHandlerContext |
WriteTimeoutHandler.WriteTimeoutTask.ctx |
private ChannelHandlerContext |
IdleStateHandler.AbstractIdleTask.ctx |
Modifier and Type | Method and Description |
---|---|
void |
IdleStateHandler.channelActive(ChannelHandlerContext ctx) |
protected void |
IdleStateHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt)
Is called when an
IdleStateEvent should be fired. |
protected void |
ReadTimeoutHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt) |
void |
IdleStateHandler.channelInactive(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
IdleStateHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WriteTimeoutHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerRemoved(ChannelHandlerContext ctx) |
private boolean |
IdleStateHandler.hasOutputChanged(ChannelHandlerContext ctx,
boolean first)
Returns
true if and only if the IdleStateHandler was constructed
with IdleStateHandler.observeOutput enabled and there has been an observed change in the
ChannelOutboundBuffer between two consecutive calls of this method. |
private void |
IdleStateHandler.initialize(ChannelHandlerContext ctx) |
private void |
IdleStateHandler.initOutputChanged(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.readTimedOut(ChannelHandlerContext ctx)
Is called when a read timeout was detected.
|
protected abstract void |
IdleStateHandler.AbstractIdleTask.run(ChannelHandlerContext ctx) |
protected void |
IdleStateHandler.ReaderIdleTimeoutTask.run(ChannelHandlerContext ctx) |
protected void |
IdleStateHandler.WriterIdleTimeoutTask.run(ChannelHandlerContext ctx) |
protected void |
IdleStateHandler.AllIdleTimeoutTask.run(ChannelHandlerContext ctx) |
(package private) java.util.concurrent.ScheduledFuture<?> |
IdleStateHandler.schedule(ChannelHandlerContext ctx,
java.lang.Runnable task,
long delay,
java.util.concurrent.TimeUnit unit)
This method is visible for testing!
|
private void |
WriteTimeoutHandler.scheduleTimeout(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
WriteTimeoutHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
IdleStateHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
protected void |
WriteTimeoutHandler.writeTimedOut(ChannelHandlerContext ctx)
Is called when a write timeout was detected
|
Constructor and Description |
---|
AbstractIdleTask(ChannelHandlerContext ctx) |
AllIdleTimeoutTask(ChannelHandlerContext ctx) |
ReaderIdleTimeoutTask(ChannelHandlerContext ctx) |
WriterIdleTimeoutTask(ChannelHandlerContext ctx) |
WriteTimeoutTask(ChannelHandlerContext ctx,
ChannelPromise promise) |
Modifier and Type | Field and Description |
---|---|
(package private) ChannelHandlerContext |
AbstractTrafficShapingHandler.ReopenReadTimerTask.ctx |
Modifier and Type | Method and Description |
---|---|
void |
AbstractTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
GlobalChannelTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
AbstractTrafficShapingHandler.channelRegistered(ChannelHandlerContext ctx) |
(package private) long |
AbstractTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now)
Method overridden in GTSH to take into account specific timer for the channel.
|
(package private) long |
GlobalTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
protected long |
GlobalChannelTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
(package private) void |
AbstractTrafficShapingHandler.checkWriteSuspend(ChannelHandlerContext ctx,
long delay,
long queueSize)
Check the writability according to delay and size for the channel.
|
private GlobalTrafficShapingHandler.PerChannel |
GlobalTrafficShapingHandler.getOrSetPerChannel(ChannelHandlerContext ctx) |
private GlobalChannelTrafficShapingHandler.PerChannel |
GlobalChannelTrafficShapingHandler.getOrSetPerChannel(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
GlobalTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
(package private) void |
AbstractTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now)
Method overridden in GTSH to take into account specific timer for the channel.
|
(package private) void |
GlobalTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now) |
protected void |
GlobalChannelTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now) |
protected static boolean |
AbstractTrafficShapingHandler.isHandlerActive(ChannelHandlerContext ctx) |
void |
AbstractTrafficShapingHandler.read(ChannelHandlerContext ctx) |
(package private) void |
AbstractTrafficShapingHandler.releaseReadSuspended(ChannelHandlerContext ctx)
Release the Read suspension
|
(package private) void |
AbstractTrafficShapingHandler.releaseWriteSuspended(ChannelHandlerContext ctx)
Explicitly release the Write suspended status.
|
private void |
GlobalChannelTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx,
GlobalChannelTrafficShapingHandler.PerChannel perChannel,
long now) |
private void |
GlobalTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx,
GlobalTrafficShapingHandler.PerChannel perChannel,
long now) |
private void |
ChannelTrafficShapingHandler.sendAllValid(ChannelHandlerContext ctx,
long now) |
(package private) void |
AbstractTrafficShapingHandler.setUserDefinedWritability(ChannelHandlerContext ctx,
boolean writable) |
protected void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long delay,
ChannelPromise promise)
Deprecated.
|
(package private) abstract void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long delay,
long now,
ChannelPromise promise) |
(package private) void |
ChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long delay,
long now,
ChannelPromise promise) |
(package private) void |
GlobalTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
void |
AbstractTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
GlobalChannelTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Constructor and Description |
---|
ReopenReadTimerTask(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
DnsNameResolver.DnsResponseHandler.channelActive(ChannelHandlerContext ctx) |
void |
DnsNameResolver.DnsResponseHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
DnsNameResolver.DnsResponseHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |