Merge remote-tracking branch 'upstream/master' into ws-toilet

lichess-org · Sep 26, 2024 · 78fb9f5 · 78fb9f5
2 parents 566be56 + 34da272
commit 78fb9f5
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/main/scala/Monitor.scala b/src/main/scala/Monitor.scala
@@ -190,3 +190,4 @@ object Monitor:
         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()
+    val scheduledHit = Kamon.counter("connector.scheduledHit").withoutTags()
diff --git a/src/main/scala/netty/ActorChannelConnector.scala b/src/main/scala/netty/ActorChannelConnector.scala
@@ -82,3 +82,8 @@ final private class ActorChannelConnector(
       else if flushQ.isEmpty then 1.second // hibernate
       else 1.millis                        // interval is 0 but we still need to empty the queue
     scheduler.scheduleOnce(nextInterval, () => flush())
+
+  def scheduledHit(): Unit =
+    Monitor.connector.scheduledHit.increment()
+    scheduler.scheduleOnce(1 millis, () => scheduledHit())
+  scheduledHit()