From d65216cc76b844ad2a475c3d9664d2010bb8c4c5 Mon Sep 17 00:00:00 2001 From: Dmitry Zuikov Date: Wed, 20 Dec 2023 06:04:51 +0300 Subject: [PATCH] fixed oopsie --- hbs2-peer/app/RefChanNotifyLog.hs | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/hbs2-peer/app/RefChanNotifyLog.hs b/hbs2-peer/app/RefChanNotifyLog.hs index 47ec866a..97c1cdb9 100644 --- a/hbs2-peer/app/RefChanNotifyLog.hs +++ b/hbs2-peer/app/RefChanNotifyLog.hs @@ -9,7 +9,6 @@ import HBS2.Prelude.Plated import HBS2.Actors.Peer import HBS2.Hash import HBS2.Base58 -import HBS2.Clock import HBS2.Events import HBS2.Polling import HBS2.Data.Detect @@ -31,19 +30,16 @@ import PeerTypes hiding (downloads) import PeerConfig import Brains -import Data.Time.Clock (NominalDiffTime(..)) +import Data.Time.Clock (NominalDiffTime) import Data.List qualified as List import Control.Concurrent.STM (flushTQueue) import Data.Hashable import Control.Exception () -import Control.Monad import Control.Monad.Except () -import Data.HashMap.Strict qualified as HashMap import Data.Maybe import Data.Text qualified as Text import UnliftIO -import Control.Monad.Trans.Maybe import Data.Function (on) import Streaming() @@ -148,7 +144,7 @@ refChanNotifyLogWorker conf brains = do headDef 1 [ fromIntegral n | ListVal [SymbolVal "write-time", LitIntVal n] <- syn ] getTrim syn = Just $ - headDef 0 [ fromIntegral n | ListVal [SymbolVal "trim", LitIntVal n] <- syn ] + headDef 10000 [ fromIntegral n | ListVal [SymbolVal "trim", LitIntVal n] <- syn ] toPolling qs = pure $ fmap (\(l,q) -> (MyPoll (listenChan l) l q, listenWriteTime l)) qs