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

Fix an inspector warning

Browse Source
This commit is contained in:
Trustin Lee 2014-02-17 05:25:17 -08:00
parent 2a74378d01
commit 31c24bc981
2 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
transport-native-epoll/src/main/java/io/netty/channel/epoll/AbstractEpollChannel.java
View File

@ -32,15 +32,16 @@ abstract class AbstractEpollChannel extends AbstractChannel {
volatile int fd;
int id;
AbstractEpollChannel(Channel parent, EventLoop eventLoop, int fd, int flag) {
AbstractEpollChannel(EventLoop eventLoop, int flag) {
this(null, eventLoop, socketFd(), flag, false);
}
AbstractEpollChannel(Channel parent, EventLoop eventLoop, int fd, int flag, boolean active) {
super(parent, eventLoop);
this.fd = fd;
readFlag = flag;
flags |= flag;
}
AbstractEpollChannel(EventLoop eventLoop, int flag) {
this(null, eventLoop, socketFd(), flag);
this.active = active;
}
private static int socketFd() {

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

@ -47,6 +47,7 @@ import java.util.concurrent.TimeUnit;
* maximal performance.
*/
public final class EpollSocketChannel extends AbstractEpollChannel implements SocketChannel {
private final EpollSocketChannelConfig config;
/**
@ -61,8 +62,7 @@ public final class EpollSocketChannel extends AbstractEpollChannel implements So
private volatile boolean outputShutdown;
EpollSocketChannel(Channel parent, EventLoop eventLoop, int fd) {
super(parent, eventLoop, fd, Native.EPOLLIN);
active = true;
super(parent, eventLoop, fd, Native.EPOLLIN, true);
config = new EpollSocketChannelConfig(this);
}