diff --git a/hbs2-peer/app/RefLog.hs b/hbs2-peer/app/RefLog.hs
index 03c9d1f6..fad1b56c 100644
--- a/hbs2-peer/app/RefLog.hs
+++ b/hbs2-peer/app/RefLog.hs
@@ -169,6 +169,7 @@ reflogWorker conf adapter = do
 
     here <- liftIO $ readTVarIO reflogMon <&> HashSet.member h
     unless here do
+      liftIO $ atomically $ modifyTVar' reflogMon (HashSet.insert h)
       void $ liftIO $ async $ do
         timeout <-  async (reflogTimeout reflog h)
         work <- async $ do