From 5d4480606466a7af0ee19f34badd9de32174bc4d Mon Sep 17 00:00:00 2001
From: KirCute <951206789@qq.com>
Date: Sat, 21 Jun 2025 00:16:19 +0800
Subject: [PATCH] fix(upload): revert #79 (#248)

---
 drivers/123_open/upload.go      | 1 -
 drivers/189pc/utils.go          | 1 -
 drivers/baidu_netdisk/driver.go | 1 -
 drivers/baidu_photo/driver.go   | 1 -
 drivers/mopan/driver.go         | 1 -
 5 files changed, 5 deletions(-)

diff --git a/drivers/123_open/upload.go b/drivers/123_open/upload.go
index 5cedd5a3..c3cdd33b 100644
--- a/drivers/123_open/upload.go
+++ b/drivers/123_open/upload.go
@@ -82,7 +82,6 @@ func (d *Open123) Upload(ctx context.Context, file model.FileStreamer, createRes
 		retry.Attempts(3),
 		retry.Delay(time.Second),
 		retry.DelayType(retry.BackOffDelay))
-	threadG.SetLimit(3)
 
 	for partIndex := int64(0); partIndex < uploadNums; partIndex++ {
 		if utils.IsCanceled(uploadCtx) {
diff --git a/drivers/189pc/utils.go b/drivers/189pc/utils.go
index 2251dbc5..5f71b332 100644
--- a/drivers/189pc/utils.go
+++ b/drivers/189pc/utils.go
@@ -504,7 +504,6 @@ func (y *Cloud189PC) StreamUpload(ctx context.Context, dstDir model.Obj, file mo
 		retry.Attempts(3),
 		retry.Delay(time.Second),
 		retry.DelayType(retry.BackOffDelay))
-	threadG.SetLimit(3)
 
 	count := int(size / sliceSize)
 	lastPartSize := size % sliceSize
diff --git a/drivers/baidu_netdisk/driver.go b/drivers/baidu_netdisk/driver.go
index 98973391..3afbe0db 100644
--- a/drivers/baidu_netdisk/driver.go
+++ b/drivers/baidu_netdisk/driver.go
@@ -295,7 +295,6 @@ func (d *BaiduNetdisk) Put(ctx context.Context, dstDir model.Obj, stream model.F
 		retry.Attempts(1),
 		retry.Delay(time.Second),
 		retry.DelayType(retry.BackOffDelay))
-	threadG.SetLimit(3)
 
 	for i, partseq := range precreateResp.BlockList {
 		if utils.IsCanceled(upCtx) {
diff --git a/drivers/baidu_photo/driver.go b/drivers/baidu_photo/driver.go
index 1dd911b5..52b71b87 100644
--- a/drivers/baidu_photo/driver.go
+++ b/drivers/baidu_photo/driver.go
@@ -342,7 +342,6 @@ func (d *BaiduPhoto) Put(ctx context.Context, dstDir model.Obj, stream model.Fil
 			retry.Attempts(3),
 			retry.Delay(time.Second),
 			retry.DelayType(retry.BackOffDelay))
-		threadG.SetLimit(3)
 
 		for i, partseq := range precreateResp.BlockList {
 			if utils.IsCanceled(upCtx) {
diff --git a/drivers/mopan/driver.go b/drivers/mopan/driver.go
index 12208cb1..7c2d0977 100644
--- a/drivers/mopan/driver.go
+++ b/drivers/mopan/driver.go
@@ -298,7 +298,6 @@ func (d *MoPan) Put(ctx context.Context, dstDir model.Obj, stream model.FileStre
 			retry.Attempts(3),
 			retry.Delay(time.Second),
 			retry.DelayType(retry.BackOffDelay))
-		threadG.SetLimit(3)
 
 		// step.3
 		parts, err := d.client.GetAllMultiUploadUrls(initUpdload.UploadFileID, initUpdload.PartInfos)