Fix race
This commit is contained in:
parent
732b11e7d5
commit
e3fa9810f8
@ -345,9 +345,6 @@ public class SctpWorker extends NioWorker {
|
|||||||
selector, channel.getRawInterestOps(), channel);
|
selector, channel.getRawInterestOps(), channel);
|
||||||
}
|
}
|
||||||
|
|
||||||
} else {
|
|
||||||
// TODO: Is this needed ?
|
|
||||||
setInterestOps(channel, future, channel.getRawInterestOps());
|
|
||||||
}
|
}
|
||||||
if (future != null) {
|
if (future != null) {
|
||||||
((SctpChannelImpl) channel).setConnected();
|
((SctpChannelImpl) channel).setConnected();
|
||||||
|
Loading…
x
Reference in New Issue
Block a user