From c2a2473eb19e3e5e093e70412d0b431af4cb9172 Mon Sep 17 00:00:00 2001
From: Dmitry Zuikov <dzuikov@gmail.com>
Date: Tue, 24 Jan 2023 15:51:34 +0300
Subject: [PATCH] works

---
 hbs2-core/lib/HBS2/Actors/ChunkWriter.hs | 4 ++--
 hbs2-core/lib/HBS2/Actors/Peer.hs        | 2 +-
 hbs2-tests/test/Peer2Main.hs             | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/hbs2-core/lib/HBS2/Actors/ChunkWriter.hs b/hbs2-core/lib/HBS2/Actors/ChunkWriter.hs
index 3372f461..b21cdf48 100644
--- a/hbs2-core/lib/HBS2/Actors/ChunkWriter.hs
+++ b/hbs2-core/lib/HBS2/Actors/ChunkWriter.hs
@@ -122,8 +122,8 @@ runChunkWriter2 w = do
       amount <- for ks $ \k -> flush w k
 
       if (sum amount == 0) then do
-        pure ()
-        -- pause ( 0.5 :: Timeout 'Seconds )
+        -- pure ()
+        pause ( 0.1 :: Timeout 'Seconds )
       else do
         liftIO $ print ("flushed:" <+> pretty (sum amount))
 
diff --git a/hbs2-core/lib/HBS2/Actors/Peer.hs b/hbs2-core/lib/HBS2/Actors/Peer.hs
index 3219d29b..e481d0a1 100644
--- a/hbs2-core/lib/HBS2/Actors/Peer.hs
+++ b/hbs2-core/lib/HBS2/Actors/Peer.hs
@@ -303,7 +303,7 @@ runPeerM s bus p f  = do
                             <*> liftIO (newTVarIO mempty)
 
   let de = view envDeferred env
-  as <- liftIO $ replicateM 8 $ async $ runPipeline de
+  as <- liftIO $ replicateM 4 $ async $ runPipeline de
 
   sw <- liftIO $ async $ forever $ withPeerM env $ do
           pause defSweepTimeout
diff --git a/hbs2-tests/test/Peer2Main.hs b/hbs2-tests/test/Peer2Main.hs
index 641e3032..ca2dd72e 100644
--- a/hbs2-tests/test/Peer2Main.hs
+++ b/hbs2-tests/test/Peer2Main.hs
@@ -155,7 +155,7 @@ runTestPeer p zu = do
   cww  <- newChunkWriterIO  stor (Just chDir)
 
   sw <- liftIO $ replicateM 4  $ async $ simpleStorageWorker stor
-  cw <- liftIO $ replicateM 8 $ async $ runChunkWriter cww
+  cw <- liftIO $ replicateM 8  $ async $ runChunkWriter cww
 
   zu stor cww