add MountConfig FuseType

mount_config.go

@@ -169,6 +169,11 @@ type MountConfig struct {
 	// default name involving the string 'osxfuse' is used.
 	VolumeName string
 
+	// OS X only.
+	//
+	// FuseType choice FUSE impl By OsxFuse/Fuse-T,default is OsxFuse
+	FuseType FuseType
+
 	// Additional key=value options to pass unadulterated to the underlying mount
 	// command. See `man 8 mount`, the fuse documentation, etc. for
 	// system-specific information.
@@ -187,6 +192,13 @@ type MountConfig struct {
 	EnableAsyncReads bool
 }
 
+type FuseType uint8
+
+const (
+	FuseTypeOsxFuse = iota + 1
+	FuseTypeFuseT
+)
+
 // Create a map containing all of the key=value mount options to be given to
 // the mount helper.
 func (c *MountConfig) toMap() (opts map[string]string) {

mount_darwin.go

@@ -381,10 +381,13 @@ func startFuseTServer(binary string, argv []string,
 }
 
 func mountFuset(
-	bin string,
 	dir string,
 	cfg *MountConfig,
 	ready chan<- error) (dev *os.File, err error) {
+	fuseTBin, err := fusetBinary()
+	if err != nil {
+		return nil, err
+	}
 
 	fusekernel.IsPlatformFuseT = true
 	env := []string{}
@@ -403,7 +406,7 @@ func mountFuset(
 	env = append(env, "_FUSE_COMMVERS=2")
 	argv = append(argv, dir)
 
-	return startFuseTServer(bin, argv, env, false, cfg.DebugLogger, ready)
+	return startFuseTServer(fuseTBin, argv, env, false, cfg.DebugLogger, ready)
 }
 
 func mount(
@@ -412,8 +415,12 @@ func mount(
 	ready chan<- error) (dev *os.File, err error) {
 
 	fusekernel.IsPlatformFuseT = false
-	if fuset_bin, err := fusetBinary(); err == nil {
-		return mountFuset(fuset_bin, dir, cfg, ready)
+	switch cfg.FuseType {
+	case FuseTypeFuseT:
+		dev, err = mountFuset(dir, cfg, ready)
+	case FuseTypeOsxFuse:
+	default:
+		dev, err = mountOsxFuse(dir, cfg, ready)
 	}
-	return mountOsxFuse(dir, cfg, ready)
+	return
 }