Method SetRetry

internal/fs/put.go:53–59

(retry int, maxRetry int)

}

func (t *UploadTask) SetRetry(retry int, maxRetry int) {
	t.TaskExtension.SetRetry(retry, maxRetry)
	if retry == 0 &&
		(t.GetErr() == nil && t.GetState() != tache.StatePending) { // 手动重试
		task_group.TransferCoordinator.AddTask(stdpath.Join(t.storage.GetStorage().MountPath, t.dstDirActualPath), nil)
	}
}

var UploadTaskManager *tache.Manager[*UploadTask]