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

Fix over-sensible testcase

Browse Source
This commit is contained in:
Norman Maurer 2014-07-13 17:19:15 +02:00
parent 1cdbbe0f9b
commit 0eb64b5a5d
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
common/src/test/java/io/netty/util/HashedWheelTimerTest.java
View File

@ -131,7 +131,7 @@ public class HashedWheelTimerTest {
public void testExecutionOnTime() throws InterruptedException { public void testExecutionOnTime() throws InterruptedException {
int tickDuration = 200; int tickDuration = 200;
int timeout = 125; int timeout = 125;
int maxTimeout = tickDuration + timeout; int maxTimeout = tickDuration + timeout + tickDuration;
final HashedWheelTimer timer = new HashedWheelTimer(tickDuration, TimeUnit.MILLISECONDS); final HashedWheelTimer timer = new HashedWheelTimer(tickDuration, TimeUnit.MILLISECONDS);
final BlockingQueue<Long> queue = new LinkedBlockingQueue<Long>(); final BlockingQueue<Long> queue = new LinkedBlockingQueue<Long>();
@ -148,8 +148,8 @@ public class HashedWheelTimerTest {
for (int i = 0; i < scheduledTasks; i++) { for (int i = 0; i < scheduledTasks; i++) {
long delay = queue.take(); long delay = queue.take();
assertTrue("Timeout + " + scheduledTasks + " delay " + delay + " must be " + timeout + " <= " + maxTimeout, assertTrue("Timeout + " + scheduledTasks + " delay " + delay + " must be " + timeout + " < " + maxTimeout,
delay >= timeout && delay <= maxTimeout); delay >= timeout && delay < maxTimeout);
} }
timer.stop(); timer.stop();