diff --git a/src/Hash2Pub/FediChord.hs b/src/Hash2Pub/FediChord.hs index ce8b5b9..95617fc 100644 --- a/src/Hash2Pub/FediChord.hs +++ b/src/Hash2Pub/FediChord.hs @@ -243,7 +243,7 @@ cacheVerifyThread nsSTM = forever $ do forkIO $ sendQueryIdMessages targetID latestNs (Just (1 + jEntriesPerSlice latestNs)) (nodesToQuery targetID) >> pure () -- ask for 1 entry more than j because of querying the middle ) - threadDelay $ toEnum (fromEnum maxEntryAge `div` 20) + threadDelay $ 10^6 * round maxEntryAge `div` 20 -- | Checks the invariant of at least @jEntries@ per cache slice. @@ -355,7 +355,7 @@ stabiliseThread nsSTM = forever $ do ) -- TODO: make delay configurable - threadDelay (60 * 1000) + threadDelay (60 * 10^6) where -- | send a stabilise request to the n-th neighbour -- (specified by the provided getter function) and on failure retr @@ -450,7 +450,7 @@ requestMapPurge mapVar = forever $ do putMVar mapVar $ Map.filter (\entry@(RequestMapEntry _ _ ts) -> now - ts < responsePurgeAge ) rMapState - threadDelay $ fromEnum responsePurgeAge * 2000 + threadDelay $ round responsePurgeAge * 2 * 10^6 -- | Wait for messages, deserialise them, manage parts and acknowledgement status,