Xfs support

src/connector/connector_utils.go

@@ -723,8 +723,11 @@ func ResizeMountPath(volumePath string) error {
 	switch fsType {
 	case "ext2", "ext3", "ext4":
 		return extResize(devicePath)
+	case "xfs":
+		return xfsResize(devicePath)
 	}
 
+
 	return fmt.Errorf("resize of format %s is not supported for device %s", fsType, devicePath)
 }
 
@@ -739,6 +742,17 @@ func extResize(devicePath string) error {
 	return nil
 }
 
+func xfsResize(devicePath string) error {
+	output, err := utils.ExecShellCmd("xfs_growfs %s", devicePath)
+	if err != nil {
+		log.Errorf("xfs Resize %s error: %s", devicePath, output)
+		return err
+	}
+
+	log.Infof("xfs Resize success for device path : %v", devicePath)
+	return nil
+}
+
 func findMultiPathWWN(mPath string) (string, error) {
 	output, err := utils.ExecShellCmd("multipathd show maps")
 	if err != nil {

src/connector/nfs/nfs_helper.go

@@ -245,18 +245,22 @@ func getFSType(sourcePath string) (string, error) {
 
 func formatDisk(sourcePath, fsType, diskSizeType string) error {
 	var cmd string
-	switch diskSizeType {
-	case "default":
-		cmd = fmt.Sprintf("mkfs -t %s -F %s", fsType, sourcePath)
-	case "big":
-		cmd = fmt.Sprintf("mkfs -t %s -T big -F %s", fsType, sourcePath)
-	case "huge":
-		cmd = fmt.Sprintf("mkfs -t %s -T huge -F %s", fsType, sourcePath)
-	case "large":
-		cmd = fmt.Sprintf("mkfs -t %s -T largefile -F %s", fsType, sourcePath)
-	case "veryLarge":
-		cmd = fmt.Sprintf("mkfs -t %s -T largefile4 -F %s", fsType, sourcePath)
-	}
+	switch fsType {
+	case "xfs":
+		cmd = fmt.Sprintf("mkfs.xfs -f %s", sourcePath)
+        default:
+		switch diskSizeType {
+		case "default":
+			cmd = fmt.Sprintf("mkfs -t %s -F %s", fsType, sourcePath)
+		case "big":
+			cmd = fmt.Sprintf("mkfs -t %s -T big -F %s", fsType, sourcePath)
+		case "huge":
+			cmd = fmt.Sprintf("mkfs -t %s -T huge -F %s", fsType, sourcePath)
+		case "large":
+			cmd = fmt.Sprintf("mkfs -t %s -T largefile -F %s", fsType, sourcePath)
+		case "veryLarge":
+			cmd = fmt.Sprintf("mkfs -t %s -T largefile4 -F %s", fsType, sourcePath)
+		}
 	output, err := utils.ExecShellCmd(cmd)
 	if err != nil {
 		if strings.Contains(output, "in use by the system") {
@@ -267,6 +271,7 @@ func formatDisk(sourcePath, fsType, diskSizeType string) error {
 		log.Errorf("Couldn't mkfs %s to %s: %s", sourcePath, fsType, output)
 		return err
 	}
+
 	return nil
 }
 

src/utils/utils.go

@@ -127,7 +127,7 @@ func execShellCmd(format string, logFilter bool, args ...interface{}) (string, b
 	execCmd := []string{"-i/proc/1/ns/ipc", "-m/proc/1/ns/mnt", "-n/proc/1/ns/net", "/bin/sh", "-c", cmd}
 	shCmd := exec.Command("nsenter", execCmd...)
 	var timeOut bool
-	if strings.Contains(cmd, "mkfs") || strings.Contains(cmd, "resize2fs") {
+	if strings.Contains(cmd, "mkfs") || strings.Contains(cmd, "resize2fs" ||  strings.Contains(cmd, "xfs_growfs" ) {
 		time.AfterFunc(longTimeout*time.Second, func() {
 			timeOut = true
 		})