From c9ed0ecebb0963605c7a14f3e410dace95d017b7 Mon Sep 17 00:00:00 2001 From: Binwei Fang Date: Wed, 28 Dec 2022 00:40:05 +0800 Subject: [PATCH] fix: fix upload concurrency (#12) --- operation/upload.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/operation/upload.go b/operation/upload.go index b752a99..7745fd9 100644 --- a/operation/upload.go +++ b/operation/upload.go @@ -27,9 +27,9 @@ func UploadObjects(root string, bucket *oss.Bucket, records <-chan utils.FileInf var uploadedMutex sync.Mutex var errs []error uploaded := make([]UploadedObject, 0, 20) + var tokens = make(chan struct{}, 30) for item := range records { sw.Add(1) - var tokens = make(chan struct{}, 10) go func(item utils.FileInfoType) { defer sw.Done() fPath := item.Path