celogeek/piwigo-cli
1
0
Fork 0
mirror of https://github.com/celogeek/piwigo-cli.git synced 2025-05-25 10:12:37 +02:00
Code Issues Projects Releases Wiki Activity

pre add jobs

Browse Source
This commit is contained in:
Celogeek 2022-01-02 12:22:16 +01:00
parent 028396b43c
commit 95f3963579
Signed by: celogeek
GPG Key ID: E6B7BDCFC446233A
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/piwigo/files.go
View File

@ -64,8 +64,8 @@ func (p *Piwigo) Upload(file *piwigotools.FileToUpload, stat *piwigotools.FileTo
} }
ok := true ok := true
wg.Add(nbJobs)
for j := 0; j < nbJobs; j++ { for j := 0; j < nbJobs; j++ {
wg.Add(1)
go p.UploadChunk(file, chunks, wg, stat, &ok) go p.UploadChunk(file, chunks, wg, stat, &ok)
} }
wg.Wait() wg.Wait()
@ -208,8 +208,8 @@ func (p *Piwigo) CheckFiles(filesToCheck chan *piwigotools.FileToUpload, files c
defer close(files) defer close(files)
wg := &sync.WaitGroup{} wg := &sync.WaitGroup{}
wg.Add(nbJobs)
for i := 0; i < nbJobs; i++ { for i := 0; i < nbJobs; i++ {
wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
for file := range filesToCheck { for file := range filesToCheck {
@ -235,8 +235,8 @@ func (p *Piwigo) UploadFiles(
defer stat.Close() defer stat.Close()
wg := &sync.WaitGroup{} wg := &sync.WaitGroup{}
wg.Add(nbJobs)
for i := 0; i < nbJobs; i++ { for i := 0; i < nbJobs; i++ {
wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
for file := range files { for file := range files {