Forgot to revert the experimental change
This commit is contained in:
parent
050c2c793f
commit
d7d0877ede
@ -160,7 +160,6 @@ class NioServerSocketPipelineSink extends AbstractChannelSink {
|
|||||||
|
|
||||||
Executor bossExecutor =
|
Executor bossExecutor =
|
||||||
((NioServerSocketChannelFactory) channel.getFactory()).bossExecutor;
|
((NioServerSocketChannelFactory) channel.getFactory()).bossExecutor;
|
||||||
for (int i = 0; i < 2; i ++) {
|
|
||||||
bossExecutor.execute(
|
bossExecutor.execute(
|
||||||
new IoWorkerRunnable(
|
new IoWorkerRunnable(
|
||||||
new ThreadRenamingRunnable(
|
new ThreadRenamingRunnable(
|
||||||
@ -168,7 +167,6 @@ class NioServerSocketPipelineSink extends AbstractChannelSink {
|
|||||||
"New I/O server boss #" + id +
|
"New I/O server boss #" + id +
|
||||||
" (channelId: " + channel.getId() +
|
" (channelId: " + channel.getId() +
|
||||||
", " + channel.getLocalAddress() + ')')));
|
", " + channel.getLocalAddress() + ')')));
|
||||||
}
|
|
||||||
bossStarted = true;
|
bossStarted = true;
|
||||||
} catch (Throwable t) {
|
} catch (Throwable t) {
|
||||||
future.setFailure(t);
|
future.setFailure(t);
|
||||||
|
Loading…
Reference in New Issue
Block a user