fix(nas): sub directory not created when mounting cpfs with efc protocol

Author: iltyty

pkg/nas/utils.go

@@ -94,9 +94,7 @@ func doMount(mounter mountutils.Interface, opt *Options, targetPath, volumeId, p
 		}
 		mountFstype = "alinas"
 		// err = mounter.Mount(source, mountPoint, "alinas", combinedOptions)
-		isPathNotFound = func(err error) bool {
-			return strings.Contains(err.Error(), "Failed to bind mount")
-		}
+		isPathNotFound = isEFCPathNotFoundError
 	case NativeClient:
 		switch opt.FSType {
 		case "cpfs":
@@ -115,17 +113,16 @@ func doMount(mounter mountutils.Interface, opt *Options, targetPath, volumeId, p
 			// must enable tls when using accesspoint
 			combinedOptions = addTLSMountOptions(combinedOptions)
 		}
+		isPathNotFound = isNFSPathNotFoundError
 		// Enable compatibility for BMCPFS VPC mount points using the NAS Driver, to support the same usage in ECI.
 		if isCPFS(opt.FSType, opt.Server) && opt.MountProtocol == "efc" {
 			mountFstype = "alinas"
 			combinedOptions = append(combinedOptions, "efc,protocol=efc,net=tcp,fstype=cpfs")
+			isPathNotFound = isEFCPathNotFoundError
 		}
 		if mountFstype == "" {
 			mountFstype = opt.MountProtocol
 		}
-		isPathNotFound = func(err error) bool {
-			return strings.Contains(err.Error(), "reason given by server: No such file or directory") || strings.Contains(err.Error(), "access denied by server while mounting")
-		}
 	}
 	err := mounter.Mount(source, targetPath, mountFstype, combinedOptions)
 	if err == nil {
@@ -166,6 +163,23 @@ func doMount(mounter mountutils.Interface, opt *Options, targetPath, volumeId, p
 	return mounter.Mount(source, targetPath, mountFstype, combinedOptions)
 }
 
+func isEFCPathNotFoundError(err error) bool {
+	return strings.Contains(err.Error(), "Failed to bind mount")
+}
+
+func isNFSPathNotFoundError(err error) bool {
+	errors := []string{
+		"reason given by server: No such file or directory",
+		"access denied by server while mounting",
+	}
+	for _, error := range errors {
+		if strings.Contains(err.Error(), error) {
+			return true
+		}
+	}
+	return false
+}
+
 // check system config,
 // if tcp_slot_table_entries not set to 128, just config.
 func checkSystemNasConfig() error {