Next round for async channel api support a.k.a nio2. See See #396
This commit is contained in:
parent
032912d938
commit
f8ef5d5d78
0
transport/src/main/java/io/netty/bootstrap/Bootstrap.java
Normal file → Executable file
0
transport/src/main/java/io/netty/bootstrap/Bootstrap.java
Normal file → Executable file
13
transport/src/main/java/io/netty/bootstrap/ServerBootstrap.java
Normal file → Executable file
13
transport/src/main/java/io/netty/bootstrap/ServerBootstrap.java
Normal file → Executable file
@ -167,13 +167,6 @@ public class ServerBootstrap {
|
||||
return future;
|
||||
}
|
||||
|
||||
try {
|
||||
channel.config().setOptions(parentOptions);
|
||||
} catch (Exception e) {
|
||||
future.setFailure(e);
|
||||
return future;
|
||||
}
|
||||
|
||||
ChannelPipeline p = channel.pipeline();
|
||||
if (handler != null) {
|
||||
p.addLast(handler);
|
||||
@ -185,6 +178,12 @@ public class ServerBootstrap {
|
||||
future.setFailure(f.cause());
|
||||
return future;
|
||||
}
|
||||
try {
|
||||
channel.config().setOptions(parentOptions);
|
||||
} catch (Exception e) {
|
||||
future.setFailure(e);
|
||||
return future;
|
||||
}
|
||||
|
||||
if (!channel.isOpen()) {
|
||||
// Registration was successful but the channel was closed due to some failure in
|
||||
|
0
transport/src/main/java/io/netty/bootstrap/package-info.java
Normal file → Executable file
0
transport/src/main/java/io/netty/bootstrap/package-info.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/AbstractChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/AbstractChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/AbstractServerChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/AbstractServerChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/BlockingOperationException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/BlockingOperationException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/Channel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/Channel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelFutureAggregator.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelFutureAggregator.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelFutureFactory.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelFutureFactory.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelFutureListener.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelFutureListener.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelFutureProgressListener.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelFutureProgressListener.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelHandlerContext.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelHandlerContext.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelHandlerLifeCycleException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelHandlerLifeCycleException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelHandlerType.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelHandlerType.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundByteHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundByteHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundByteHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundByteHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundInvoker.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundInvoker.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundMessageHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundMessageHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundMessageHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInboundMessageHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInitializer.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelInitializer.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOperationHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOperationHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOperationHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOperationHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOption.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOption.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundByteHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundByteHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundByteHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundByteHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundInvoker.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundInvoker.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundMessageHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundMessageHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundMessageHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelOutboundMessageHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelPipeline.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelPipeline.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelPipelineException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelPipelineException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelStateHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelStateHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelStateHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ChannelStateHandlerAdapter.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/CombinedChannelHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/CombinedChannelHandler.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/CompleteChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/CompleteChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChannelPipelineModificationTask.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChannelPipelineModificationTask.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChildEventExecutor.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultChildEventExecutor.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultEventExecutor.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/DefaultEventExecutor.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/EventExecutor.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/EventExecutor.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/EventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/EventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/EventLoopException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/EventLoopException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/FailedChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/FailedChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/MultithreadEventExecutor.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/MultithreadEventExecutor.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/MultithreadEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/MultithreadEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/NoSuchBufferException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/NoSuchBufferException.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ServerChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/ServerChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/SingleThreadEventExecutor.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/SingleThreadEventExecutor.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/SingleThreadEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/SingleThreadEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/SucceededChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/SucceededChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/VoidChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/VoidChannelFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/AbstractEmbeddedChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/AbstractEmbeddedChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/EmbeddedByteChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/EmbeddedByteChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/EmbeddedEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/EmbeddedEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/EmbeddedMessageChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/EmbeddedMessageChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/EmbeddedSocketAddress.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/EmbeddedSocketAddress.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/package-info.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/embedded/package-info.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/ChannelGroup.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/ChannelGroup.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/ChannelGroupFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/ChannelGroupFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/ChannelGroupFutureListener.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/ChannelGroupFutureListener.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/CombinedIterator.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/CombinedIterator.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/DefaultChannelGroup.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/DefaultChannelGroup.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/DefaultChannelGroupFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/DefaultChannelGroupFuture.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/package-info.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/group/package-info.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalAddress.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalAddress.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalChannelRegistry.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalChannelRegistry.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalChildEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalChildEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalServerChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/LocalServerChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/package-info.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/local/package-info.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/package-info.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/package-info.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DatagramChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DatagramChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DatagramChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DatagramChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DatagramPacket.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DatagramPacket.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DefaultDatagramChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DefaultDatagramChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DefaultServerSocketChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DefaultServerSocketChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DefaultSocketChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/DefaultSocketChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/InternetProtocolFamily.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/InternetProtocolFamily.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/ServerSocketChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/ServerSocketChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/ServerSocketChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/ServerSocketChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/SocketChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/SocketChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/SocketChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/SocketChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/AbstractNioByteChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/AbstractNioByteChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/AbstractNioChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/AbstractNioChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/AbstractNioMessageChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/AbstractNioMessageChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/NioChildEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/NioChildEventLoop.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannel.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannelConfig.java
Normal file → Executable file
0
transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannelConfig.java
Normal file → Executable file
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue
Block a user