monitor traffic shaping

lichess-org · Sep 25, 2024 · 7ad53ab · 7ad53ab
1 parent aea879f
commit 7ad53ab
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/src/main/scala/Monitor.scala b/src/main/scala/Monitor.scala
@@ -188,3 +188,5 @@ object Monitor:
         val step     = Kamon.gauge("connector.flush.config.step").withoutTags()
         val interval = Kamon.gauge("connector.flush.config.interval").withoutTags()
         val maxDelay = Kamon.gauge("connector.flush.config.maxDelay").withoutTags()
+      val qSize           = Kamon.histogram("connector.flush.qSize").withoutTags()
+      val channelsToFlush = Kamon.histogram("connector.flush.channelsToFlush").withoutTags()
diff --git a/src/main/scala/netty/ActorChannelConnector.scala b/src/main/scala/netty/ActorChannelConnector.scala
@@ -62,8 +62,12 @@ final private class ActorChannelConnector(
       flushQ.add(channel)
 
   private def flush(): Unit =
+    val qSize           = flushQ.size
     val maxDelayFactor  = maxDelay.get().toDouble / interval.get()
-    var channelsToFlush = step.get().atLeast((flushQ.size * maxDelayFactor).toInt)
+    var channelsToFlush = step.get().atLeast((qSize * maxDelayFactor).toInt)
+
+    monitor.qSize.record(qSize)
+    monitor.channelsToFlush.record(channelsToFlush)
 
     while channelsToFlush > 0 do
       Option(flushQ.poll()) match