From 3efe992436ea590e8a2ebe197fadc84ed1710850 Mon Sep 17 00:00:00 2001 From: Dmitry Zuikov Date: Wed, 19 Jul 2023 20:40:34 +0300 Subject: [PATCH] wip, log merging, debug-19 --- hbs2-peer/app/RefChan.hs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/hbs2-peer/app/RefChan.hs b/hbs2-peer/app/RefChan.hs index 67b51ead..ff7fe1db 100644 --- a/hbs2-peer/app/RefChan.hs +++ b/hbs2-peer/app/RefChan.hs @@ -217,6 +217,7 @@ refChanWorker env brains = do debug $ "ON ROUND STARTED" <+> pretty rcrk forever do + -- FIXME: use-polling-function-and-respect-wait pause @'Seconds 30 now <- getTimeCoarse @@ -235,9 +236,10 @@ refChanWorker env brains = do when (closed || ttl <= now) do lift $ expire x - forM_ trans $ \t -> do - debug $ "WRITING TRANS" <+> pretty t - lift $ refChanWriteTranFn env t + when closed do + forM_ trans $ \t -> do + debug $ "WRITING TRANS" <+> pretty t + lift $ refChanWriteTranFn env t atomically $ modifyTVar rounds (HashSet.delete x) debug $ "CLEANUP ROUND" <+> pretty x