summaryrefslogtreecommitdiffstats
path: root/jdisc_core/src/test/java/com/yahoo/jdisc/core/ScheduledQueueTestCase.java
diff options
context:
space:
mode:
Diffstat (limited to 'jdisc_core/src/test/java/com/yahoo/jdisc/core/ScheduledQueueTestCase.java')
-rw-r--r--jdisc_core/src/test/java/com/yahoo/jdisc/core/ScheduledQueueTestCase.java21
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);