Merge pull request #624 from schlawg/no-negative-size

prevent devious scheduling from reporting negative size to kamon
lichess-org · Nov 28, 2024 · 9dc34d5 · 9dc34d5
2 parents ff0c941 + 8a1f104
commit 9dc34d5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/netty/ActorChannelConnector.scala b/src/main/scala/netty/ActorChannelConnector.scala
@@ -97,8 +97,8 @@ object ActorChannelConnector:
     private val size  = java.util.concurrent.atomic.AtomicInteger()
 
     def add(channel: Channel): Unit =
-      queue.add(channel)
       size.getAndIncrement()
+      queue.add(channel)
 
     def poll(): Option[Channel] =
       val maybeChannel = Option(queue.poll())