| Package | Description |
|---|---|
| org.jboss.netty.bootstrap |
IoC/DI friendly helper classes which enable an easy implementation of
typical client side and server side channel initialization.
|
| org.jboss.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
| org.jboss.netty.channel.group |
A channel registry which helps a user maintain the list of open
Channels and perform bulk operations on them. |
| org.jboss.netty.channel.local |
A virtual transport that enables the communication between the two
parties in the same virtual machine.
|
| org.jboss.netty.channel.socket |
Abstract TCP and UDP socket interfaces which extend the core channel API.
|
| org.jboss.netty.channel.socket.http |
An HTTP-based client-side
SocketChannel
and its corresponding server-side Servlet implementation that make your
existing server application work in a firewalled network. |
| org.jboss.netty.channel.socket.nio |
NIO-based socket channel
API implementation - recommended for a large number of connections (>= 1000).
|
| org.jboss.netty.channel.socket.oio |
Old blocking I/O based socket channel API implementation - recommended for
a small number of connections (< 1000).
|
| org.jboss.netty.example.securechat | |
| org.jboss.netty.handler.codec.compression |
Encoder and decoder which compresses and decompresses
ChannelBuffers
in a compression format such as zlib
and gzip. |
| org.jboss.netty.handler.codec.embedder |
A helper that wraps an encoder or a decoder so that they can be used without
doing actual I/O in unit tests or higher level codecs.
|
| org.jboss.netty.handler.codec.http.websocketx |
Encoder, decoder, handshakers and their related message types for
Web Socket data frames.
|
| org.jboss.netty.handler.codec.spdy |
Encoder, decoder, session handler and their related message types for the SPDY protocol.
|
| org.jboss.netty.handler.ipfilter |
Implementation of a Ip based Filter handlers.
|
| org.jboss.netty.handler.ssl |
SSL ·
TLS implementation based on
SSLEngine |
| org.jboss.netty.handler.timeout |
Adds support for read and write timeout and idle connection notification
using a
Timer. |
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
ClientBootstrap.bind(java.net.SocketAddress localAddress)
Attempts to bind a channel with the specified
localAddress. |
ChannelFuture |
ServerBootstrap.bindAsync()
Bind a channel asynchronous to the local address
specified in the current
"localAddress" option. |
ChannelFuture |
ServerBootstrap.bindAsync(java.net.SocketAddress localAddress)
Bind a channel asynchronous to the specified local address.
|
ChannelFuture |
ClientBootstrap.connect()
Attempts a new connection with the current
"remoteAddress" and
"localAddress" option. |
ChannelFuture |
ConnectionlessBootstrap.connect()
Creates a new connected channel with the current
"remoteAddress"
and "localAddress" option. |
ChannelFuture |
ClientBootstrap.connect(java.net.SocketAddress remoteAddress)
Attempts a new connection with the specified
remoteAddress and
the current "localAddress" option. |
ChannelFuture |
ConnectionlessBootstrap.connect(java.net.SocketAddress remoteAddress)
Creates a new connected channel with the specified
"remoteAddress" and the current "localAddress" option. |
ChannelFuture |
ClientBootstrap.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
Attempts a new connection with the specified
remoteAddress and
the specified localAddress. |
ChannelFuture |
ConnectionlessBootstrap.connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
Creates a new connected channel with the specified
"remoteAddress" and the specified "localAddress". |
| Modifier and Type | Class and Description |
|---|---|
private class |
AbstractChannel.ChannelCloseFuture |
class |
CompleteChannelFuture
A skeletal
ChannelFuture implementation which represents a
ChannelFuture which has been completed already. |
class |
DefaultChannelFuture
The default
ChannelFuture implementation. |
class |
FailedChannelFuture
The
CompleteChannelFuture which is failed already. |
class |
SucceededChannelFuture
The
CompleteChannelFuture which is succeeded already. |
| Modifier and Type | Field and Description |
|---|---|
private ChannelFuture |
ChannelFutureNotifier.future |
private ChannelFuture |
DownstreamChannelStateEvent.future |
private ChannelFuture |
DownstreamMessageEvent.future |
private ChannelFuture |
AbstractChannel.succeededFuture |
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
ChannelFuture.await()
Waits for this future to be completed.
|
ChannelFuture |
CompleteChannelFuture.await() |
ChannelFuture |
DefaultChannelFuture.await() |
ChannelFuture |
ChannelFuture.awaitUninterruptibly()
Waits for this future to be completed without
interruption.
|
ChannelFuture |
CompleteChannelFuture.awaitUninterruptibly() |
ChannelFuture |
DefaultChannelFuture.awaitUninterruptibly() |
static ChannelFuture |
Channels.bind(Channel channel,
java.net.SocketAddress localAddress)
Sends a
"bind" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
ChannelFuture |
AbstractChannel.bind(java.net.SocketAddress localAddress) |
ChannelFuture |
Channel.bind(java.net.SocketAddress localAddress)
Binds this channel to the specified local address asynchronously.
|
ChannelFuture |
AbstractChannel.close() |
ChannelFuture |
Channel.close()
Closes this channel asynchronously.
|
static ChannelFuture |
Channels.close(Channel channel)
Sends a
"close" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.connect(Channel channel,
java.net.SocketAddress remoteAddress)
Sends a
"connect" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
ChannelFuture |
AbstractChannel.connect(java.net.SocketAddress remoteAddress) |
ChannelFuture |
AbstractServerChannel.connect(java.net.SocketAddress remoteAddress) |
ChannelFuture |
Channel.connect(java.net.SocketAddress remoteAddress)
Connects this channel to the specified remote address asynchronously.
|
ChannelFuture |
AbstractChannel.disconnect() |
ChannelFuture |
AbstractServerChannel.disconnect() |
ChannelFuture |
Channel.disconnect()
Disconnects this channel from the current remote address asynchronously.
|
static ChannelFuture |
Channels.disconnect(Channel channel)
Sends a
"disconnect" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
ChannelFuture |
AbstractChannelSink.execute(ChannelPipeline pipeline,
java.lang.Runnable task)
This implementation just directly call
Runnable.run(). |
ChannelFuture |
ChannelSink.execute(ChannelPipeline pipeline,
java.lang.Runnable task)
Execute the given
Runnable later in the io-thread. |
ChannelFuture |
DefaultChannelPipeline.DiscardingChannelSink.execute(ChannelPipeline pipeline,
java.lang.Runnable task) |
ChannelFuture |
ChannelPipeline.execute(java.lang.Runnable task)
Schedules the specified task to be executed in the I/O thread associated
with this pipeline's
Channel. |
ChannelFuture |
DefaultChannelPipeline.execute(java.lang.Runnable task) |
static ChannelFuture |
Channels.failedFuture(Channel channel,
java.lang.Throwable cause)
Creates a new
ChannelFuture which has failed already for the
specified Channel. |
static ChannelFuture |
Channels.fireChannelClosedLater(Channel channel)
Sends a
"channelClosed" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel once the io-thread runs again. |
static ChannelFuture |
Channels.fireChannelDisconnectedLater(Channel channel)
Sends a
"channelDisconnected" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel once the io-thread runs again. |
static ChannelFuture |
Channels.fireChannelInterestChangedLater(Channel channel)
Sends a
"channelInterestChanged" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel once the io-thread runs again. |
static ChannelFuture |
Channels.fireChannelUnboundLater(Channel channel)
Sends a
"channelUnbound" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel once the io-thread runs again. |
static ChannelFuture |
Channels.fireExceptionCaughtLater(ChannelHandlerContext ctx,
java.lang.Throwable cause)
Sends a
"exceptionCaught" event to the
ChannelUpstreamHandler which is placed in the closest upstream
from the handler associated with the specified
ChannelHandlerContext once the io-thread runs again. |
static ChannelFuture |
Channels.fireExceptionCaughtLater(Channel channel,
java.lang.Throwable cause)
Sends a
"exceptionCaught" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel once the io-thread runs again. |
static ChannelFuture |
Channels.fireWriteCompleteLater(Channel channel,
long amount)
Sends a
"writeComplete" event to the first
ChannelUpstreamHandler in the ChannelPipeline of
the specified Channel in the next io-thread. |
static ChannelFuture |
Channels.future(Channel channel)
Creates a new non-cancellable
ChannelFuture for the specified
Channel. |
static ChannelFuture |
Channels.future(Channel channel,
boolean cancellable)
Creates a new
ChannelFuture for the specified Channel. |
ChannelFuture |
AbstractChannel.getCloseFuture() |
ChannelFuture |
Channel.getCloseFuture()
Returns the
ChannelFuture which will be notified when this
channel is closed. |
ChannelFuture |
ChannelEvent.getFuture()
Returns the
ChannelFuture which is associated with this event. |
ChannelFuture |
DefaultChildChannelStateEvent.getFuture() |
ChannelFuture |
DefaultExceptionEvent.getFuture() |
ChannelFuture |
DefaultWriteCompletionEvent.getFuture() |
ChannelFuture |
DownstreamChannelStateEvent.getFuture() |
ChannelFuture |
DownstreamMessageEvent.getFuture() |
ChannelFuture |
UpstreamChannelStateEvent.getFuture() |
ChannelFuture |
UpstreamMessageEvent.getFuture() |
protected ChannelFuture |
AbstractChannel.getSucceededFuture()
Returns the cached
SucceededChannelFuture instance. |
protected ChannelFuture |
AbstractChannel.getUnsupportedOperationFuture()
Returns the
FailedChannelFuture whose cause is an
UnsupportedOperationException. |
static ChannelFuture |
Channels.setInterestOps(Channel channel,
int interestOps)
Sends a
"setInterestOps" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
ChannelFuture |
AbstractChannel.setInterestOps(int interestOps) |
ChannelFuture |
AbstractServerChannel.setInterestOps(int interestOps) |
ChannelFuture |
Channel.setInterestOps(int interestOps)
Changes the
interestOps of this channel asynchronously. |
ChannelFuture |
AbstractChannel.setReadable(boolean readable) |
ChannelFuture |
Channel.setReadable(boolean readable)
Suspends or resumes the read operation of the I/O thread asynchronously.
|
static ChannelFuture |
Channels.succeededFuture(Channel channel)
Creates a new
ChannelFuture which is already succeeded for the
specified Channel. |
ChannelFuture |
ChannelFuture.sync()
Waits for this future until it is done, and rethrows the cause of the failure if this future
failed.
|
ChannelFuture |
DefaultChannelFuture.sync() |
ChannelFuture |
FailedChannelFuture.sync() |
ChannelFuture |
SucceededChannelFuture.sync() |
ChannelFuture |
ChannelFuture.syncUninterruptibly()
Waits for this future until it is done, and rethrows the cause of the failure if this future
failed.
|
ChannelFuture |
DefaultChannelFuture.syncUninterruptibly() |
ChannelFuture |
FailedChannelFuture.syncUninterruptibly() |
ChannelFuture |
SucceededChannelFuture.syncUninterruptibly() |
ChannelFuture |
AbstractChannel.unbind() |
ChannelFuture |
Channel.unbind()
Unbinds this channel from the current local address asynchronously.
|
static ChannelFuture |
Channels.unbind(Channel channel)
Sends a
"unbind" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.write(Channel channel,
java.lang.Object message)
Sends a
"write" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
static ChannelFuture |
Channels.write(Channel channel,
java.lang.Object message,
java.net.SocketAddress remoteAddress)
Sends a
"write" request to the last
ChannelDownstreamHandler in the ChannelPipeline of
the specified Channel. |
ChannelFuture |
AbstractChannel.write(java.lang.Object message) |
ChannelFuture |
AbstractServerChannel.write(java.lang.Object message) |
ChannelFuture |
Channel.write(java.lang.Object message)
Sends a message to this channel asynchronously.
|
ChannelFuture |
AbstractChannel.write(java.lang.Object message,
java.net.SocketAddress remoteAddress) |
ChannelFuture |
AbstractServerChannel.write(java.lang.Object message,
java.net.SocketAddress remoteAddress) |
ChannelFuture |
Channel.write(java.lang.Object message,
java.net.SocketAddress remoteAddress)
Sends a message to this channel asynchronously.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
Channels.bind(ChannelHandlerContext ctx,
ChannelFuture future,
java.net.SocketAddress localAddress)
Sends a
"bind" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext. |
static void |
Channels.close(ChannelHandlerContext ctx,
ChannelFuture future)
Sends a
"close" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext. |
static void |
Channels.connect(ChannelHandlerContext ctx,
ChannelFuture future,
java.net.SocketAddress remoteAddress)
Sends a
"connect" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext. |
static void |
Channels.disconnect(ChannelHandlerContext ctx,
ChannelFuture future)
Sends a
"disconnect" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext. |
void |
ChannelFutureListener.operationComplete(ChannelFuture future)
Invoked when the I/O operation associated with the
ChannelFuture
has been completed. |
void |
ChannelFutureNotifier.operationComplete(ChannelFuture cf) |
void |
ChannelFutureProgressListener.operationProgressed(ChannelFuture future,
long amount,
long current,
long total)
Invoked when the I/O operation associated with the
ChannelFuture
has been progressed. |
static void |
Channels.setInterestOps(ChannelHandlerContext ctx,
ChannelFuture future,
int interestOps)
Sends a
"setInterestOps" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext. |
static void |
Channels.unbind(ChannelHandlerContext ctx,
ChannelFuture future)
Sends a
"unbind" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext. |
static void |
Channels.write(ChannelHandlerContext ctx,
ChannelFuture future,
java.lang.Object message)
Sends a
"write" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext. |
static void |
Channels.write(ChannelHandlerContext ctx,
ChannelFuture future,
java.lang.Object message,
java.net.SocketAddress remoteAddress)
Sends a
"write" request to the
ChannelDownstreamHandler which is placed in the closest
downstream from the handler associated with the specified
ChannelHandlerContext. |
| Constructor and Description |
|---|
ChannelFutureNotifier(ChannelFuture future) |
DownstreamChannelStateEvent(Channel channel,
ChannelFuture future,
ChannelState state,
java.lang.Object value)
Creates a new instance.
|
DownstreamMessageEvent(Channel channel,
ChannelFuture future,
java.lang.Object message,
java.net.SocketAddress remoteAddress)
Creates a new instance.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) java.util.Map<java.lang.Integer,ChannelFuture> |
DefaultChannelGroupFuture.futures |
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
ChannelGroupFuture.find(Channel channel)
Returns the
ChannelFuture of the individual I/O operation which
is associated with the specified Channel. |
ChannelFuture |
DefaultChannelGroupFuture.find(Channel channel) |
ChannelFuture |
ChannelGroupFuture.find(java.lang.Integer channelId)
Returns the
ChannelFuture of the individual I/O operation which
is associated with the Channel whose ID matches the specified
integer. |
ChannelFuture |
DefaultChannelGroupFuture.find(java.lang.Integer channelId) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Iterator<ChannelFuture> |
ChannelGroupFuture.iterator()
Returns the
Iterator that enumerates all ChannelFutures
which are associated with this future. |
java.util.Iterator<ChannelFuture> |
DefaultChannelGroupFuture.iterator() |
| Constructor and Description |
|---|
DefaultChannelGroupFuture(ChannelGroup group,
java.util.Collection<ChannelFuture> futures)
Creates a new instance.
|
DefaultChannelGroupFuture(ChannelGroup group,
java.util.Map<java.lang.Integer,ChannelFuture> futures) |
| Modifier and Type | Method and Description |
|---|---|
private static void |
LocalClientChannelSink.bind(DefaultLocalChannel channel,
ChannelFuture future,
LocalAddress localAddress) |
private static void |
LocalServerChannelSink.bind(DefaultLocalServerChannel channel,
ChannelFuture future,
LocalAddress localAddress) |
private static void |
LocalServerChannelSink.close(DefaultLocalServerChannel channel,
ChannelFuture future) |
(package private) void |
DefaultLocalChannel.closeNow(ChannelFuture future) |
private void |
LocalClientChannelSink.connect(DefaultLocalChannel channel,
ChannelFuture future,
LocalAddress remoteAddress) |
| Modifier and Type | Class and Description |
|---|---|
class |
ChannelRunnableWrapper |
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetAddress multicastAddress)
Joins a multicast group.
|
ChannelFuture |
DatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface)
Joins the specified multicast group at the specified interface.
|
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetAddress multicastAddress)
Leaves a multicast group.
|
ChannelFuture |
DatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface)
Leaves a multicast group on a specified local interface.
|
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
HttpTunnelingClientSocketChannel.write(java.lang.Object message,
java.net.SocketAddress remoteAddress) |
private ChannelFuture |
HttpTunnelingClientSocketChannel.writeLastChunk() |
| Modifier and Type | Method and Description |
|---|---|
(package private) void |
HttpTunnelingClientSocketChannel.bindReal(java.net.SocketAddress localAddress,
ChannelFuture future) |
(package private) void |
HttpTunnelingClientSocketChannel.closeReal(ChannelFuture future) |
(package private) void |
HttpTunnelingClientSocketChannel.connectReal(java.net.SocketAddress remoteAddress,
ChannelFuture future) |
(package private) void |
HttpTunnelingClientSocketChannel.disconnectReal(ChannelFuture future) |
(package private) void |
HttpTunnelingClientSocketChannel.setInterestOpsReal(int interestOps,
ChannelFuture future) |
(package private) void |
HttpTunnelingClientSocketChannel.unbindReal(ChannelFuture future) |
(package private) void |
HttpTunnelingClientSocketChannel.writeReal(ChannelBuffer a,
ChannelFuture future) |
| Modifier and Type | Field and Description |
|---|---|
(package private) ChannelFuture |
NioClientSocketChannel.connectFuture |
private ChannelFuture |
NioDatagramWorker.ChannelRegistionTask.future |
private ChannelFuture |
NioServerBoss.RegisterTask.future |
private ChannelFuture |
NioWorker.RegisterTask.future |
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
NioDatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.InetAddress sourceToBlock)
Block the given sourceToBlock address for the given multicastAddress
|
ChannelFuture |
NioDatagramChannel.block(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress sourceToBlock)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterface
|
ChannelFuture |
AbstractNioChannelSink.execute(ChannelPipeline pipeline,
java.lang.Runnable task) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source)
Joins the specified multicast group at the specified interface using the specified source.
|
ChannelFuture |
NioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source)
Leave the specified multicast group at the specified interface using the specified source.
|
ChannelFuture |
NioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface) |
ChannelFuture |
NioDatagramChannel.write(java.lang.Object message,
java.net.SocketAddress remoteAddress) |
ChannelFuture |
NioSocketChannel.write(java.lang.Object message,
java.net.SocketAddress remoteAddress) |
| Modifier and Type | Method and Description |
|---|---|
private static void |
NioClientSocketPipelineSink.bind(NioClientSocketChannel channel,
ChannelFuture future,
java.net.SocketAddress localAddress) |
private static void |
NioDatagramPipelineSink.bind(NioDatagramChannel channel,
ChannelFuture future,
java.net.InetSocketAddress address)
Will bind the DatagramSocket to the passed-in address.
|
(package private) void |
NioServerBoss.bind(NioServerSocketChannel channel,
ChannelFuture future,
java.net.SocketAddress localAddress) |
protected void |
AbstractNioWorker.close(AbstractNioChannel<?> channel,
ChannelFuture future) |
private static void |
NioDatagramPipelineSink.close(NioDatagramChannel channel,
ChannelFuture future) |
(package private) void |
NioServerBoss.close(NioServerSocketChannel channel,
ChannelFuture future) |
private void |
NioClientSocketPipelineSink.connect(NioClientSocketChannel channel,
ChannelFuture cf,
java.net.SocketAddress remoteAddress) |
private static void |
NioDatagramPipelineSink.connect(NioDatagramChannel channel,
ChannelFuture future,
java.net.InetSocketAddress remoteAddress) |
protected abstract java.lang.Runnable |
AbstractNioSelector.createRegisterTask(Channel channel,
ChannelFuture future) |
protected java.lang.Runnable |
NioClientBoss.createRegisterTask(Channel channel,
ChannelFuture future) |
protected java.lang.Runnable |
NioDatagramWorker.createRegisterTask(Channel channel,
ChannelFuture future) |
protected java.lang.Runnable |
NioServerBoss.createRegisterTask(Channel channel,
ChannelFuture future) |
protected java.lang.Runnable |
NioWorker.createRegisterTask(Channel channel,
ChannelFuture future) |
(package private) static void |
NioDatagramWorker.disconnect(NioDatagramChannel channel,
ChannelFuture future) |
void |
AbstractNioSelector.register(Channel channel,
ChannelFuture future) |
void |
NioSelector.register(Channel channel,
ChannelFuture future) |
(package private) void |
AbstractNioWorker.setInterestOps(AbstractNioChannel<?> channel,
ChannelFuture future,
int interestOps) |
| Constructor and Description |
|---|
ChannelRegistionTask(NioDatagramChannel channel,
ChannelFuture future) |
RegisterTask(NioServerSocketChannel channel,
ChannelFuture future,
java.net.SocketAddress localAddress) |
RegisterTask(NioSocketChannel channel,
ChannelFuture future,
boolean server) |
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
AbstractOioChannelSink.execute(ChannelPipeline pipeline,
java.lang.Runnable task) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
OioDatagramChannel.joinGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetAddress multicastAddress) |
ChannelFuture |
OioDatagramChannel.leaveGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface) |
ChannelFuture |
AbstractOioChannel.write(java.lang.Object message,
java.net.SocketAddress remoteAddress) |
| Modifier and Type | Method and Description |
|---|---|
private static void |
OioClientSocketPipelineSink.bind(OioClientSocketChannel channel,
ChannelFuture future,
java.net.SocketAddress localAddress) |
private void |
OioDatagramPipelineSink.bind(OioDatagramChannel channel,
ChannelFuture future,
java.net.SocketAddress localAddress) |
private void |
OioServerSocketPipelineSink.bind(OioServerSocketChannel channel,
ChannelFuture future,
java.net.SocketAddress localAddress) |
(package private) static void |
AbstractOioWorker.close(AbstractOioChannel channel,
ChannelFuture future) |
private static void |
AbstractOioWorker.close(AbstractOioChannel channel,
ChannelFuture future,
boolean iothread) |
private static void |
OioServerSocketPipelineSink.close(OioServerSocketChannel channel,
ChannelFuture future) |
private void |
OioClientSocketPipelineSink.connect(OioClientSocketChannel channel,
ChannelFuture future,
java.net.SocketAddress remoteAddress) |
private void |
OioDatagramPipelineSink.connect(OioDatagramChannel channel,
ChannelFuture future,
java.net.SocketAddress remoteAddress) |
(package private) static void |
OioDatagramWorker.disconnect(OioDatagramChannel channel,
ChannelFuture future) |
(package private) static void |
AbstractOioWorker.setInterestOps(AbstractOioChannel channel,
ChannelFuture future,
int interestOps) |
(package private) static void |
OioDatagramWorker.write(OioDatagramChannel channel,
ChannelFuture future,
java.lang.Object message,
java.net.SocketAddress remoteAddress) |
(package private) static void |
OioWorker.write(OioSocketChannel channel,
ChannelFuture future,
java.lang.Object message) |
| Modifier and Type | Method and Description |
|---|---|
void |
SecureChatServerHandler.Greeter.operationComplete(ChannelFuture future) |
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
JdkZlibEncoder.close() |
ChannelFuture |
ZlibEncoder.close() |
private ChannelFuture |
JdkZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelEvent evt) |
private ChannelFuture |
ZlibEncoder.finishEncode(ChannelHandlerContext ctx,
ChannelEvent evt) |
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
AbstractCodecEmbedder.EmbeddedChannelSink.execute(ChannelPipeline pipeline,
java.lang.Runnable task) |
| Modifier and Type | Method and Description |
|---|---|
abstract ChannelFuture |
WebSocketServerHandshaker.close(Channel channel,
CloseWebSocketFrame frame)
Performs the closing handshake
|
ChannelFuture |
WebSocketServerHandshaker00.close(Channel channel,
CloseWebSocketFrame frame)
Echo back the closing frame
|
ChannelFuture |
WebSocketServerHandshaker07.close(Channel channel,
CloseWebSocketFrame frame)
Echo back the closing frame and close the connection
|
ChannelFuture |
WebSocketServerHandshaker08.close(Channel channel,
CloseWebSocketFrame frame)
Echo back the closing frame and close the connection
|
ChannelFuture |
WebSocketServerHandshaker13.close(Channel channel,
CloseWebSocketFrame frame)
Echo back the closing frame and close the connection
|
abstract ChannelFuture |
WebSocketClientHandshaker.handshake(Channel channel)
Begins the opening handshake
|
ChannelFuture |
WebSocketClientHandshaker00.handshake(Channel channel)
Sends the opening request to the server:
|
ChannelFuture |
WebSocketClientHandshaker07.handshake(Channel channel)
/**
|
ChannelFuture |
WebSocketClientHandshaker08.handshake(Channel channel)
/**
|
ChannelFuture |
WebSocketClientHandshaker13.handshake(Channel channel)
/**
|
abstract ChannelFuture |
WebSocketServerHandshaker.handshake(Channel channel,
HttpRequest req)
Performs the opening handshake
|
ChannelFuture |
WebSocketServerHandshaker00.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi version 0 and lower.
|
ChannelFuture |
WebSocketServerHandshaker07.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi version 7.
|
ChannelFuture |
WebSocketServerHandshaker08.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi version 8 to 10.
|
ChannelFuture |
WebSocketServerHandshaker13.handshake(Channel channel,
HttpRequest req)
Handle the web socket handshake for the web socket specification HyBi
versions 13-17.
|
ChannelFuture |
WebSocketServerHandshakerFactory.sendUnsupportedWebSocketVersionResponse(Channel channel)
Return that we need cannot not support the web socket version
|
protected ChannelFuture |
WebSocketServerHandshaker.writeHandshakeResponse(Channel channel,
HttpResponse res,
ChannelHandler encoder,
ChannelHandler decoder)
Upgrades the connection and send the handshake response.
|
| Modifier and Type | Method and Description |
|---|---|
private static ChannelFuture |
SpdyHttpEncoder.getDataFuture(ChannelHandlerContext ctx,
ChannelFuture future,
SpdyDataFrame[] spdyDataFrames,
java.net.SocketAddress remoteAddress) |
private ChannelFuture |
SpdyHttpEncoder.getMessageFuture(ChannelHandlerContext ctx,
MessageEvent e,
int streamId,
HttpMessage httpMessage) |
private ChannelFuture |
SpdySessionHandler.sendGoAwayFrame(ChannelHandlerContext ctx,
Channel channel,
java.net.SocketAddress remoteAddress,
SpdySessionStatus status) |
| Modifier and Type | Method and Description |
|---|---|
private static ChannelFuture |
SpdyHttpEncoder.getDataFuture(ChannelHandlerContext ctx,
ChannelFuture future,
SpdyDataFrame[] spdyDataFrames,
java.net.SocketAddress remoteAddress) |
private void |
SpdySessionHandler.halfCloseStream(int streamId,
boolean remote,
ChannelFuture future) |
void |
SpdyHttpEncoder.SpdyFrameWriter.operationComplete(ChannelFuture future) |
void |
SpdySessionHandler.ClosingChannelFutureListener.operationComplete(ChannelFuture sentGoAwayFuture) |
private void |
SpdySessionHandler.removeStream(int streamId,
ChannelFuture future) |
protected void |
SpdyHttpEncoder.writeChunk(ChannelHandlerContext ctx,
ChannelFuture future,
int streamId,
HttpChunk chunk,
java.net.SocketAddress remoteAddress)
Writes an HTTP chunk downstream as one or more SPDY frames.
|
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
IpFilterListener.allowed(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress)
Called when the channel has the CONNECTED status and the channel was allowed by a previous call to accept().
|
protected ChannelFuture |
IpFilteringHandlerImpl.handleAllowedChannel(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress) |
protected ChannelFuture |
IpFilteringHandlerImpl.handleRefusedChannel(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress)
Called when the channel has the CONNECTED status and the channel was refused by a previous call to accept().
|
ChannelFuture |
IpFilterListener.refused(ChannelHandlerContext ctx,
ChannelEvent e,
java.net.InetSocketAddress inetSocketAddress)
Called when the channel has the CONNECTED status and the channel was refused by a previous call to accept().
|
| Modifier and Type | Class and Description |
|---|---|
private class |
SslHandler.SSLEngineInboundCloseFuture |
| Modifier and Type | Field and Description |
|---|---|
(package private) ChannelFuture |
SslHandler.PendingWrite.future |
private ChannelFuture |
SslHandler.handshakeFuture |
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
SslHandler.close()
Sends an SSL
close_notify message to the specified channel and
destroys the underlying SSLEngine. |
ChannelFuture |
SslHandler.getSSLEngineInboundCloseFuture()
Return the
ChannelFuture that will get notified if the inbound of the SSLEngine will get closed. |
ChannelFuture |
SslHandler.handshake()
Starts an SSL / TLS handshake for the specified channel.
|
private ChannelFuture |
SslHandler.wrapNonAppData(ChannelHandlerContext ctx,
Channel channel) |
| Modifier and Type | Method and Description |
|---|---|
void |
SslHandler.ClosingChannelFutureListener.operationComplete(ChannelFuture closeNotifyFuture) |
| Constructor and Description |
|---|
PendingWrite(ChannelFuture future,
java.nio.ByteBuffer outAppBuf) |
| Modifier and Type | Field and Description |
|---|---|
private ChannelFuture |
WriteTimeoutHandler.WriteTimeoutTask.future |
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
DefaultIdleStateEvent.getFuture() |
| Modifier and Type | Method and Description |
|---|---|
void |
WriteTimeoutHandler.TimeoutCanceller.operationComplete(ChannelFuture future) |
| Constructor and Description |
|---|
WriteTimeoutTask(ChannelHandlerContext ctx,
ChannelFuture future) |