From 39ac3e88325eb08a934b6b57c8b6a98649f80bde Mon Sep 17 00:00:00 2001
From: voidlizard <dzuikov@gmail.com>
Date: Tue, 22 Jul 2025 08:39:26 +0300
Subject: [PATCH] wip

---
 hbs2-storage-ncq/lib/HBS2/Storage/NCQ2.hs | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git a/hbs2-storage-ncq/lib/HBS2/Storage/NCQ2.hs b/hbs2-storage-ncq/lib/HBS2/Storage/NCQ2.hs
index d6b95e19..8479dfe2 100644
--- a/hbs2-storage-ncq/lib/HBS2/Storage/NCQ2.hs
+++ b/hbs2-storage-ncq/lib/HBS2/Storage/NCQ2.hs
@@ -120,10 +120,7 @@ type NCQSize   = Word32
 type StateVersion = Word64
 
 data NCQIdxEntry =
-  NCQIdxEntry
-  { ncqIdxEntryOffset :: !NCQOffset
-  , ncqIdxEntrySize   :: !NCQSize
-  }
+  NCQIdxEntry {-# UNPACK#-} !NCQOffset !NCQSize
 
 data StateOP = D FileKey | F TimeSpec FileKey | P FileKey
                deriving (Eq,Ord,Show)
@@ -547,7 +544,11 @@ ncqLocateActually ncq href = do
 ncqLocate2 :: MonadUnliftIO m => NCQStorage2 -> HashRef -> m (Maybe Location)
 ncqLocate2 NCQStorage2{..} href = do
   answ <- newEmptyTMVarIO
-  atomically $ writeTQueue ncqReadReq (href, answ)
+
+  atomically do
+    modifyTVar ncqWrites succ
+    writeTQueue ncqReadReq (href, answ)
+
   atomically $ takeTMVar answ
 
 data RunSt =
@@ -1370,7 +1371,7 @@ ncqCompactStep me@NCQStorage2{..} = withSem ncqMergeSem $ flip runContT pure $ c
     getProfit fk tombs = do
       (bs,nw) <- viewIndex fk
       r <- S.toList_ $ nwayHashScanAll nw bs$ \_ k v -> do
-        when (HS.member (coerce k) tombs) $ S.yield $ ncqIdxEntrySize (decodeEntry v)
+        when (HS.member (coerce k) tombs) $ S.yield $ let (NCQIdxEntry _ s) = decodeEntry v in s
       pure (sum r)
 
     getGargabeSlow :: MonadIO m => FileKey -> HashSet HashRef -> m (HashMap HashRef NCQSize)