diff --git a/hbs2-storage-ncq/lib/HBS2/Storage/NCQ2.hs b/hbs2-storage-ncq/lib/HBS2/Storage/NCQ2.hs index a22f9e78..64f21561 100644 --- a/hbs2-storage-ncq/lib/HBS2/Storage/NCQ2.hs +++ b/hbs2-storage-ncq/lib/HBS2/Storage/NCQ2.hs @@ -412,9 +412,7 @@ ncqStorageRun2 ncq@NCQStorage2{..} = flip runContT pure do mq <- newEmptyTMVarIO spawnJob $ do - -- TODO: back-to-merge - -- merged <- ncqStorageMergeStep ncq - let merged = True + merged <- ncqStorageMergeStep ncq atomically $ putTMVar mq merged -- TODO: detect-dead-merge