Fix race
This commit is contained in:
parent
070c92906d
commit
4afd038fc0
|
@ -123,7 +123,7 @@ public class NioWorker extends AbstractNioWorker {
|
||||||
if (server) {
|
if (server) {
|
||||||
channel.getJdkChannel().configureBlocking(false);
|
channel.getJdkChannel().configureBlocking(false);
|
||||||
}
|
}
|
||||||
|
|
||||||
boolean registered = channel.getJdkChannel().isRegistered();
|
boolean registered = channel.getJdkChannel().isRegistered();
|
||||||
if (!registered) {
|
if (!registered) {
|
||||||
synchronized (channel.interestOpsLock) {
|
synchronized (channel.interestOpsLock) {
|
||||||
|
@ -131,11 +131,9 @@ public class NioWorker extends AbstractNioWorker {
|
||||||
selector, channel.getRawInterestOps(), channel);
|
selector, channel.getRawInterestOps(), channel);
|
||||||
}
|
}
|
||||||
|
|
||||||
} else {
|
|
||||||
// TODO: Is this needed ?
|
|
||||||
setInterestOps(channel, future, channel.getRawInterestOps());
|
|
||||||
}
|
}
|
||||||
if (future != null) {
|
if (future != null) {
|
||||||
|
|
||||||
((NioSocketChannel) channel).setConnected();
|
((NioSocketChannel) channel).setConnected();
|
||||||
future.setSuccess();
|
future.setSuccess();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user