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

Fix a bug where channelInactive() is not triggered for local transport

Browse Source
This commit is contained in:
Trustin Lee 2012-06-11 11:59:00 +09:00
parent cf0259661e
commit d27a27c980
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -498,8 +498,8 @@ public abstract class AbstractChannel extends DefaultAttributeMap implements Cha
@Override @Override
public final void close(final ChannelFuture future) { public final void close(final ChannelFuture future) {
if (eventLoop().inEventLoop()) { if (eventLoop().inEventLoop()) {
boolean wasActive = isActive();
if (closeFuture.setClosed()) { if (closeFuture.setClosed()) {
boolean wasActive = isActive();
try { try {
doClose(); doClose();
future.setSuccess(); future.setSuccess();