feat: created code in ReconcileVolumeNodeAccess.

added EnableCustomExportPolicySettings where needed

Author: nikos445

core/concurrent_core.go

@@ -1596,6 +1596,9 @@ func (o *ConcurrentTridentOrchestrator) updateBackendVolumes(ctx context.Context
 
 		// Update volume cache on backend.
 		backend.Volumes().Store(vol.Config.Name, vol)
+
+		// Update volume based access policy when backend reloads.
+		backend.ReconcileVolumeNodeAccess(ctx, vol.Config, volResult.Nodes)
 	}
 
 	// update the backend cache

storage_drivers/ontap/ontap_common.go

@@ -473,6 +473,7 @@ func ensureNodeAccessForPolicy(
 
 		// Rule does not exist, so create it
 		if !ruleFound {
+			// Create Export Rule
 			if err = clientAPI.ExportRuleCreate(ctx, policyName, desiredRule, config.NASType); err != nil {
 				// Check if error is that the export policy rule already exist error
 				if errors.IsAlreadyExistsError(err) {
@@ -628,6 +629,7 @@ func reconcileExportPolicyRules(
 		}
 		deleted++
 	}
+
 	return nil
 }
 

storage_drivers/ontap/ontap_nas.go

@@ -1726,14 +1726,45 @@ func (d *NASStorageDriver) reconcileNodeAccessForBackendPolicy(
 }
 
 func (d *NASStorageDriver) ReconcileVolumeNodeAccess(
-	ctx context.Context, _ *storage.VolumeConfig, _ []*models.Node,
+	ctx context.Context, volConfig *storage.VolumeConfig, nodes []*models.Node,
 ) error {
+
+	if !d.Config.AutoExportPolicy {
+		return nil
+	}
+
+	policyName := volConfig.ExportPolicy
+
 	fields := LogFields{
 		"Method": "ReconcileVolumeNodeAccess",
 		"Type":   "NASStorageDriver",
+		"policyName":   policyName,
+	}
+	
+	Logc(ctx).WithFields(fields).Debug(">>>>>> ReconcileVolumeNodeAccess")
+	defer Logc(ctx).Debug("<<<<<< ReconcileVolumeNodeAccess")
+
+
+	// Ensure the export policy exists. If it doesn't, create it.
+	// This also handles the case where it might have been deleted out-of-band.
+	if err := ensureExportPolicyExists(ctx, policyName, d.API); err != nil {
+		Logc(ctx).WithError(err).WithField("ExportPolicy", policyName).Error("Error ensuring export policy exists during volume node access reconciliation.")
+		return fmt.Errorf("error ensuring export policy %s exists: %v", policyName, err)
+	}
+
+	desiredRules, err := getDesiredExportPolicyRules(ctx, nodes, &d.Config)
+	if err != nil {
+		err = fmt.Errorf("unable to determine desired export policy rules; %v", err)
+		Logc(ctx).Error(err)
+		return err
+	}
+	
+	err = reconcileExportPolicyRules(ctx, policyName, desiredRules, d.API, &d.Config)
+	if err != nil {
+		err = fmt.Errorf("unabled to reconcile export policy rules; %v", err)
+		Logc(ctx).WithField("ExportPolicy", policyName).Error(err)
+		return err
 	}
-	Logd(ctx, d.Name(), d.Config.DebugTraceFlags["method"]).WithFields(fields).Trace(">>>> ReconcileVolumeNodeAccess")
-	defer Logd(ctx, d.Name(), d.Config.DebugTraceFlags["method"]).WithFields(fields).Trace("<<<< ReconcileVolumeNodeAccess")
 
 	return nil
 }