1 files changed, 8 insertions, 0 deletions
diff --git a/jdisc_core/src/main/java/com/yahoo/jdisc/core/ScheduledQueue.java b/jdisc_core/src/main/java/com/yahoo/jdisc/core/ScheduledQueue.java
index 29ac57a24a1..397271d0b48 100644
--- a/jdisc_core/src/main/java/com/yahoo/jdisc/core/ScheduledQueue.java
+++ b/jdisc_core/src/main/java/com/yahoo/jdisc/core/ScheduledQueue.java
@@ -60,6 +60,14 @@ class ScheduledQueue {
         }
     }
 
+    synchronized int queueSize() {
+        int sum = 0;
+        for (int cnt : counts) {
+            sum += cnt;
+        }
+        return sum;
+    }
+
     private synchronized void scheduleAt(Entry entry, long expireAtMillis) {
         if (entry.next != null) {
             linkOut(entry);