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

ServerBootstrap needs to have a localAddress defined

Browse Source
This commit is contained in:
Norman Maurer 2012-12-23 16:05:43 +01:00
parent 6ef1729d06
commit e0d42df77b
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
transport/src/main/java/io/netty/bootstrap/ServerBootstrap.java
View File

@ -33,9 +33,7 @@ import io.netty.channel.socket.SocketChannel;
import io.netty.logging.InternalLogger; import io.netty.logging.InternalLogger;
import io.netty.logging.InternalLoggerFactory; import io.netty.logging.InternalLoggerFactory;
import io.netty.util.AttributeKey; import io.netty.util.AttributeKey;
import io.netty.util.NetworkConstants;
import java.net.InetSocketAddress;
import java.nio.channels.ClosedChannelException; import java.nio.channels.ClosedChannelException;
import java.util.LinkedHashMap; import java.util.LinkedHashMap;
import java.util.Map; import java.util.Map;
@ -48,7 +46,6 @@ import java.util.Map.Entry;
public class ServerBootstrap extends AbstractBootstrap<ServerBootstrap> { public class ServerBootstrap extends AbstractBootstrap<ServerBootstrap> {
private static final InternalLogger logger = InternalLoggerFactory.getInstance(ServerBootstrap.class); private static final InternalLogger logger = InternalLoggerFactory.getInstance(ServerBootstrap.class);
private static final InetSocketAddress DEFAULT_LOCAL_ADDR = new InetSocketAddress(NetworkConstants.LOCALHOST, 0);
private final ChannelHandler acceptor = new ChannelInitializer<Channel>() { private final ChannelHandler acceptor = new ChannelInitializer<Channel>() {
@Override @Override
@ -211,14 +208,14 @@ public class ServerBootstrap extends AbstractBootstrap<ServerBootstrap> {
if (childHandler == null) { if (childHandler == null) {
throw new IllegalStateException("childHandler not set"); throw new IllegalStateException("childHandler not set");
} }
if (localAddress() == null) {
throw new IllegalStateException("localAddress not set");
}
if (childGroup == null) { if (childGroup == null) {
logger.warn("childGroup is not set. Using parentGroup instead."); logger.warn("childGroup is not set. Using parentGroup instead.");
childGroup = group(); childGroup = group();
} }
if (localAddress() == null) {
logger.warn("localAddress is not set. Using " + DEFAULT_LOCAL_ADDR + " instead.");
localAddress(DEFAULT_LOCAL_ADDR);
}
} }
private class Acceptor private class Acceptor