Skip to content

Commit

Permalink
converge: fixes in svg after upgrade
Browse files Browse the repository at this point in the history
Signed-off-by: Leela Venkaiah G <[email protected]>
  • Loading branch information
leelavg committed Jan 24, 2025
1 parent 5a5f2f7 commit d93255c
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 7 deletions.
6 changes: 0 additions & 6 deletions controllers/ocsinitialization/ocsinitialization_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -501,11 +501,6 @@ func (r *OCSInitializationReconciler) getCsiTolerations(csiTolerationKey string)
// When any value in the configmap is updated, the rook-ceph-operator pod is restarted to pick up the new values.
func (r *OCSInitializationReconciler) ensureOcsOperatorConfigExists(initialData *ocsv1.OCSInitialization) error {

<<<<<<< HEAD
allowConsumers := slices.ContainsFunc(r.clusters.GetInternalStorageClusters(), func(sc ocsv1.StorageCluster) bool {
return sc.Spec.AllowRemoteStorageConsumers
})

enableCephfsVal, err := r.getEnableCephfsKeyValue()
if err != nil {
r.Log.Error(err, "Failed to get enableCephfsKeyValue")
Expand All @@ -519,7 +514,6 @@ func (r *OCSInitializationReconciler) ensureOcsOperatorConfigExists(initialData
util.TopologyDomainLabelsKey: r.getTopologyDomainLabelsKeyValue(),
util.EnableNFSKey: r.getEnableNFSKeyValue(),
util.EnableCephfsKey: enableCephfsVal,
util.DisableCSIDriverKey: strconv.FormatBool(allowConsumers),
util.DisableCSIDriverKey: strconv.FormatBool(true),
}

Expand Down
5 changes: 5 additions & 0 deletions controllers/storageconsumer/storageconsumer_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -469,6 +469,11 @@ func (r *StorageConsumerReconciler) reconcileCephFilesystemSubVolumeGroup() erro
}
// we are not tracking the data pool as it was same in both internal and provider mode
r.cephFilesystemSubVolumeGroup.Spec.FilesystemName = cephFs.Name
if existingSvgName != "" {
r.cephFilesystemSubVolumeGroup.Spec.Name = existingSvgName
} else {
r.cephFilesystemSubVolumeGroup.Spec.Name = r.cephFilesystemSubVolumeGroup.Name
}
return nil
}); err != nil {
return err
Expand Down
2 changes: 1 addition & 1 deletion services/provider/server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -696,7 +696,7 @@ func (s *OCSProviderServer) getExternalResources(ctx context.Context, consumerRe
internalMappingRequired = true
} else {
clientProfile.Spec.CephFs = &csiopv1a1.CephFsConfigSpec{
SubVolumeGroup: svg.Name,
SubVolumeGroup: svg.Spec.Name,
KernelMountOptions: kernelMountOptions,
}
vscName = storageCluster.Name
Expand Down

0 comments on commit d93255c

Please sign in to comment.