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

Allow to set IoRatio to 100%

Browse Source
This commit is contained in:
Norman Maurer 2014-02-12 15:22:39 +01:00
parent 4dc337a717
commit 0ad029bf96
1 changed files with 21 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
transport/src/main/java/io/netty/channel/nio/NioEventLoop.java
View File

@ -211,8 +211,8 @@ public final class NioEventLoop extends SingleThreadEventLoop {
* {@code 50}, which means the event loop will try to spend the same amount of time for I/O as for non-I/O tasks. * {@code 50}, which means the event loop will try to spend the same amount of time for I/O as for non-I/O tasks.
*/ */
public void setIoRatio(int ioRatio) { public void setIoRatio(int ioRatio) {
if (ioRatio <= 0 || ioRatio >= 100) { if (ioRatio <= 0 || ioRatio > 100) {
throw new IllegalArgumentException("ioRatio: " + ioRatio + " (expected: 0 < ioRatio < 100)"); throw new IllegalArgumentException("ioRatio: " + ioRatio + " (expected: 0 < ioRatio < 101)");
} }
this.ioRatio = ioRatio; this.ioRatio = ioRatio;
} }
@ -339,18 +339,19 @@ public final class NioEventLoop extends SingleThreadEventLoop {
} }
cancelledKeys = 0; cancelledKeys = 0;
final long ioStartTime = System.nanoTime();
needsToSelectAgain = false; needsToSelectAgain = false;
if (selectedKeys != null) {
processSelectedKeysOptimized(selectedKeys.flip());
} else {
processSelectedKeysPlain(selector.selectedKeys());
}
final long ioTime = System.nanoTime() - ioStartTime;
final int ioRatio = this.ioRatio; final int ioRatio = this.ioRatio;
runAllTasks(ioTime * (100 - ioRatio) / ioRatio); if (ioRatio == 100) {
processSelectedKeys();
runAllTasks();
} else {
final long ioStartTime = System.nanoTime();
processSelectedKeys();
final long ioTime = System.nanoTime() - ioStartTime;
runAllTasks(ioTime * (100 - ioRatio) / ioRatio);
}
if (isShuttingDown()) { if (isShuttingDown()) {
closeAll(); closeAll();
@ -372,6 +373,14 @@ public final class NioEventLoop extends SingleThreadEventLoop {
} }
} }
private void processSelectedKeys() {
if (selectedKeys != null) {
processSelectedKeysOptimized(selectedKeys.flip());
} else {
processSelectedKeysPlain(selector.selectedKeys());
}
}
@Override @Override
protected void cleanup() { protected void cleanup() {
try { try {