Revert "Check that eventloop's were setup correctly. See #396"
This reverts commit 82834c2f348d35f8d9a224c3b9a51e3aa085839d.
This commit is contained in:
parent
82834c2f34
commit
c3770a0fba
@ -17,7 +17,6 @@ package io.netty.channel.socket.aio;
|
||||
|
||||
import io.netty.buffer.ByteBuf;
|
||||
import io.netty.buffer.ChannelBufType;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelFuture;
|
||||
import io.netty.channel.ChannelPipeline;
|
||||
import io.netty.channel.socket.SocketChannel;
|
||||
@ -106,14 +105,6 @@ public class AioSocketChannel extends AbstractAioChannel implements SocketChanne
|
||||
|
||||
@Override
|
||||
protected Runnable doRegister() throws Exception {
|
||||
Channel parent = parent();
|
||||
if (parent != null) {
|
||||
// check that the eventloop instance is shared for the parent and the child
|
||||
// if not throw an IllegalStateException
|
||||
if (parent.eventLoop() != eventLoop()) {
|
||||
throw new IllegalStateException("eventLoop and childEventLoop must be the same!");
|
||||
}
|
||||
}
|
||||
if (ch == null) {
|
||||
ch = AsynchronousSocketChannel.open(AsynchronousChannelGroup.withThreadPool(eventLoop()));
|
||||
config = new AioSocketChannelConfig(javaChannel());
|
||||
|
Loading…
x
Reference in New Issue
Block a user