diff --git a/testsuite/src/test/java/io/netty/testsuite/transport/socket/SocketTestPermutation.java b/testsuite/src/test/java/io/netty/testsuite/transport/socket/SocketTestPermutation.java index 34ab5d1505..1891372eb9 100644 --- a/testsuite/src/test/java/io/netty/testsuite/transport/socket/SocketTestPermutation.java +++ b/testsuite/src/test/java/io/netty/testsuite/transport/socket/SocketTestPermutation.java @@ -54,10 +54,11 @@ final class SocketTestPermutation { sbfs.add(new Factory() { @Override public ServerBootstrap newInstance() { - AioEventLoopGroup loop = new AioEventLoopGroup(); + AioEventLoopGroup parentGroup = new AioEventLoopGroup(); + AioEventLoopGroup childGroup = new AioEventLoopGroup(); return new ServerBootstrap(). - group(loop). - channel(new AioServerSocketChannel(loop)); + group(parentGroup, childGroup). + channel(new AioServerSocketChannel(parentGroup, childGroup)); } }); sbfs.add(new Factory() { diff --git a/transport/src/main/java/io/netty/channel/socket/aio/AioServerSocketChannel.java b/transport/src/main/java/io/netty/channel/socket/aio/AioServerSocketChannel.java index 4a83008d7b..147dff177a 100755 --- a/transport/src/main/java/io/netty/channel/socket/aio/AioServerSocketChannel.java +++ b/transport/src/main/java/io/netty/channel/socket/aio/AioServerSocketChannel.java @@ -43,7 +43,7 @@ public class AioServerSocketChannel extends AbstractAioChannel implements Server private final AioEventLoopGroup childGroup; private final AioServerSocketChannelConfig config; private boolean closed; - private AtomicBoolean readSuspended = new AtomicBoolean(); + private final AtomicBoolean readSuspended = new AtomicBoolean(); private final Runnable acceptTask = new Runnable() { @@ -68,7 +68,7 @@ public class AioServerSocketChannel extends AbstractAioChannel implements Server public AioServerSocketChannel(AioEventLoopGroup parentGroup, AioEventLoopGroup childGroup) { super(null, null, parentGroup, newSocket(parentGroup.group)); this.childGroup = childGroup; - this.config = new AioServerSocketChannelConfig(javaChannel()); + config = new AioServerSocketChannelConfig(javaChannel()); } @Override