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

Fix checkstyle

Browse Source
This commit is contained in:
norman 2012-08-07 15:38:52 +02:00
parent 3ed3827760
commit 0334333c82
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
transport/src/main/java/io/netty/channel/socket/nio/NioServerSocketChannel.java
View File

@ -46,7 +46,7 @@ public class NioServerSocketChannel extends AbstractNioMessageChannel
private final ServerSocketChannelConfig config; private final ServerSocketChannelConfig config;
public NioServerSocketChannel() { public NioServerSocketChannel() {
super(null, null, newSocket(), SelectionKey.OP_ACCEPT); super(null, null, newSocket(), 0);
config = new DefaultServerSocketChannelConfig(javaChannel().socket()); config = new DefaultServerSocketChannelConfig(javaChannel().socket());
} }
@ -137,12 +137,17 @@ public class NioServerSocketChannel extends AbstractNioMessageChannel
private final class NioServerSocketUnsafe extends AbstractNioMessageUnsafe { private final class NioServerSocketUnsafe extends AbstractNioMessageUnsafe {
@Override @Override
public void suspendRead() { public void suspendRead() {
selectionKey().interestOps(selectionKey().interestOps() & ~ SelectionKey.OP_ACCEPT); selectionKey().cancel();
} }
@Override @Override
public void resumeRead() { public void resumeRead() {
selectionKey().interestOps(selectionKey().interestOps() | SelectionKey.OP_ACCEPT); try {
doRegister();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} }
} }
} }