diff options
Diffstat (limited to 'jdisc_core/src/test/java/com')
-rw-r--r-- | jdisc_core/src/test/java/com/yahoo/jdisc/core/ScheduledQueueTestCase.java | 21 |
1 files changed, 0 insertions, 21 deletions
diff --git a/jdisc_core/src/test/java/com/yahoo/jdisc/core/ScheduledQueueTestCase.java b/jdisc_core/src/test/java/com/yahoo/jdisc/core/ScheduledQueueTestCase.java index cd963caa8d2..9fcfd49d4ee 100644 --- a/jdisc_core/src/test/java/com/yahoo/jdisc/core/ScheduledQueueTestCase.java +++ b/jdisc_core/src/test/java/com/yahoo/jdisc/core/ScheduledQueueTestCase.java @@ -5,12 +5,10 @@ import org.junit.jupiter.api.Test; import java.util.Arrays; import java.util.LinkedList; -import java.util.List; import java.util.Queue; import static com.yahoo.jdisc.core.ScheduledQueue.MILLIS_PER_SLOT; import static com.yahoo.jdisc.core.ScheduledQueue.NUM_SLOTS; -import static com.yahoo.jdisc.core.ScheduledQueue.NUM_SLOTS_UNDILATED; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertTrue; import static org.junit.jupiter.api.Assertions.fail; @@ -115,25 +113,6 @@ public class ScheduledQueueTestCase { assertDrainTo(queue, 0, foo); } - @Test - void requireThatDrainToPerformsTimeDilationWhenOverloaded() { - ScheduledQueue queue = new ScheduledQueue(0); - List<Object> payloads = new LinkedList<>(); - for (int i = 1; i <= NUM_SLOTS_UNDILATED + 1; ++i) { - payloads.add(scheduleAt(queue, i * MILLIS_PER_SLOT)); - } - - Queue<Object> expired = new LinkedList<>(); - long currentTimeMillis = payloads.size() * MILLIS_PER_SLOT; - queue.drainTo(currentTimeMillis, expired); - assertEquals(NUM_SLOTS_UNDILATED, expired.size()); - - expired = new LinkedList<>(); - currentTimeMillis += MILLIS_PER_SLOT; - queue.drainTo(currentTimeMillis, expired); - assertEquals(1, expired.size()); - } - private static Object scheduleAt(ScheduledQueue queue, long expireAtMillis) { Object obj = new Object(); queue.newEntry(obj).scheduleAt(expireAtMillis); |