Remove code which I committed by mistake
This commit is contained in:
parent
bbdc2032f0
commit
cb2e047f1d
@ -82,7 +82,6 @@ class NioWorker implements Runnable {
|
|||||||
|
|
||||||
private final SocketReceiveBufferPool recvBufferPool = new SocketReceiveBufferPool();
|
private final SocketReceiveBufferPool recvBufferPool = new SocketReceiveBufferPool();
|
||||||
private final SocketSendBufferPool sendBufferPool = new SocketSendBufferPool();
|
private final SocketSendBufferPool sendBufferPool = new SocketSendBufferPool();
|
||||||
private final AtomicBoolean fireConnect = new AtomicBoolean(true);
|
|
||||||
|
|
||||||
NioWorker(int bossId, int id, Executor executor) {
|
NioWorker(int bossId, int id, Executor executor) {
|
||||||
this.bossId = bossId;
|
this.bossId = bossId;
|
||||||
@ -97,7 +96,6 @@ class NioWorker implements Runnable {
|
|||||||
Selector selector;
|
Selector selector;
|
||||||
|
|
||||||
synchronized (startStopLock) {
|
synchronized (startStopLock) {
|
||||||
fireConnect.set(true);
|
|
||||||
|
|
||||||
if (!started) {
|
if (!started) {
|
||||||
// Open a selector if this worker didn't start yet.
|
// Open a selector if this worker didn't start yet.
|
||||||
|
Loading…
x
Reference in New Issue
Block a user