andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Make use of AUTO_READ to not accept traffic before connection is complete

Browse Source
This commit is contained in:
Norman Maurer 2013-02-17 08:26:06 +01:00
parent 60ee9460a9
commit 2f737d4e70
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
example/src/main/java/io/netty/example/proxy/HexDumpProxy.java
View File

@ -16,6 +16,7 @@
package io.netty.example.proxy; package io.netty.example.proxy;
import io.netty.bootstrap.ServerBootstrap; import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelOption;
import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel; import io.netty.channel.socket.nio.NioServerSocketChannel;
@ -41,8 +42,8 @@ public class HexDumpProxy {
try { try {
b.group(new NioEventLoopGroup(), new NioEventLoopGroup()) b.group(new NioEventLoopGroup(), new NioEventLoopGroup())
.channel(NioServerSocketChannel.class) .channel(NioServerSocketChannel.class)
.childHandler(new HexDumpProxyInitializer(remoteHost, remotePort)); .childHandler(new HexDumpProxyInitializer(remoteHost, remotePort))
.childOption(ChannelOption.AUTO_READ, false);
b.bind(localPort).sync().channel().closeFuture().sync(); b.bind(localPort).sync().channel().closeFuture().sync();
} finally { } finally {
b.shutdown(); b.shutdown();

4
example/src/main/java/io/netty/example/proxy/HexDumpProxyFrontendHandler.java
View File

@ -54,8 +54,8 @@ public class HexDumpProxyFrontendHandler extends ChannelInboundByteHandlerAdapte
@Override @Override
public void operationComplete(ChannelFuture future) throws Exception { public void operationComplete(ChannelFuture future) throws Exception {
if (future.isSuccess()) { if (future.isSuccess()) {
// Connection attempt succeeded: // connection complete start to auto read data
// TODO: Begin to accept incoming traffic. inboundChannel.config().setAutoRead(true);
} else { } else {
// Close the connection if the connection attempt has failed. // Close the connection if the connection attempt has failed.
inboundChannel.close(); inboundChannel.close();