ProjectHentai/alist
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(baidu_netdisk): remove duplicate retry (#7972)

Browse Source
This commit is contained in:
Ljcbaby 2025-03-01 19:00:36 +08:00 committed by GitHub
parent 2570707a06
commit 370a6c15a9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
drivers/baidu_netdisk/driver.go
View File

@ -20,7 +20,6 @@ import (
"github.com/alist-org/alist/v3/internal/model" "github.com/alist-org/alist/v3/internal/model"
"github.com/alist-org/alist/v3/pkg/errgroup" "github.com/alist-org/alist/v3/pkg/errgroup"
"github.com/alist-org/alist/v3/pkg/utils" "github.com/alist-org/alist/v3/pkg/utils"
"github.com/avast/retry-go"
log "github.com/sirupsen/logrus" log "github.com/sirupsen/logrus"
) )
@ -261,10 +260,7 @@ func (d *BaiduNetdisk) Put(ctx context.Context, dstDir model.Obj, stream model.F
} }
} }
// step.2 上传分片 // step.2 上传分片
threadG, upCtx := errgroup.NewGroupWithContext(ctx, d.uploadThread, threadG, upCtx := errgroup.NewGroupWithContext(ctx, d.uploadThread)
retry.Attempts(3),
retry.Delay(time.Second),
retry.DelayType(retry.BackOffDelay))
sem := semaphore.NewWeighted(3) sem := semaphore.NewWeighted(3)
for i, partseq := range precreateResp.BlockList { for i, partseq := range precreateResp.BlockList {
if utils.IsCanceled(upCtx) { if utils.IsCanceled(upCtx) {