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

[#1723] invoke close in eventloop

Browse Source
This commit is contained in:
bgallagher 2013-08-09 16:24:14 -04:00 committed by Norman Maurer
parent c1d787bff7
commit 59c2fd8813
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java
View File

@ -498,23 +498,26 @@ final class DefaultChannelHandlerContext extends DefaultAttributeMap implements
public ChannelFuture disconnect(final ChannelPromise promise) { public ChannelFuture disconnect(final ChannelPromise promise) {
validatePromise(promise, false); validatePromise(promise, false);
// Translate disconnect to close if the channel has no notion of disconnect-reconnect.
// So far, UDP/IP is the only transport that has such behavior.
if (!channel().metadata().hasDisconnect()) {
findContextOutbound().invokeClose(promise);
return promise;
}
final DefaultChannelHandlerContext next = findContextOutbound(); final DefaultChannelHandlerContext next = findContextOutbound();
EventExecutor executor = next.executor(); EventExecutor executor = next.executor();
if (executor.inEventLoop()) { if (executor.inEventLoop()) {
// Translate disconnect to close if the channel has no notion of disconnect-reconnect.
// So far, UDP/IP is the only transport that has such behavior.
if (!channel().metadata().hasDisconnect()) {
next.invokeClose(promise);
} else {
next.invokeDisconnect(promise); next.invokeDisconnect(promise);
}
} else { } else {
executor.execute(new Runnable() { executor.execute(new Runnable() {
@Override @Override
public void run() { public void run() {
if (!channel().metadata().hasDisconnect()) {
next.invokeClose(promise);
} else {
next.invokeDisconnect(promise); next.invokeDisconnect(promise);
} }
}
}); });
} }