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

Fixed a bug where channelUnbound/channelDisconnected/channelClosed event is sometimes not fired

Browse Source
This commit is contained in:
Trustin Lee 2008-11-27 15:44:14 +00:00
parent e7d5048440
commit 044fd23b0b
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java
View File

@ -86,7 +86,7 @@ class NioWorker implements Runnable {
}
void register(NioSocketChannel channel, ChannelFuture future) {
boolean server = !(channel instanceof NioClientSocketChannel);
Runnable registerTask = new RegisterTask(channel, future, server);
Selector selector;
@ -100,7 +100,7 @@ class NioWorker implements Runnable {
throw new ChannelException(
"Failed to create a selector.", t);
}
// Start the worker thread with the new Selector.
String threadName =
(server ? "New I/O server worker #"
@ -126,7 +126,7 @@ class NioWorker implements Runnable {
// Use the existing selector if this worker has been started.
selector = this.selector;
}
assert selector != null && selector.isOpen();
started = true;
@ -716,7 +716,7 @@ class NioWorker implements Runnable {
boolean bound = channel.isBound();
try {
channel.socket.close();
future.setSuccess();
assert future == channel.getCloseFuture();
if (channel.setClosed()) {
if (connected) {
if (channel.getInterestOps() != Channel.OP_WRITE) {
@ -880,4 +880,4 @@ class NioWorker implements Runnable {
fireChannelConnected(channel, channel.getRemoteAddress());
}
}
}
}