skip invalid mountpoints on unpublish request

woehrl01 · woehrl01 · commit a4031a971c84 · 2024-03-03T22:53:23.000+01:00
diff --git a/cmd/plugin/node_server.go b/cmd/plugin/node_server.go
@@ -191,6 +191,11 @@ func (n NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpubl
 	}
 
 	mnt, err := n.k8smounter.IsMountPoint(req.TargetPath)
+	if !mnt || !os.IsNotExist(err) {
+		klog.Warningf("mount cleanup skipped: %s is not a mount point", req.TargetPath)
+		return &csi.NodeUnpublishVolumeResponse{}, nil
+	}
+
 	if err != nil || !mnt {
 		return &csi.NodeUnpublishVolumeResponse{}, err
 	}

Original file line number	Diff line number	Diff line change
`@@ -191,6 +191,11 @@ func (n NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpubl`
`191`	`191`	`}`
`192`	`192`
`193`	`193`	`mnt, err := n.k8smounter.IsMountPoint(req.TargetPath)`
	`194`	`+ if !mnt \|\| !os.IsNotExist(err) {`
	`195`	`+ klog.Warningf("mount cleanup skipped: %s is not a mount point", req.TargetPath)`
	`196`	`+ return &csi.NodeUnpublishVolumeResponse{}, nil`
	`197`	`+ }`
	`198`	`+`
`194`	`199`	`if err != nil \|\| !mnt {`
`195`	`200`	`return &csi.NodeUnpublishVolumeResponse{}, err`
`196`	`201`	`}`