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

Allow to adjust timeout of Selector.select(timeout) via io.netty.selectTimeout property. See #568

Browse Source
This commit is contained in:
Norman Maurer 2012-08-26 10:05:20 +02:00
parent 65f8fbb82c
commit 778599baf8
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
transport/src/main/java/io/netty/channel/socket/nio/SelectorUtil.java
View File

@ -25,6 +25,8 @@ import java.nio.channels.Selector;
final class SelectorUtil {
private static final InternalLogger logger =
InternalLoggerFactory.getInstance(SelectorUtil.class);
static final long DEFAULT_SELECT_TIMEOUT = 10;
static final long SELECT_TIMEOUT;
// Workaround for JDK NIO bug.
//
@ -43,11 +45,20 @@ final class SelectorUtil {
logger.debug("Unable to get/set System Property '" + key + "'", e);
}
}
long selectTimeout;
try {
selectTimeout = Long.parseLong(System.getProperty("io.netty.selectTimeout",
String.valueOf(DEFAULT_SELECT_TIMEOUT)));
} catch (NumberFormatException e) {
selectTimeout = DEFAULT_SELECT_TIMEOUT;
}
SELECT_TIMEOUT = selectTimeout;
logger.debug("Using select timeout of " + SELECT_TIMEOUT);
}
static void select(Selector selector) throws IOException {
try {
selector.select(10);
selector.select(SELECT_TIMEOUT);
} catch (CancelledKeyException e) {
if (logger.isDebugEnabled()) {
logger.debug(