From 6ad24295090cc2611ab63eded047279c4f44b9af Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Domen=20Ko=C5=BEar?= Date: Wed, 9 Apr 2025 13:44:36 +0100 Subject: [PATCH] Increase queue sizes to handle larger workloads --- cachix/src/Cachix/Client/PushQueue.hs | 2 +- cachix/src/Cachix/Daemon/PushManager.hs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/cachix/src/Cachix/Client/PushQueue.hs b/cachix/src/Cachix/Client/PushQueue.hs index e69b7365..6e915032 100644 --- a/cachix/src/Cachix/Client/PushQueue.hs +++ b/cachix/src/Cachix/Client/PushQueue.hs @@ -60,7 +60,7 @@ startWorkers numWorkers mkProducer pushParams = do -- start query worker (newQueryQueue, newPushQueue, newLock) <- atomically $ - (,,) <$> TBQueue.newTBQueue 10000 <*> TBQueue.newTBQueue 10000 <*> Lock.new + (,,) <$> TBQueue.newTBQueue 100_000 <*> TBQueue.newTBQueue 100_000 <*> Lock.new let queryWorkerState = QueryWorkerState newQueryQueue S.empty newLock queryWorker <- async $ queryLoop queryWorkerState newPushQueue pushParams diff --git a/cachix/src/Cachix/Daemon/PushManager.hs b/cachix/src/Cachix/Daemon/PushManager.hs index b4ba8bbd..411c0a26 100644 --- a/cachix/src/Cachix/Daemon/PushManager.hs +++ b/cachix/src/Cachix/Daemon/PushManager.hs @@ -80,7 +80,7 @@ newPushManagerEnv pushOptions pmPushParams onPushEvent pmLogger = liftIO $ do pmPushJobs <- newTVarIO mempty pmPendingJobCount <- newTVarIO 0 pmStorePathIndex <- newTVarIO mempty - pmTaskQueue <- newTBMQueueIO 1000 + pmTaskQueue <- newTBMQueueIO 100_000 pmTaskSemaphore <- QSem.newQSem (numJobs pushOptions) pmLastEventTimestamp <- newTVarIO =<< getCurrentTime let pmOnPushEvent id pushEvent = updateTimestampTVar pmLastEventTimestamp >> onPushEvent id pushEvent