voidlizard
/
hbs2
mirror of https://github.com/voidlizard/hbs2
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fixed oopsie

This commit is contained in:
Dmitry Zuikov 2023-12-20 06:04:51 +03:00
parent 24272ad4d9
commit d65216cc76
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbs2-peer/app/RefChanNotifyLog.hs
View File

@ -9,7 +9,6 @@ import HBS2.Prelude.Plated
import HBS2.Actors.Peer import HBS2.Actors.Peer
import HBS2.Hash import HBS2.Hash
import HBS2.Base58 import HBS2.Base58
import HBS2.Clock
import HBS2.Events import HBS2.Events
import HBS2.Polling import HBS2.Polling
import HBS2.Data.Detect import HBS2.Data.Detect
@ -31,19 +30,16 @@ import PeerTypes hiding (downloads)
import PeerConfig import PeerConfig
import Brains import Brains
import Data.Time.Clock (NominalDiffTime(..)) import Data.Time.Clock (NominalDiffTime)
import Data.List qualified as List import Data.List qualified as List
import Control.Concurrent.STM (flushTQueue) import Control.Concurrent.STM (flushTQueue)
import Data.Hashable import Data.Hashable
import Control.Exception () import Control.Exception ()
import Control.Monad
import Control.Monad.Except () import Control.Monad.Except ()
import Data.HashMap.Strict qualified as HashMap
import Data.Maybe import Data.Maybe
import Data.Text qualified as Text import Data.Text qualified as Text
import UnliftIO import UnliftIO
import Control.Monad.Trans.Maybe
import Data.Function (on) import Data.Function (on)
import Streaming() import Streaming()
@ -148,7 +144,7 @@ refChanNotifyLogWorker conf brains = do
headDef 1 [ fromIntegral n | ListVal [SymbolVal "write-time", LitIntVal n] <- syn ] headDef 1 [ fromIntegral n | ListVal [SymbolVal "write-time", LitIntVal n] <- syn ]
getTrim syn = Just $ 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 toPolling qs = pure $ fmap (\(l,q) -> (MyPoll (listenChan l) l q, listenWriteTime l)) qs