From f704d3b273e2d1a9874397d11d7b6611667c3d5b Mon Sep 17 00:00:00 2001 From: shiyunhao <231220148@smail.nju.edu.cn> Date: Mon, 29 Jun 2026 21:21:41 +0800 Subject: [PATCH] Add comments to processUpdatingUFS in pkg/ddc/alluxio/ufs_internal.go --- pkg/ddc/alluxio/ufs_internal.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/ddc/alluxio/ufs_internal.go b/pkg/ddc/alluxio/ufs_internal.go index 69b56ee8728..0ab8a58d893 100644 --- a/pkg/ddc/alluxio/ufs_internal.go +++ b/pkg/ddc/alluxio/ufs_internal.go @@ -145,6 +145,10 @@ func (e *AlluxioEngine) FindUnmountedUFS() (unmountedPaths []string, err error) return fileUtils.FindUnmountedAlluxioPaths(alluxioPaths) } +// processUpdatingUFS updates the under file system (UFS) mount configuration for the Alluxio engine. +// It first determines the update method based on whether mount config map is enabled, +// then if the update succeeds, it resets the dataset's UfsTotal status to trigger a metadata sync, +// and finally updates the mount timestamp when new mount paths are added. func (e *AlluxioEngine) processUpdatingUFS(ufsToUpdate *utils.UFSToUpdate) (updateReady bool, err error) { dataset, err := utils.GetDataset(e.Client, e.name, e.namespace) if err != nil {