From 66d49090d14fdaa1813da9e8ba7a2d44994e6101 Mon Sep 17 00:00:00 2001 From: morpho327 <2410653591@qq.com> Date: Tue, 26 May 2026 12:11:02 +0800 Subject: [PATCH] Add comments to UpdateOnUFSChange in pkg/ddc/alluxio/ufs.go. Signed-off-by: morpho327 <2410653591@qq.com> --- pkg/ddc/alluxio/ufs.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/pkg/ddc/alluxio/ufs.go b/pkg/ddc/alluxio/ufs.go index b2158bdc208..a22b3ab4650 100644 --- a/pkg/ddc/alluxio/ufs.go +++ b/pkg/ddc/alluxio/ufs.go @@ -134,6 +134,16 @@ func (e *AlluxioEngine) ShouldUpdateUFS() (ufsToUpdate *utils.UFSToUpdate) { return } +// UpdateOnUFSChange handles the updates when the Underlying File System (UFS) changes. +// It checks if an update is required, sets the dataset status to Updating, and processes +// the added or removed mount points for the Alluxio engine. +// +// Parameters: +// - ufsToUpdate (*utils.UFSToUpdate): The object containing information about which UFS paths need to be updated. +// +// Returns: +// - updateReady (bool): Returns true when the update process has completed. +// - err (error): Returns an error if the status update or UFS processing fails, otherwise returns nil. func (e *AlluxioEngine) UpdateOnUFSChange(ufsToUpdate *utils.UFSToUpdate) (updateReady bool, err error) { // 1. check if need to update ufs if !ufsToUpdate.ShouldUpdate() {