data mover ms new controller

Signed-off-by: Lyndon-Li <[email protected]>
vmware-tanzu · Aug 1, 2024 · 903458b · 903458b
1 parent 514ba56
commit 903458b
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 6 deletions.
diff --git a/changelogs/unreleased/8074-Lyndon-Li b/changelogs/unreleased/8074-Lyndon-Li
@@ -0,0 +1 @@
+Data mover micro service DUCR/DDCR controller refactor according to design #7576
diff --git a/pkg/controller/data_download_controller.go b/pkg/controller/data_download_controller.go
@@ -349,7 +349,9 @@ func (r *DataDownloadReconciler) runCancelableDataPath(ctx context.Context, asyn
 }
 
 func (r *DataDownloadReconciler) OnDataDownloadCompleted(ctx context.Context, namespace string, ddName string, result datapath.Result) {
-	defer r.closeDataPath(ctx, ddName)
+	defer func() {
+		go r.closeDataPath(ctx, ddName)
+	}()
 
 	log := r.logger.WithField("datadownload", ddName)
 	log.Info("Async fs restore data path completed")
@@ -382,7 +384,9 @@ func (r *DataDownloadReconciler) OnDataDownloadCompleted(ctx context.Context, na
 }
 
 func (r *DataDownloadReconciler) OnDataDownloadFailed(ctx context.Context, namespace string, ddName string, err error) {
-	defer r.closeDataPath(ctx, ddName)
+	defer func() {
+		go r.closeDataPath(ctx, ddName)
+	}()
 
 	log := r.logger.WithField("datadownload", ddName)
 
@@ -399,7 +403,9 @@ func (r *DataDownloadReconciler) OnDataDownloadFailed(ctx context.Context, names
 }
 
 func (r *DataDownloadReconciler) OnDataDownloadCancelled(ctx context.Context, namespace string, ddName string) {
-	defer r.closeDataPath(ctx, ddName)
+	defer func() {
+		go r.closeDataPath(ctx, ddName)
+	}()
 
 	log := r.logger.WithField("datadownload", ddName)
 

diff --git a/pkg/controller/data_upload_controller.go b/pkg/controller/data_upload_controller.go
@@ -360,7 +360,9 @@ func (r *DataUploadReconciler) runCancelableDataUpload(ctx context.Context, asyn
 }
 
 func (r *DataUploadReconciler) OnDataUploadCompleted(ctx context.Context, namespace string, duName string, result datapath.Result) {
-	defer r.closeDataPath(ctx, duName)
+	defer func() {
+		go r.closeDataPath(ctx, duName)
+	}()
 
 	log := r.logger.WithField("dataupload", duName)
 
@@ -404,7 +406,9 @@ func (r *DataUploadReconciler) OnDataUploadCompleted(ctx context.Context, namesp
 }
 
 func (r *DataUploadReconciler) OnDataUploadFailed(ctx context.Context, namespace, duName string, err error) {
-	defer r.closeDataPath(ctx, duName)
+	defer func() {
+		go r.closeDataPath(ctx, duName)
+	}()
 
 	log := r.logger.WithField("dataupload", duName)
 
@@ -421,7 +425,9 @@ func (r *DataUploadReconciler) OnDataUploadFailed(ctx context.Context, namespace
 }
 
 func (r *DataUploadReconciler) OnDataUploadCancelled(ctx context.Context, namespace string, duName string) {
-	defer r.closeDataPath(ctx, duName)
+	defer func() {
+		go r.closeDataPath(ctx, duName)
+	}()
 
 	log := r.logger.WithField("dataupload", duName)