From a73dfc572038b61dfc24c5fe4d3c9259146144f2 Mon Sep 17 00:00:00 2001 From: Dmitry Zuikov Date: Sat, 28 Jan 2023 10:39:47 +0300 Subject: [PATCH] wip --- hbs2-storage-simple/lib/HBS2/Storage/Simple.hs | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/hbs2-storage-simple/lib/HBS2/Storage/Simple.hs b/hbs2-storage-simple/lib/HBS2/Storage/Simple.hs index 4b47fbc6..c03756a1 100644 --- a/hbs2-storage-simple/lib/HBS2/Storage/Simple.hs +++ b/hbs2-storage-simple/lib/HBS2/Storage/Simple.hs @@ -153,19 +153,20 @@ simpleStorageWorker ss = do Just a -> a >> next killer <- async $ forever $ do - pause ( 20 :: Timeout 'Seconds ) -- FIXME: setting + pause ( 30 :: Timeout 'Seconds ) -- FIXME: setting + simpleAddTask ss $ do - atomically $ do + atomically $ do - alive <- readTVar ( ss ^. storageMMapedLRU ) - mmaped <- readTVar ( ss ^. storageMMaped ) + alive <- readTVar ( ss ^. storageMMapedLRU ) + mmaped <- readTVar ( ss ^. storageMMaped ) - let survived = mmaped `HashMap.intersection` alive + let survived = mmaped `HashMap.intersection` alive - writeTVar ( ss ^. storageMMaped ) survived + writeTVar ( ss ^. storageMMaped ) survived killerLRU <- async $ forever $ do - pause ( 5 :: Timeout 'Seconds ) -- FIXME: setting + pause ( 10 :: Timeout 'Seconds ) -- FIXME: setting atomically $ writeTVar ( ss ^. storageMMapedLRU ) mempty (_, e) <- waitAnyCatchCancel [ops,killer, killerLRU]