mirrors/velero
1
0
Fork 0
mirror of https://github.com/vmware-tanzu/velero.git synced 2026-01-07 13:55:20 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

data mover ms new controller

Browse Source 
Signed-off-by: Lyndon-Li <lyonghui@vmware.com>
This commit is contained in:
Lyndon-Li
2024-08-01 13:07:22 +08:00
parent 29aad63f32
commit 514ba56ca1
3 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/cmd/cli/datamover/restore.go
View File

@@ -198,8 +198,7 @@ func (s *dataMoverRestore) run() {
}
}()
// TODOOO: call s.runDataPath()
time.Sleep(time.Duration(1<<63 - 1))
s.runDataPath()
}
func (s *dataMoverRestore) runDataPath() {

4
pkg/controller/data_download_controller.go
View File

@@ -336,7 +336,7 @@ func (r *DataDownloadReconciler) runCancelableDataPath(ctx context.Context, asyn
return r.errorOut(ctx, dd, err, "error to initialize asyncBR", log)
}
log.Infof("async restore init for pod %s, volume %s", res.ByPod.HostingPod, res.ByPod.VolumeName)
log.Infof("async restore init for pod %s, volume %s", res.ByPod.HostingPod.Name, res.ByPod.VolumeName)
if err := asyncBR.StartRestore(dd.Spec.SnapshotID, datapath.AccessPoint{
ByPath: res.ByPod.VolumeName,
@@ -344,7 +344,7 @@ func (r *DataDownloadReconciler) runCancelableDataPath(ctx context.Context, asyn
return r.errorOut(ctx, dd, err, fmt.Sprintf("error starting async restore for pod %s, volume %s", res.ByPod.HostingPod, res.ByPod.VolumeName), log)
}
log.Info("Async restore started for pod %s, volume %s", res.ByPod.HostingPod, res.ByPod.VolumeName)
log.Infof("Async restore started for pod %s, volume %s", res.ByPod.HostingPod, res.ByPod.VolumeName)
return ctrl.Result{}, nil
}

4
pkg/controller/data_upload_controller.go
View File

@@ -347,7 +347,7 @@ func (r *DataUploadReconciler) runCancelableDataUpload(ctx context.Context, asyn
return r.errorOut(ctx, du, err, "error to initialize asyncBR", log)
}
log.Infof("async backup init for pod %s, volume %s", res.ByPod.HostingPod, res.ByPod.VolumeName)
log.Infof("async backup init for pod %s, volume %s", res.ByPod.HostingPod.Name, res.ByPod.VolumeName)
if err := asyncBR.StartBackup(datapath.AccessPoint{
ByPath: res.ByPod.VolumeName,
@@ -355,7 +355,7 @@ func (r *DataUploadReconciler) runCancelableDataUpload(ctx context.Context, asyn
return r.errorOut(ctx, du, err, fmt.Sprintf("error starting async backup for pod %s, volume %s", res.ByPod.HostingPod, res.ByPod.VolumeName), log)
}
log.Info("Async backup started for pod %s, volume %s", res.ByPod.HostingPod, res.ByPod.VolumeName)
log.Infof("Async backup started for pod %s, volume %s", res.ByPod.HostingPod, res.ByPod.VolumeName)
return ctrl.Result{}, nil
}