test if the scheduler can run every millisecond - REVERT ME eventually

lichess-org · Sep 26, 2024 · 34da272 · 34da272
1 parent aa78adb
commit 34da272
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()