Label leaky bucket thread

IntersectMBO · Jan 24, 2025 · b7f2236 · b7f2236
1 parent 388194c
commit b7f2236
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/ouroboros-consensus/src/ouroboros-consensus/Ouroboros/Consensus/Util/LeakyBucket.hs b/ouroboros-consensus/src/ouroboros-consensus/Ouroboros/Consensus/Util/LeakyBucket.hs
@@ -222,7 +222,9 @@ runAgainstBucket config action = do
   leakingPeriodVersionTMVar <- atomically newEmptyTMVar -- see note [Leaky bucket design].
   tid <- myThreadId
   bucket <- init config
-  withAsync (leak (readTMVar leakingPeriodVersionTMVar) tid bucket) $ \_ -> do
+  withAsync (do
+    labelThisThread "Leaky bucket (ouroboros-consensus)"
+    leak (readTMVar leakingPeriodVersionTMVar) tid bucket) $ \_ -> do
     atomicallyWithMonotonicTime $ maybeStartThread Nothing leakingPeriodVersionTMVar bucket
     result <-
       action $