feat: stop carina controller from trying to expand/delete volume on a…

… node removed from the cluster

Signed-off-by: Hao Fan <[email protected]>

pkg/csidriver/driver/k8s/logicvolume_service.go

@@ -24,6 +24,7 @@ import (
 
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"
+	corev1 "k8s.io/api/core/v1"
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/api/resource"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -249,6 +250,10 @@ func (s *LogicVolumeService) DeleteVolume(ctx context.Context, volumeID string)
 		return err
 	}
 
+	if !lv.GetDeletionTimestamp().IsZero() {
+		return errors.New("lv is being deleted")
+	}
+
 	err = s.Delete(ctx, lv)
 	if err != nil {
 		if apierrors.IsNotFound(err) {
@@ -257,6 +262,13 @@ func (s *LogicVolumeService) DeleteVolume(ctx context.Context, volumeID string)
 		return err
 	}
 
+	// if the node doesn't exist, return directly
+	existingNode := new(corev1.Node)
+	err = s.getter.Get(ctx, client.ObjectKey{Name: lv.Spec.NodeName}, existingNode)
+	if err != nil {
+		return err
+	}
+
 	// wait until delete the target volume
 	for {
 		log.Info("waiting for delete LogicalVolume name ", lv.Name)
@@ -286,6 +298,13 @@ func (s *LogicVolumeService) ExpandVolume(ctx context.Context, volumeID string,
 		return err
 	}
 
+	// if the node doesn't exist, return directly
+	existingNode := new(corev1.Node)
+	err = s.getter.Get(ctx, client.ObjectKey{Name: lv.Spec.NodeName}, existingNode)
+	if err != nil {
+		return err
+	}
+
 	err = s.UpdateLogicVolumeSpecSize(ctx, volumeID, resource.NewQuantity(requestGb<<30, resource.BinarySI))
 	if err != nil {
 		return err