Keeps track of the duration.

JonathanLennox · Jun 3, 2019 · 45c5c4a · 45c5c4a
1 parent 6c316f4
commit 45c5c4a
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/main/java/org/jitsi/utils/queue/QueueStatistics.java b/src/main/java/org/jitsi/utils/queue/QueueStatistics.java
@@ -66,6 +66,11 @@ public class QueueStatistics
      */
     private AtomicInteger totalPacketsDropped = new AtomicInteger();
 
+    /**
+     * The time the first packet was added.
+     */
+    private long firstPacketAddedMs = -1;
+
     /**
      * Initializes a new {@link QueueStatistics} instance.
      * 
@@ -89,6 +94,9 @@ public JSONObject getStats()
         stats.put("add_rate", addRate.getRate(now));
         stats.put("remove_rate", removeRate.getRate(now));
         stats.put("drop_rate", dropRate.getRate(now));
+        double duration = (now - firstPacketAddedMs) / 1000;
+        stats.put("duration_s", duration);
+        stats.put("average_remove_rate_pps", totalPacketsRemoved.get() / duration);
 
         return stats;
     }
@@ -100,6 +108,10 @@ public JSONObject getStats()
      */
     void add(long now)
     {
+        if (firstPacketAddedMs < 0)
+        {
+            firstPacketAddedMs = now;
+        }
         addRate.update(1, now);
         totalPacketsAdded.incrementAndGet();
     }