Bug 1943378: Fix InstanceCreate volume cleanup

Using the deferred function, this solution triggers the cleanup of the
unused root volume in all failure cases of InstanceCreate.

Author: pierreprinetti

pkg/cloud/openstack/clients/machineservice.go

@@ -462,6 +462,10 @@ func GetSecurityGroups(is *InstanceService, sg_param []openstackconfigv1.Securit
 // If ServerGroupName is nonempty and no server group exists with that name,
 // then InstanceCreate creates a server group with that name.
 func (is *InstanceService) InstanceCreate(clusterName string, name string, clusterSpec *openstackconfigv1.OpenstackClusterProviderSpec, config *openstackconfigv1.OpenstackProviderSpec, cmd string, keyName string, configClient configclient.ConfigV1Interface) (instance *Instance, err error) {
+	// This variable is used in early returns to trigger the deletion of
+	// associated resources in case of failure to create the server.
+	needsCleanup := true
+
 	if config == nil {
 		return nil, fmt.Errorf("create Options need be specified to create instace")
 	}
@@ -475,8 +479,6 @@ func (is *InstanceService) InstanceCreate(clusterName string, name string, clust
 		}
 	}
 
-	var cleanupOperationsInCaseOfServerCreationFailure []func() error
-
 	// Set default Tags
 	machineTags := []string{
 		"cluster-api-provider-openstack",
@@ -713,7 +715,7 @@ func (is *InstanceService) InstanceCreate(clusterName string, name string, clust
 			volumeName := name
 
 			// if source type is "image" then we have to create a volume from the image first
-			klog.Infof("Creating bootable volume with name %q from image %v.", volumeName, config.RootVolume.SourceUUID)
+			klog.Infof("Creating bootable volume with name %q from image %q.", volumeName, config.RootVolume.SourceUUID)
 
 			// Deleting any volumes with the same name, as they may
 			// be leftovers from a previous failed try.
@@ -750,21 +752,23 @@ func (is *InstanceService) InstanceCreate(clusterName string, name string, clust
 			if err != nil {
 				return nil, fmt.Errorf("Create bootable volume err: %v", err)
 			}
-
-			cleanupOperationsInCaseOfServerCreationFailure = append(cleanupOperationsInCaseOfServerCreationFailure, func() error {
-				return volumes.Delete(is.volumeClient, volume.ID, nil).ExtractErr()
-			})
 			volumeID = volume.ID
 
-			err = volumes.WaitForStatus(is.volumeClient, volumeID, "available", 300)
-			if err != nil {
-				klog.Infof("Bootable volume %v creation failed. Removing...", volumeID)
-				err = volumes.Delete(is.volumeClient, volumeID, volumes.DeleteOpts{}).ExtractErr()
-				if err != nil {
-					return nil, fmt.Errorf("Bootable volume deletion err: %v", err)
+			defer func() {
+				// If the server is created in Nova, the lifetime of the associated volume will be
+				// bound to it. This deferred cleanup function tackles the case where a volume was created
+				// but never attached to a server. In that case, the volume must be removed manually.
+				if needsCleanup == true {
+					if err := volumes.Delete(is.volumeClient, volumeID, nil).ExtractErr(); err != nil {
+						klog.Infof("Failed to delete stale volume %q", volumeID)
+					} else {
+						klog.Infof("Deleted stale volume %q", volumeID)
+					}
 				}
+			}()
 
-				return nil, fmt.Errorf("Bootable volume %v is not available err: %v", volumeID, err)
+			if err := volumes.WaitForStatus(is.volumeClient, volumeID, "available", 300); err != nil {
+				return nil, fmt.Errorf("bootable volume is not available: %v", err)
 			}
 
 			klog.Infof("Bootable volume %v was created successfully.", volumeID)
@@ -839,19 +843,17 @@ func (is *InstanceService) InstanceCreate(clusterName string, name string, clust
 		}
 	}
 
-	server, err := servers.Create(is.computeClient, keypairs.CreateOptsExt{
+	server, err = servers.Create(is.computeClient, keypairs.CreateOptsExt{
 		CreateOptsBuilder: serverCreateOpts,
 		KeyName:           keyName,
 	}).Extract()
 	if err != nil {
-		for _, cleanup := range cleanupOperationsInCaseOfServerCreationFailure {
-			if e := cleanup(); e != nil {
-				err = fmt.Errorf("%w. Additionally: %v", err, e)
-			}
-		}
 		return nil, err
 	}
 
+	// Disabling cleanup functions because server creation was successful.
+	needsCleanup = false
+
 	is.computeClient.Microversion = ""
 	return serverToInstance(server), nil
 }