From 95f3963579aad37dc4b3557da6d97157bd45c155 Mon Sep 17 00:00:00 2001 From: celogeek <65178+celogeek@users.noreply.github.com> Date: Sun, 2 Jan 2022 12:22:16 +0100 Subject: [PATCH] pre add jobs --- internal/piwigo/files.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/piwigo/files.go b/internal/piwigo/files.go index dea3f44..117d54c 100644 --- a/internal/piwigo/files.go +++ b/internal/piwigo/files.go @@ -64,8 +64,8 @@ func (p *Piwigo) Upload(file *piwigotools.FileToUpload, stat *piwigotools.FileTo } ok := true + wg.Add(nbJobs) for j := 0; j < nbJobs; j++ { - wg.Add(1) go p.UploadChunk(file, chunks, wg, stat, &ok) } wg.Wait() @@ -208,8 +208,8 @@ func (p *Piwigo) CheckFiles(filesToCheck chan *piwigotools.FileToUpload, files c defer close(files) wg := &sync.WaitGroup{} + wg.Add(nbJobs) for i := 0; i < nbJobs; i++ { - wg.Add(1) go func() { defer wg.Done() for file := range filesToCheck { @@ -235,8 +235,8 @@ func (p *Piwigo) UploadFiles( defer stat.Close() wg := &sync.WaitGroup{} + wg.Add(nbJobs) for i := 0; i < nbJobs; i++ { - wg.Add(1) go func() { defer wg.Done() for file := range files {