summaryrefslogtreecommitdiffstats
path: root/jdisc_core/src/test/java/com/yahoo
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-05-02 15:14:45 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2023-05-02 15:14:45 +0200
commitb34f0750f733bf7012b99db3cc5f82b154ea87a6 (patch)
treecb50f51c59c48f453996aa23ef00e2fa82f62458 /jdisc_core/src/test/java/com/yahoo
parent920dbadd44872f34ed4bc51314cc9d09b0645233 (diff)
If you start lagging behind, always prefer timing out as that will be good for all.
Diffstat (limited to 'jdisc_core/src/test/java/com/yahoo')
-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);