test(journal): add logging for when backpressure happens

platonic-io · Jan 19, 2022 · 288026f · 288026f
1 parent c1f6dad
commit 288026f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/journal/src/Journal/Internal.hs b/src/journal/src/Journal/Internal.hs
@@ -88,7 +88,9 @@ calculatePositionLimit jour = do
 cleanBufferTo :: Journal -> Int -> IO ()
 cleanBufferTo _ _ = return ()
 
-backPressureStatus _ _ = return Nothing
+backPressureStatus _ _ = do
+  putStrLn "backPressureStatus"
+  return Nothing
 
 newPosition :: Metadata -> Maybe (TermOffset, BufferClaim) -> IO (Maybe (Int64, BufferClaim))
 newPosition meta mResult =

diff --git a/src/journal/src/Journal/Types.hs b/src/journal/src/Journal/Types.hs
@@ -155,8 +155,8 @@ activeTermCount (Metadata meta) =
   TermCount <$> readInt32OffAddr meta lOG_ACTIVE_TERM_COUNT_OFFSET
 
 writeActiveTermCount :: Metadata -> TermCount -> IO ()
-writeActiveTermCount (Metadata meta) = do
-  writeIntOffAddr meta lOG_ACTIVE_TERM_COUNT_OFFSET . fromIntegral
+writeActiveTermCount (Metadata meta) =
+  writeInt32OffAddr meta lOG_ACTIVE_TERM_COUNT_OFFSET . unTermCount
 
 casActiveTermCount :: Metadata -> TermCount -> TermCount -> IO Bool
 casActiveTermCount (Metadata meta) (TermCount expected) (TermCount new) =