Compiles on Darwin (does not work.)

fuse/mountstate.go

@@ -348,6 +348,7 @@ func (ms *MountState) handleRequest(req *request) {
 	ms.returnRequest(req)
 }
 
+
 func (ms *MountState) AllocOut(req *request, size uint32) []byte {
 	if cap(req.bufferPoolOutputBuf) >= int(size) {
 		req.bufferPoolOutputBuf = req.bufferPoolOutputBuf[:size]
@@ -375,29 +376,7 @@ func (ms *MountState) write(req *request) Status {
 		return OK
 	}
 
-	if req.flatDataSize() == 0 {
-		_, err := ms.mountFile.Write(header)
-		return ToStatus(err)
-	}
-
-	if req.fdData != nil {
-		if err := ms.trySplice(header, req, req.fdData); err == nil {
-			req.readResult.Done()
-			return OK
-		} else {
-			log.Println("trySplice:", err)
-			sz := req.flatDataSize()
-			buf := ms.AllocOut(req, uint32(sz))
-			req.flatData, req.status = req.fdData.Bytes(buf)
-			header = req.serializeHeader(len(req.flatData))
-		}
-	}
-
-	_, err := Writev(int(ms.mountFile.Fd()), [][]byte{header, req.flatData})
-	if req.readResult != nil {
-		req.readResult.Done()
-	}
-	return ToStatus(err)
+	return ms.systemWrite(req, header)
 }
 
 func (ms *MountState) writeInodeNotify(entry *raw.NotifyInvalInodeOut) Status {

fuse/mountstate_darwin.go

+package fuse
+
+func (ms *MountState) systemWrite(req *request, header []byte) Status {
+	if req.flatDataSize() == 0 {
+		_, err := ms.mountFile.Write(header)
+		return ToStatus(err)
+	}
+
+	if req.fdData != nil {
+		sz := req.flatDataSize()
+		buf := ms.AllocOut(req, uint32(sz))
+		req.flatData, req.status = req.fdData.Bytes(buf)
+		header = req.serializeHeader(len(req.flatData))
+	}
+
+	_, err := Writev(int(ms.mountFile.Fd()), [][]byte{header, req.flatData})
+	if req.readResult != nil {
+		req.readResult.Done()
+	}
+	return ToStatus(err)
+}

fuse/mountstate_linux.go

+package fuse
+import (
+	"log"
+)
+func (ms *MountState) systemWrite(req *request, header []byte) Status {
+	if req.flatDataSize() == 0 {
+		_, err := ms.mountFile.Write(header)
+		return ToStatus(err)
+	}
+
+	if req.fdData != nil {
+		if err := ms.trySplice(header, req, req.fdData); err == nil {
+			req.readResult.Done()
+			return OK
+		} else {
+			log.Println("trySplice:", err)
+			sz := req.flatDataSize()
+			buf := ms.AllocOut(req, uint32(sz))
+			req.flatData, req.status = req.fdData.Bytes(buf)
+			header = req.serializeHeader(len(req.flatData))
+		}
+	}
+
+	_, err := Writev(int(ms.mountFile.Fd()), [][]byte{header, req.flatData})
+	if req.readResult != nil {
+		req.readResult.Done()
+	}
+	return ToStatus(err)
+}

fuse/syscall_darwin.go

+package fuse
+
+import (
+	"bytes"
+	"os"
+	"syscall"
+	"unsafe"
+)
+
+// TODO - move these into Go's syscall package.
+
+func writev(fd int, iovecs *syscall.Iovec, cnt int) (n int, errno int) {
+	n1, _, e1 := syscall.Syscall(
+		syscall.SYS_WRITEV,
+		uintptr(fd), uintptr(unsafe.Pointer(iovecs)), uintptr(cnt))
+	return int(n1), int(e1)
+}
+
+func Writev(fd int, packet [][]byte) (n int, err error) {
+	iovecs := make([]syscall.Iovec, 0, len(packet))
+
+	for _, v := range packet {
+		if len(v) == 0 {
+			continue
+		}
+		vec := syscall.Iovec{
+			Base: &v[0],
+		}
+		vec.SetLen(len(v))
+		iovecs = append(iovecs, vec)
+	}
+
+	n, errno := writev(fd, &iovecs[0], len(iovecs))
+	if errno != 0 {
+		err = os.NewSyscallError("writev", syscall.Errno(errno))
+	}
+	return n, err
+}
+
+func getxattr(path string, attr string, dest []byte) (sz int, errno int) {
+	pathBs := syscall.StringBytePtr(path)
+	attrBs := syscall.StringBytePtr(attr)
+	size, _, errNo := syscall.Syscall6(
+		syscall.SYS_GETXATTR,
+		uintptr(unsafe.Pointer(pathBs)),
+		uintptr(unsafe.Pointer(attrBs)),
+		uintptr(unsafe.Pointer(&dest[0])),
+		uintptr(len(dest)),
+		0, 0)
+	return int(size), int(errNo)
+}
+
+func GetXAttr(path string, attr string, dest []byte) (value []byte, errno int) {
+	sz, errno := getxattr(path, attr, dest)
+
+	for sz > cap(dest) && errno == 0 {
+		dest = make([]byte, sz)
+		sz, errno = getxattr(path, attr, dest)
+	}
+
+	if errno != 0 {
+		return nil, errno
+	}
+
+	return dest[:sz], errno
+}
+
+func listxattr(path string, dest []byte) (sz int, errno int) {
+	pathbs := syscall.StringBytePtr(path)
+	var destPointer unsafe.Pointer
+	if len(dest) > 0 {
+		destPointer = unsafe.Pointer(&dest[0])
+	}
+	size, _, errNo := syscall.Syscall(
+		syscall.SYS_LISTXATTR,
+		uintptr(unsafe.Pointer(pathbs)),
+		uintptr(destPointer),
+		uintptr(len(dest)))
+
+	return int(size), int(errNo)
+}
+
+func ListXAttr(path string) (attributes []string, errno int) {
+	dest := make([]byte, 0)
+	sz, errno := listxattr(path, dest)
+	if errno != 0 {
+		return nil, errno
+	}
+
+	for sz > cap(dest) && errno == 0 {
+		dest = make([]byte, sz)
+		sz, errno = listxattr(path, dest)
+	}
+
+	// -1 to drop the final empty slice.
+	dest = dest[:sz-1]
+	attributesBytes := bytes.Split(dest, []byte{0})
+	attributes = make([]string, len(attributesBytes))
+	for i, v := range attributesBytes {
+		attributes[i] = string(v)
+	}
+	return attributes, errno
+}
+
+func Setxattr(path string, attr string, data []byte, flags int) (errno int) {
+	pathbs := syscall.StringBytePtr(path)
+	attrbs := syscall.StringBytePtr(attr)
+	_, _, errNo := syscall.Syscall6(
+		syscall.SYS_SETXATTR,
+		uintptr(unsafe.Pointer(pathbs)),
+		uintptr(unsafe.Pointer(attrbs)),
+		uintptr(unsafe.Pointer(&data[0])),
+		uintptr(len(data)),
+		uintptr(flags), 0)
+
+	return int(errNo)
+}
+
+func Removexattr(path string, attr string) (errno int) {
+	pathbs := syscall.StringBytePtr(path)
+	attrbs := syscall.StringBytePtr(attr)
+	_, _, errNo := syscall.Syscall(
+		syscall.SYS_REMOVEXATTR,
+		uintptr(unsafe.Pointer(pathbs)),
+		uintptr(unsafe.Pointer(attrbs)), 0)
+	return int(errNo)
+}
+
+func ioctl(fd int, cmd int, arg uintptr) (int, int) {
+	r0, _, e1 := syscall.Syscall(
+		syscall.SYS_IOCTL, uintptr(fd), uintptr(cmd), uintptr(arg))
+	val := int(r0)
+	errno := int(e1)
+	return val, errno
+}