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

Fix check to clear READ_OP and EPOLLIN. Part of [#2254]

Browse Source
This commit is contained in:
Norman Maurer 2014-02-22 20:06:21 +01:00
parent b32316b33c
commit 8c68c5a3ae
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
transport-native-epoll/src/main/java/io/netty/channel/epoll/EpollServerSocketChannel.java
View File

@ -123,7 +123,7 @@ public final class EpollServerSocketChannel extends AbstractEpollChannel impleme
// * The user called Channel.read() or ChannelHandlerContext.read() in channelReadComplete(...) method
//
// See https://github.com/netty/netty/issues/2254
if (config.isAutoRead() && !readPending) {
if (!config.isAutoRead() && !readPending) {
clearEpollIn();
}
}

2
transport-native-epoll/src/main/java/io/netty/channel/epoll/EpollSocketChannel.java
View File

@ -648,7 +648,7 @@ public final class EpollSocketChannel extends AbstractEpollChannel implements So
// * The user called Channel.read() or ChannelHandlerContext.read() in channelReadComplete(...) method
//
// See https://github.com/netty/netty/issues/2254
if (config.isAutoRead() && !readPending) {
if (!config.isAutoRead() && !readPending) {
clearEpollIn();
}
}

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

@ -152,7 +152,7 @@ public abstract class AbstractNioByteChannel extends AbstractNioChannel {
// * The user called Channel.read() or ChannelHandlerContext.read() in channelReadComplete(...) method
//
// See https://github.com/netty/netty/issues/2254
if (config.isAutoRead() && !readPending) {
if (!config.isAutoRead() && !readPending) {
removeReadOp();
}
}

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

@ -112,7 +112,7 @@ public abstract class AbstractNioMessageChannel extends AbstractNioChannel {
// * The user called Channel.read() or ChannelHandlerContext.read() in channelReadComplete(...) method
//
// See https://github.com/netty/netty/issues/2254
if (config.isAutoRead() && !readPending) {
if (!config.isAutoRead() && !readPending) {
removeReadOp();
}
}