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

Made sure interestOps is updated before OIO thread is interrupted

Browse Source
This commit is contained in:
Trustin Lee 2009-06-05 07:00:55 +00:00
parent 76777b74b4
commit 5273e274de
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/jboss/netty/channel/socket/oio/OioDatagramWorker.java
View File

@ -144,6 +144,8 @@ class OioDatagramWorker implements Runnable {
future.setSuccess();
if (changed) {
channel.setInterestOpsNow(interestOps);
// Notify the worker so it stops or continues reading.
Thread currentThread = Thread.currentThread();
Thread workerThread = channel.workerThread;
@ -151,7 +153,6 @@ class OioDatagramWorker implements Runnable {
workerThread.interrupt();
}
channel.setInterestOpsNow(interestOps);
fireChannelInterestChanged(channel);
}
} catch (Throwable t) {