andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix a bug where a closed channel was tried to register with the eventloop

Browse Source
This commit is contained in:
Norman Maurer 2013-02-08 11:31:48 +01:00
parent 2f12f95d9b
commit a3b46ec9d7
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
transport/src/main/java/io/netty/channel/AbstractChannel.java
View File

@ -575,10 +575,6 @@ public abstract class AbstractChannel extends DefaultAttributeMap implements Cha
assert eventLoop().inEventLoop();
if (!ensureOpen(promise)) {
return;
}
// check if the eventLoop which was given is currently in the eventloop.
// if that is the case we are safe to call register, if not we need to
// schedule the execution as otherwise we may say some race-conditions.
@ -598,6 +594,11 @@ public abstract class AbstractChannel extends DefaultAttributeMap implements Cha
private void register0(ChannelPromise promise) {
try {
// check if the channel is still open as it could be closed in the mean time when the register
// call was outside of the eventLoop
if (!ensureOpen(promise)) {
return;
}
Runnable postRegisterTask = doRegister();
registered = true;
promise.setSuccess();