Merge pull request kosmos-io#675 from zhouhaoA1/fix_pvc_0.4.0

fix leaf pvc storage update
OrangeBao · Aug 11, 2024 · 0b5b75e · 0b5b75e
2 parents 8f4a7ae + d90b4cb
commit 0b5b75e
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/pkg/clustertree/cluster-manager/controllers/pvc/leaf_pvc_controller.go b/pkg/clustertree/cluster-manager/controllers/pvc/leaf_pvc_controller.go
@@ -104,14 +104,23 @@ func (l *LeafPVCController) Reconcile(ctx context.Context, request reconcile.Req
 		klog.Errorf("patch pvc error: %v", err)
 		return reconcile.Result{}, err
 	}
-	_, err = l.RootClientSet.CoreV1().PersistentVolumeClaims(rootPVC.Namespace).Patch(ctx,
+	updatedRootPvc, err := l.RootClientSet.CoreV1().PersistentVolumeClaims(rootPVC.Namespace).Patch(ctx,
 		rootPVC.Name, mergetypes.MergePatchType, patch, metav1.PatchOptions{})
 	if err != nil {
 		klog.Errorf("patch pvc namespace: %q, name: %q to root cluster failed, error: %v",
 			request.NamespacedName.Namespace, request.NamespacedName.Name, err)
 		return reconcile.Result{RequeueAfter: utils.DefaultRequeueTime}, nil
 	}
 
+	updatedRootPvc.Status = pvcCopy.Status
+	updatedRootPvc.ResourceVersion = "0"
+	err = l.RootClient.Status().Update(ctx, updatedRootPvc)
+	if err != nil {
+		klog.Errorf("update pvc status namespace: %q, name: %q to root cluster failed, error: %v",
+			request.NamespacedName.Namespace, request.NamespacedName.Name, err)
+		return reconcile.Result{RequeueAfter: utils.DefaultRequeueTime}, nil
+	}
+
 	return reconcile.Result{}, nil
 }
 

diff --git a/pkg/clustertree/cluster-manager/controllers/pvc/root_pvc_controller.go b/pkg/clustertree/cluster-manager/controllers/pvc/root_pvc_controller.go
@@ -80,8 +80,6 @@ func (r *RootPVCController) Reconcile(ctx context.Context, request reconcile.Req
 	if reflect.DeepEqual(pvcOld.Spec.Resources.Requests, pvc.Spec.Resources.Requests) {
 		return reconcile.Result{}, nil
 	}
-	pvcOld.Spec.Resources.Requests = pvc.Spec.Resources.Requests
-	pvc.Spec = pvcOld.Spec
 
 	pvc.Annotations = pvcOld.Annotations
 	pvc.ObjectMeta.UID = pvcOld.ObjectMeta.UID