Added fuse.Mount

fuse/Makefile

@@ -4,6 +4,7 @@ include $(GOROOT)/src/Make.$(GOARCH)
 TARG=github.com/krasin/go-fuse-zip/fuse
 
 GOFILES=\
+	fuse.go\
 	types.go\
 
 include $(GOROOT)/src/Make.pkg

fuse/fuse.go

+package fuse
+
+// Written with a look to http://ptspts.blogspot.com/2009/11/fuse-protocol-tutorial-for-linux-26.html
+
+import (
+	"fmt"
+	"net"
+	"os"
+	"path"
+)
+
+type FileSystem interface {
+}
+
+type MountPoint struct {
+	mountPoint string
+}
+
+// Mount create a fuse fs on the specified mount point.
+func Mount(mountPoint string, fs FileSystem) (m *MountPoint, err os.Error) {
+	local, remote, err := net.Socketpair("unixgram")
+	if err != nil {
+		return
+	}
+	defer local.Close()
+	defer remote.Close()
+
+	mountPoint = path.Clean(mountPoint)
+	if !path.Rooted(mountPoint) {
+		cwd, err := os.Getwd()
+		if err != nil {
+			return
+		}
+		mountPoint = path.Clean(path.Join(cwd, mountPoint))
+	}
+	pid, err := os.ForkExec("/bin/fusermount",
+			[]string { "/bin/fusermount", mountPoint },
+			[]string { "_FUSE_COMMFD=3" },
+			"",
+			[]*os.File { nil, nil, os.Stderr, remote.File() })
+	if err != nil {
+		return
+	}
+	w, err := os.Wait(pid, 0)
+	if err != nil {
+		return
+	}
+	if w.ExitStatus() != 0 {
+		return nil, os.NewError(fmt.Sprintf("fusermount exited with code %d\n", w.ExitStatus()))
+	}
+	m = &MountPoint { mountPoint }
+	return
+}
+
+func (m *MountPoint) Unmount() (err os.Error) {
+	pid, err := os.ForkExec("/bin/fusermount",
+			[]string { "/bin/fusermount", "-u", "m", m.mountPoint },
+			nil,
+			"",
+			[]*os.File { nil, nil, os.Stderr })
+	if err != nil {
+		return
+	}
+	w, err := os.Wait(pid, 0)
+	if err != nil {
+		return
+	}
+	if w.ExitStatus() != 0 {
+		return os.NewError(fmt.Sprintf("fusermount exited with code %d\n", w.ExitStatus()))
+	}
+	return
+}
+