Studio/aliyunpan
5
0
Fork 0
mirror of https://gitee.com/zhangsken/aliyunpan.git synced 2026-10-16 10:29:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix part num error

Browse Source
This commit is contained in:
tickstep
2025-02-22 17:44:34 +08:00
parent 499b08dd72
commit 44e7402b27
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/file/uploader/multiuploader.go
+1 -1
View File
@@ -146,7 +146,7 @@ func (muer *MultiUploader) Execute() error {
BlockList: SplitBlock(muer.file.Len(), muer.config.BlockSize),
})
logger.Verbosef("upload task CREATED: block size: %d, num: %d\n", muer.config.BlockSize, len(muer.workers))
logger.Verbosef("upload task CREATED: block size: %d, worker num: %d\n", muer.config.BlockSize, len(muer.workers))
}
// 开始上传
internal/file/uploader/multiworker.go
+1 -1
View File
@@ -26,7 +26,7 @@ import (
type (
worker struct {
id int
id int // ID从0开始计数
partOffset int64
splitUnit SplitUnit
uploadDone bool
internal/functions/panupload/upload.go
+4 -4
View File
@@ -116,7 +116,7 @@ func (pu *PanUpload) UploadFile(ctx context.Context, partseq int, partOffset int
}
resp, err = uploadClient.Req(httpMethod, fullUrl, r, headers)
if err != nil {
logger.Verbosef("分片上传出错: 分片%d => %s\n", partseq, err)
logger.Verbosef("分片上传出错: 分片%d => %s\n", partseq+1, err)
}
if resp != nil {
@@ -124,7 +124,7 @@ func (pu *PanUpload) UploadFile(ctx context.Context, partseq int, partOffset int
if blen > 0 {
buf := make([]byte, blen)
resp.Body.Read(buf)
logger.Verbosef("分片上传出错: 分片%d => %s\n", partseq, string(buf))
logger.Verbosef("分片上传出错: 分片%d => %s\n", partseq+1, string(buf))
errResp := &apierror.ErrorXmlResp{}
if err := xml.Unmarshal(buf, errResp); err == nil {
@@ -172,7 +172,7 @@ func (pu *PanUpload) UploadFile(ctx context.Context, partseq int, partOffset int
}
}
} else {
logger.Verbosef("分片上传出错: %d分片 => 原因未知\n", partseq)
logger.Verbosef("分片上传出错: %d分片 => 原因未知\n", partseq+1)
}
// 不可恢复的错误
@@ -203,7 +203,7 @@ func (pu *PanUpload) UploadFile(ctx context.Context, partseq int, partOffset int
DriveId: pu.driveId,
FileId: pu.uploadOpEntity.FileId,
UploadId: pu.uploadOpEntity.UploadId,
PartInfoList: []aliyunpan.FileUploadPartInfoParam{{PartNumber: (partseq + 1)}}, // 阿里云盘partNum从1开始计数，partSeq从0开始
PartInfoList: []aliyunpan.FileUploadPartInfoParam{{PartNumber: partseq + 1}}, // 阿里云盘partNum从1开始计数，partSeq从0开始
})
if er != nil {
return false, &uploader.MultiError{