Fix race
This commit is contained in:
parent
c3e51af849
commit
732b11e7d5
@ -131,9 +131,6 @@ 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) {
|
||||||
if (channel instanceof NioSocketChannel) {
|
if (channel instanceof NioSocketChannel) {
|
||||||
|
Loading…
Reference in New Issue
Block a user