Add comments to updatingUFSWithMountCommand in pkg/ddc/alluxio/ufs_internal.go

Author: Sixth-deed

pkg/ddc/alluxio/ufs_internal.go

@@ -187,7 +187,23 @@ func (e *AlluxioEngine) processUpdatingUFS(ufsToUpdate *utils.UFSToUpdate) (upda
 
 	return
 }
-
+// updatingUFSWithMountCommand updates the Alluxio UFS mount points based on the differences identified in ufsToUpdate.
+// It performs mount operations for new UFS paths specified in ufsToUpdate.ToAdd() and unmount operations for paths
+// listed in ufsToUpdate.ToRemove(). The function skips mount points using Fluid native schemes as they are not editable.
+// For each mount to be added, it merges dataset-level SharedOptions with mount-specific Options, then applies
+// encryption configurations from both SharedEncryptOptions and mount-level EncryptOptions (with latter taking precedence
+// on key conflicts). The function first verifies that the Alluxio master is ready before executing any mount/unmount
+// commands via AlluxioFileUtils.
+//
+// Parameters:
+//   - dataset: the Dataset custom resource containing mount specifications and configuration options
+//   - ufsToUpdate: a utility struct holding lists of UFS paths to add or remove
+//
+// Returns:
+//   - updateReady: true if all mount/unmount operations completed successfully, false otherwise
+//   - err: any error encountered during readiness check, option processing, or mount/unmount execution
+//
+// Note: Mount operations are idempotent; however, concurrent modifications to the same Alluxio path may cause conflicts.
 func (e *AlluxioEngine) updatingUFSWithMountCommand(dataset *datav1alpha1.Dataset, ufsToUpdate *utils.UFSToUpdate) (updateReady bool, err error) {
 
 	podName, containerName := e.getMasterPodInfo()