From 677a5038c5fcc7093953978c5de0f36afbe625d8 Mon Sep 17 00:00:00 2001 From: Alexander Neumann Date: Tue, 17 Feb 2015 23:15:08 +0100 Subject: [PATCH] Increase concurrency for loading blobs --- archiver.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/archiver.go b/archiver.go index 70e39e69d..a05ccf651 100644 --- a/archiver.go +++ b/archiver.go @@ -16,8 +16,9 @@ import ( ) const ( - maxConcurrentBlobs = 32 - maxConcurrency = 10 + maxConcurrentBlobs = 32 + maxConcurrency = 10 + maxConcurrencyPreload = 100 // chunkerBufSize is used in pool.go chunkerBufSize = 512 * chunker.KiB @@ -80,7 +81,7 @@ func (arch *Archiver) Preload() error { // start workers var wg sync.WaitGroup - for i := 0; i < maxConcurrency; i++ { + for i := 0; i < maxConcurrencyPreload; i++ { wg.Add(1) go worker(&wg, idCh) }