fix local path check

kubernetes-sigs · Feb 4, 2021 · 5649fcc · 5649fcc
1 parent 6404234
commit 5649fcc
Showing 1 changed file with 6 additions and 11 deletions.
diff --git a/pkg/local/nodeutils.go b/pkg/local/nodeutils.go
@@ -68,21 +68,16 @@ func (ns *nodeServer) mountLvm(ctx context.Context, req *csi.NodePublishVolumeRe
 			return status.Error(codes.Internal, err.Error())
 		}
 	}
-	// Check target mounted
-	isMnt, err := ns.mounter.IsMounted(targetPath)
-	if err != nil {
-		if _, err := os.Stat(targetPath); os.IsNotExist(err) {
-			if err := os.MkdirAll(targetPath, 0750); err != nil {
-				log.Errorf("NodePublishVolume: volume %s mkdir target path %s with error: %s", volumeID, targetPath, err.Error())
-				return status.Error(codes.Internal, err.Error())
-			}
-			isMnt = false
-		} else {
-			log.Errorf("NodePublishVolume: check volume %s mounted with error: %v", volumeID, err)
+
+	// Check targetPath
+	if _, err := os.Stat(targetPath); os.IsNotExist(err) {
+		if err := os.MkdirAll(targetPath, 0750); err != nil {
+			log.Errorf("NodePublishVolume: volume %s mkdir target path %s with error: %s", volumeID, targetPath, err.Error())
 			return status.Error(codes.Internal, err.Error())
 		}
 	}
 
+	isMnt := utils.IsMounted(targetPath)
 	if !isMnt {
 		var options []string
 		if req.GetReadonly() {