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

cleanup comments

Browse Source
This commit is contained in:
norman 2012-04-12 09:29:59 +02:00
parent 3f8c13f138
commit 941e71de36
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java
View File

@ -430,7 +430,7 @@ abstract class AbstractNioWorker implements Worker {
int readyOps = k.readyOps(); int readyOps = k.readyOps();
if ((readyOps & SelectionKey.OP_READ) != 0 || readyOps == 0) { if ((readyOps & SelectionKey.OP_READ) != 0 || readyOps == 0) {
if (!read(k)) { if (!read(k)) {
// Connection already closed - no need to handle write. // Connection already closed - no need to handle write / accept / connect.
continue; continue;
} }
} }
@ -472,7 +472,6 @@ abstract class AbstractNioWorker implements Worker {
if (acceptedSocket == null) { if (acceptedSocket == null) {
break; break;
} }
// TODO: Remove the casting stuff
ChannelPipeline pipeline = ChannelPipeline pipeline =
channel.getConfig().getPipelineFactory().getPipeline(); channel.getConfig().getPipelineFactory().getPipeline();
NioWorker worker = channel.workers.nextWorker(); NioWorker worker = channel.workers.nextWorker();