Skip to content

Commit 72682ac

Browse files
author
cyk
committed
fix(FileTransferTask): skip copying if destination directory does not exist
1 parent e192149 commit 72682ac

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

internal/fs/copy_move.go

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -191,16 +191,16 @@ func (t *FileTransferTask) RunWithNextTaskCallback(f func(nextTask *FileTransfer
191191

192192
existedObjs := make(map[string]bool)
193193
if t.TaskType == merge {
194+
// 检查目标目录是否存在,如果不存在则跳过(existedObjs保持为空map,所有文件都会被复制)
194195
dstObjs, err := op.List(t.Ctx(), t.DstStorage, dstActualPath, model.ListArgs{})
195-
if err != nil {
196-
return errors.WithMessagef(err, "failed list dst [%s] objs", dstActualPath)
197-
}
198-
for _, obj := range dstObjs {
199-
if err := t.Ctx().Err(); err != nil {
200-
return err
201-
}
202-
if !obj.IsDir() {
203-
existedObjs[obj.GetName()] = true
196+
if err == nil {
197+
for _, obj := range dstObjs {
198+
if err := t.Ctx().Err(); err != nil {
199+
return err
200+
}
201+
if !obj.IsDir() {
202+
existedObjs[obj.GetName()] = true
203+
}
204204
}
205205
}
206206
}

0 commit comments

Comments
 (0)