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

Clear Channel.eventLoop on deregistration

Browse Source
This commit is contained in:
Trustin Lee 2012-05-01 23:19:31 +09:00
parent 1356a0b61e
commit e65e496fc0
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -432,12 +432,20 @@ public abstract class AbstractChannel extends DefaultAttributeMap implements Cha
@Override @Override
public void deregister(final ChannelFuture future) { public void deregister(final ChannelFuture future) {
if (eventLoop().inEventLoop()) { if (eventLoop().inEventLoop()) {
try {
doDeregister(future); doDeregister(future);
} finally {
eventLoop = null;
}
} else { } else {
eventLoop().execute(new Runnable() { eventLoop().execute(new Runnable() {
@Override @Override
public void run() { public void run() {
try {
doDeregister(future); doDeregister(future);
} finally {
eventLoop = null;
}
} }
}); });
} }