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.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.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.socks |
Encoder, decoder and their related message types for Socks.
|
io.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
io.netty.handler.codec.string |
Encoder and decoder which transform a
String into a
ByteBuf and vice versa. |
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 a
io.netty.channel.ChannelEvent for debugging purpose. |
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.
|
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 |
AbstractChannelHandlerContext.fireChannelActive() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelActive() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelActive()
A
Channel is active now, which means it is connected. |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelInactive() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelInactive() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelInactive()
A
Channel is inactive now, which means it is closed. |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelRead(java.lang.Object msg) |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelRead(java.lang.Object msg) |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRead(java.lang.Object msg)
A
Channel received a message. |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelReadComplete() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelReadComplete() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelReadComplete()
Triggers an
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext)
event to the next ChannelInboundHandler in the ChannelPipeline . |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelRegistered() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelRegistered() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelRegistered()
|
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelUnregistered() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelUnregistered() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelUnregistered()
|
ChannelHandlerContext |
AbstractChannelHandlerContext.fireChannelWritabilityChanged() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireChannelWritabilityChanged() |
ChannelHandlerContext |
ChannelHandlerContext.fireChannelWritabilityChanged()
Triggers an
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext)
event to the next ChannelInboundHandler in the ChannelPipeline . |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireExceptionCaught(java.lang.Throwable cause) |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireExceptionCaught(java.lang.Throwable cause) |
ChannelHandlerContext |
ChannelHandlerContext.fireExceptionCaught(java.lang.Throwable cause)
A
Channel received an Throwable in one of its inbound operations. |
ChannelHandlerContext |
AbstractChannelHandlerContext.fireUserEventTriggered(java.lang.Object event) |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.fireUserEventTriggered(java.lang.Object event) |
ChannelHandlerContext |
ChannelHandlerContext.fireUserEventTriggered(java.lang.Object evt)
A
Channel received an user defined event. |
ChannelHandlerContext |
ChannelPipeline.firstContext()
Returns the context of the first
ChannelHandler in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.firstContext() |
ChannelHandlerContext |
AbstractChannelHandlerContext.flush() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.flush() |
ChannelHandlerContext |
ChannelHandlerContext.flush()
Request to flush all pending messages via this ChannelOutboundInvoker.
|
ChannelHandlerContext |
ChannelPipeline.lastContext()
Returns the context of the last
ChannelHandler in this pipeline. |
ChannelHandlerContext |
DefaultChannelPipeline.lastContext() |
ChannelHandlerContext |
AbstractChannelHandlerContext.read() |
ChannelHandlerContext |
CombinedChannelDuplexHandler.DelegatingChannelHandlerContext.read() |
ChannelHandlerContext |
ChannelHandlerContext.read()
Request to Read data from the
Channel into the first inbound buffer, triggers an
ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) event if data was
read, and triggers a
channelReadComplete event so the
handler can decide to continue reading. |
Modifier and Type | Method and Description |
---|---|
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
bind(SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
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 |
ChannelInboundHandler.channelActive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext is now active |
void |
ChannelInboundHandlerAdapter.channelActive(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelActive(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelActive(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelActive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelInactive(ChannelHandlerContext ctx)
The
Channel of the ChannelHandlerContext was registered is now inactive and reached its
end of lifetime. |
void |
ChannelInboundHandlerAdapter.channelInactive(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelInactive(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelInactive(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelInactive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg)
Invoked when the current
Channel has read a message from the peer. |
void |
ChannelInboundHandlerAdapter.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg)
|
void |
SimpleChannelInboundHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
CombinedChannelDuplexHandler.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 |
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext ctx)
Invoked when the last message read by the current read operation has been consumed by
ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) . |
void |
ChannelInboundHandlerAdapter.channelReadComplete(ChannelHandlerContext ctx)
Calls
fireChannelReadComplete() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelReadComplete(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelReadComplete(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandlerAdapter.channelRegistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelRegistered(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInitializer.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelUnregistered(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandlerAdapter.channelUnregistered(ChannelHandlerContext ctx)
Calls
fireChannelUnregistered() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelUnregistered(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelUnregistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext ctx)
Gets called once the writable state of a
Channel changed. |
void |
ChannelInboundHandlerAdapter.channelWritabilityChanged(ChannelHandlerContext ctx)
Calls
fireChannelWritabilityChanged() to forward
to the next ChannelInboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx,
ChannelPromise promise)
Called once a close operation is made.
|
void |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
Calls
connect(SocketAddress, SocketAddress, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.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
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 |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
deregister(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 |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
disconnect(ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise)
Calls
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 |
ChannelInboundHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Gets called if a
Throwable was thrown. |
void |
ChannelInboundHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
|
void |
ChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
|
void |
CombinedChannelDuplexHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
DefaultChannelPipeline.TailContext.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
DefaultChannelPipeline.HeadContext.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 |
ChannelHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Deprecated.
is part of
ChannelInboundHandler |
void |
ChannelDuplexHandler.flush(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.flush(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.flush(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.flush(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.flush(ChannelHandlerContext ctx)
Called once a flush operation is made.
|
void |
ChannelHandlerAdapter.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
CombinedChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.handlerAdded(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelInitializer.handlerAdded(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
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.handlerRemoved(ChannelHandlerContext ctx)
Do nothing by default, sub-classes may override this method.
|
void |
CombinedChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.TailContext.handlerRemoved(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.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. |
private boolean |
ChannelInitializer.initChannel(ChannelHandlerContext ctx) |
void |
ChannelDuplexHandler.read(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.read(ChannelHandlerContext ctx) |
void |
DefaultChannelPipeline.HeadContext.read(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.read(ChannelHandlerContext ctx)
|
void |
ChannelOutboundHandler.read(ChannelHandlerContext ctx)
Intercepts
read() . |
private void |
ChannelInitializer.remove(ChannelHandlerContext ctx) |
void |
ChannelInboundHandler.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt)
Gets called if an user event was triggered.
|
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 |
DefaultChannelPipeline.TailContext.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
DefaultChannelPipeline.HeadContext.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
write(Object, ChannelPromise) to forward
to the next ChannelOutboundHandler in the ChannelPipeline . |
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
DefaultChannelPipeline.HeadContext.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise)
Calls
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.
|
Constructor and Description |
---|
DelegatingChannelHandlerContext(ChannelHandlerContext ctx,
ChannelHandler handler) |
PendingWriteQueue(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
LengthFieldPrepender.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
protected ByteBuf |
MessageToByteEncoder.allocateBuffer(ChannelHandlerContext ctx,
I msg,
boolean preferDirect)
Allocate a
ByteBuf which will be used as argument of #encode(ChannelHandlerContext, I, ByteBuf) . |
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 |
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 |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
ByteToMessageCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
protected java.lang.Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in)
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 java.lang.Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected java.lang.Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf buffer)
Create a frame out of the
ByteBuf and return it. |
protected abstract void |
ByteToMessageCodec.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 void |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
LineBasedFrameDecoder.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 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. |
protected void |
LengthFieldPrepender.encode(ChannelHandlerContext ctx,
ByteBuf msg,
ByteBuf 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) |
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 |
ByteToMessageCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.handlerRemoved(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.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. |
void |
ByteToMessageDecoder.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
void |
ByteToMessageCodec.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToByteEncoder.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
MessageToMessageCodec.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 |
JZlibEncoder.ctx |
private ChannelHandlerContext |
JdkZlibEncoder.ctx |
Modifier and Type | Method and Description |
---|---|
private ChannelHandlerContext |
JZlibEncoder.ctx() |
private ChannelHandlerContext |
JdkZlibEncoder.ctx() |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx,
ByteBuf msg,
boolean preferDirect) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx,
ChannelPromise promise) |
protected void |
SnappyFramedDecoder.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 |
JZlibDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
JZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
SnappyFramedEncoder.encode(ChannelHandlerContext ctx,
ByteBuf in,
ByteBuf out) |
protected void |
JdkZlibEncoder.encode(ChannelHandlerContext ctx,
ByteBuf uncompressed,
ByteBuf out) |
private ChannelFuture |
JZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
private ChannelFuture |
JdkZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
JZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
protected void |
JdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
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 |
---|---|
protected ChannelHandlerContext |
HttpContentDecoder.ctx |
private ChannelHandlerContext |
HttpContentCompressor.ctx |
private ChannelHandlerContext |
HttpObjectAggregator.ctx |
Modifier and Type | Method and Description |
---|---|
void |
HttpContentEncoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpObjectAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
HttpClientCodec.Decoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpServerKeepAliveHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
protected void |
HttpObjectDecoder.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 |
HttpContentDecoder.decode(ChannelHandlerContext ctx,
HttpObject msg,
java.util.List<java.lang.Object> out) |
protected void |
HttpObjectAggregator.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) |
protected void |
HttpContentEncoder.encode(ChannelHandlerContext ctx,
HttpObject 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) |
protected void |
HttpObjectEncoder.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 |
HttpContentDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentCompressor.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpObjectAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpObjectAggregator.handlerRemoved(ChannelHandlerContext ctx) |
HttpContent |
HttpChunkedInput.readChunk(ChannelHandlerContext ctx) |
void |
HttpObjectDecoder.userEventTriggered(ChannelHandlerContext ctx,
java.lang.Object evt) |
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) |
void |
CorsHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
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)
Returns the next available HttpChunk.
|
Modifier and Type | Method and Description |
---|---|
void |
WebSocketClientProtocolHandshakeHandler.channelActive(ChannelHandlerContext ctx) |
void |
WebSocketFrameAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
WebSocket08FrameDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
WebSocketServerProtocolHandshakeHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
WebSocketClientProtocolHandshakeHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(ChannelHandlerContext ctx,
ByteBuf buffer) |
private void |
WebSocket08FrameDecoder.checkUTF8String(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
WebSocket00FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
WebSocketFrameAggregator.decode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
protected void |
WebSocketServerProtocolHandler.decode(ChannelHandlerContext ctx,
WebSocketFrame frame,
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) |
private WebSocketFrame |
WebSocket00FrameDecoder.decodeBinaryFrame(ChannelHandlerContext ctx,
byte type,
ByteBuf buffer) |
private WebSocketFrame |
WebSocket00FrameDecoder.decodeTextFrame(ChannelHandlerContext ctx,
ByteBuf buffer) |
protected void |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
protected void |
WebSocket00FrameEncoder.encode(ChannelHandlerContext ctx,
WebSocketFrame msg,
java.util.List<java.lang.Object> out) |
void |
WebSocketServerProtocolHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
WebSocketProtocolHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
WebSocketServerProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketClientProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketFrameAggregator.handlerRemoved(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)
Fetches a chunked data from the stream.
|
private static void |
WebSocketServerProtocolHandshakeHandler.sendHttpResponse(ChannelHandlerContext ctx,
HttpRequest req,
HttpResponse res) |
Modifier and Type | Method and Description |
---|---|
protected void |
SctpMessageCompletionHandler.decode(ChannelHandlerContext ctx,
SctpMessage msg,
java.util.List<java.lang.Object> out) |
protected void |
SctpInboundByteStreamHandler.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 |
ObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
protected void |
CompatibleObjectEncoder.encode(ChannelHandlerContext ctx,
java.io.Serializable msg,
ByteBuf out) |
protected ByteBuf |
ObjectDecoder.extractFrame(ChannelHandlerContext ctx,
ByteBuf buffer,
int index,
int length) |
Modifier and Type | Method and Description |
---|---|
protected void |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx,
ByteBuf byteBuf,
java.util.List<java.lang.Object> out) |
protected void |
SocksAuthResponseDecoder.decode(ChannelHandlerContext channelHandlerContext,
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 |
SocksInitRequestDecoder.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 |
SocksInitResponseDecoder.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 | 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 |
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) |
protected abstract void |
SpdyOrHttpChooser.configureHttp1(ChannelHandlerContext ctx)
Deprecated.
Configures the
Channel of the specified ctx for HTTP/1. |
private boolean |
SpdyOrHttpChooser.configurePipeline(ChannelHandlerContext ctx)
Deprecated.
|
protected abstract void |
SpdyOrHttpChooser.configureSpdy(ChannelHandlerContext ctx,
SpdyVersion version)
Deprecated.
Configures the
Channel of the specified ctx for HTTP/2. |
void |
SpdyFrameCodec.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
private static FullHttpResponse |
SpdyHttpDecoder.createHttpResponse(ChannelHandlerContext ctx,
int spdyVersion,
SpdyHeadersFrame responseFrame,
boolean validateHeaders) |
protected void |
SpdyFrameCodec.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out) |
protected void |
SpdyOrHttpChooser.decode(ChannelHandlerContext ctx,
ByteBuf in,
java.util.List<java.lang.Object> out)
Deprecated.
|
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 |
SpdyOrHttpChooser.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Deprecated.
|
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 |
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) |
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 |
UniqueIpFilter.accept(ChannelHandlerContext ctx,
java.net.InetSocketAddress remoteAddress) |
protected boolean |
RuleBasedIpFilter.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.channelRegistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelUnregistered(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 message) |
private void |
LoggingHandler.logMessage(ChannelHandlerContext ctx,
java.lang.String eventName,
java.lang.Object msg) |
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 |
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)
Allocates an outbound network buffer for
SSLEngine.wrap(ByteBuffer, ByteBuffer) which can encrypt
the specified amount of pending bytes. |
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 |
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 |
SslHandler.connect(ChannelHandlerContext ctx,
java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise) |
protected void |
SniHandler.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) |
void |
SslHandler.deregister(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx,
ChannelPromise promise) |
void |
ApplicationProtocolNegotiationHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
SslHandler.exceptionCaught(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
private void |
SslHandler.finishWrap(ChannelHandlerContext ctx,
ByteBuf out,
ChannelPromise promise,
boolean inUnwrap,
boolean needUnwrap) |
void |
SslHandler.flush(ChannelHandlerContext ctx) |
private void |
SslHandler.flush(ChannelHandlerContext ctx,
ChannelPromise promise) |
private void |
SslHandler.flushIfNeeded(ChannelHandlerContext ctx) |
void |
SslHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
SslHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
ApplicationProtocolNegotiationHandler.handshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Invoked on failed initial SSL/TLS handshake.
|
(package private) static void |
SslUtils.notifyHandshakeFailure(ChannelHandlerContext ctx,
java.lang.Throwable cause) |
void |
SslHandler.read(ChannelHandlerContext ctx) |
private void |
SslHandler.readIfNeeded(ChannelHandlerContext ctx) |
private void |
SslHandler.safeClose(ChannelHandlerContext ctx,
ChannelFuture flushFuture,
ChannelPromise promise) |
private void |
SniHandler.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.wrapNonAppData(ChannelHandlerContext ctx,
boolean inUnwrap) |
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 boolean |
ChunkedWriteHandler.doFlush(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.flush(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.handlerAdded(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedStream.readChunk(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedNioFile.readChunk(ChannelHandlerContext ctx) |
B |
ChunkedInput.readChunk(ChannelHandlerContext ctx)
Fetches a chunked data from the stream.
|
ByteBuf |
ChunkedFile.readChunk(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx) |
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.ReaderIdleTimeoutTask.ctx |
private ChannelHandlerContext |
IdleStateHandler.WriterIdleTimeoutTask.ctx |
private ChannelHandlerContext |
IdleStateHandler.AllIdleTimeoutTask.ctx |
Modifier and Type | Method and Description |
---|---|
void |
IdleStateHandler.channelActive(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt) |
protected void |
IdleStateHandler.channelIdle(ChannelHandlerContext ctx,
IdleStateEvent evt)
Is called when an
IdleStateEvent should be fired. |
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 void |
IdleStateHandler.initialize(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.readTimedOut(ChannelHandlerContext ctx)
Is called when a read timeout was detected.
|
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 |
---|
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 |
GlobalChannelTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
AbstractTrafficShapingHandler.channelRead(ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
AbstractTrafficShapingHandler.channelRegistered(ChannelHandlerContext ctx) |
(package private) long |
GlobalTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
protected long |
GlobalChannelTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx,
long wait,
long now) |
(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) 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 |
GlobalTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
(package private) void |
GlobalTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now) |
protected void |
GlobalChannelTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now) |
(package private) void |
AbstractTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx,
long now)
Method overridden in GTSH to take into account specific timer for the channel.
|
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) void |
GlobalTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
(package private) void |
ChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long delay,
long now,
ChannelPromise promise) |
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long writedelay,
long now,
ChannelPromise promise) |
(package private) abstract void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx,
java.lang.Object msg,
long size,
long delay,
long now,
ChannelPromise promise) |
void |
GlobalChannelTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
AbstractTrafficShapingHandler.write(ChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
Constructor and Description |
---|
ReopenReadTimerTask(ChannelHandlerContext ctx) |