Standardize on time.Time for all times in the API

fuse/api.go

@@ -78,7 +78,7 @@ type FsNode interface {
 	Chmod(file File, perms uint32, context *Context) (code Status)
 	Chown(file File, uid uint32, gid uint32, context *Context) (code Status)
 	Truncate(file File, size uint64, context *Context) (code Status)
-	Utimens(file File, atime int64, mtime int64, context *Context) (code Status)
+	Utimens(file File, atime *time.Time, mtime *time.Time, context *Context) (code Status)
 
 	StatFs() *StatfsOut
 }
@@ -105,7 +105,7 @@ type FileSystem interface {
 	// These should update the file's ctime too.
 	Chmod(name string, mode uint32, context *Context) (code Status)
 	Chown(name string, uid uint32, gid uint32, context *Context) (code Status)
-	Utimens(name string, AtimeNs int64, MtimeNs int64, context *Context) (code Status)
+	Utimens(name string, Atime *time.Time, Mtime *time.Time, context *Context) (code Status)
 
 	Truncate(name string, size uint64, context *Context) (code Status)
 
@@ -179,7 +179,7 @@ type File interface {
 	GetAttr(out *Attr) Status
 	Chown(uid uint32, gid uint32) Status
 	Chmod(perms uint32) Status
-	Utimens(atimeNs int64, mtimeNs int64) Status
+	Utimens(atime *time.Time, mtime *time.Time) Status
 }
 
 // The result of Read is an array of bytes, but for performance

fuse/attr.go

@@ -71,48 +71,18 @@ func (a *Attr) IsSymlink() bool { return (uint32(a.Mode) & syscall.S_IFMT) == sy
 // IsSocket reports whether the FileInfo describes a socket.
 func (a *Attr) IsSocket() bool { return (uint32(a.Mode) & syscall.S_IFMT) == syscall.S_IFSOCK }
 
-func (a *Attr) Atimens() int64 {
-	return int64(1e9*a.Atime) + int64(a.Atimensec)
-}
-
-func (a *Attr) Mtimens() int64 {
-	return int64(1e9*a.Mtime) + int64(a.Mtimensec)
-}
-
-func (a *Attr) Ctimens() int64 {
-	return int64(1e9*a.Ctime) + int64(a.Ctimensec)
-}
-
-func (a *Attr) SetNs(atimens int64, mtimens int64, ctimens int64) {
-	if atimens >= 0 {
-		a.Atime = uint64(atimens / 1e9)
-		a.Atimensec = uint32(atimens % 1e9)
-	}
-	if mtimens >= 0 {
-		a.Mtime = uint64(mtimens / 1e9)
-		a.Mtimensec = uint32(mtimens % 1e9)
-	}
-	if atimens >= 0 {
-		a.Ctime = uint64(ctimens / 1e9)
-		a.Ctimensec = uint32(ctimens % 1e9)
-	}
-}
-
 func (a *Attr) SetTimes(access *time.Time, mod *time.Time, chstatus *time.Time) {
 	if access != nil {
-		atimens := access.UnixNano()
-		a.Atime = uint64(atimens / 1e9)
-		a.Atimensec = uint32(atimens % 1e9)
+		a.Atime = uint64(access.Unix())
+		a.Atimensec = uint32(access.Nanosecond())
 	}
 	if mod != nil {
-		mtimens := mod.UnixNano()
-		a.Mtime = uint64(mtimens / 1e9)
-		a.Mtimensec = uint32(mtimens % 1e9)
+		a.Mtime = uint64(mod.Unix())
+		a.Mtimensec = uint32(mod.Nanosecond())
 	}
 	if chstatus != nil {
-		ctimens := chstatus.UnixNano()
-		a.Ctime = uint64(ctimens / 1e9)
-		a.Ctimensec = uint32(ctimens % 1e9)
+		a.Ctime = uint64(chstatus.Unix())
+		a.Ctimensec = uint32(chstatus.Nanosecond())
 	}
 }
 

fuse/default.go

 package fuse
 
-import ()
+import (
+	"time"
+)
 
 // DefaultFileSystem
 func (fs *DefaultFileSystem) GetAttr(name string, context *Context) (*Attr, Status) {
@@ -89,7 +91,7 @@ func (fs *DefaultFileSystem) Create(name string, flags uint32, mode uint32, cont
 	return nil, ENOSYS
 }
 
-func (fs *DefaultFileSystem) Utimens(name string, AtimeNs int64, CtimeNs int64, context *Context) (code Status) {
+func (fs *DefaultFileSystem) Utimens(name string, Atime *time.Time, Mtime *time.Time, context *Context) (code Status) {
 	return ENOSYS
 }
 

fuse/defaultfile.go

@@ -2,6 +2,7 @@ package fuse
 
 import (
 	"log"
+	"time"
 
 	"github.com/hanwen/go-fuse/raw"
 )
@@ -45,7 +46,7 @@ func (f *DefaultFile) Fsync(flags int) (code Status) {
 	return ENOSYS
 }
 
-func (f *DefaultFile) Utimens(atimeNs int64, mtimeNs int64) Status {
+func (f *DefaultFile) Utimens(atime *time.Time, mtime *time.Time) Status {
 	return ENOSYS
 }
 

fuse/defaultnode.go

@@ -2,6 +2,7 @@ package fuse
 
 import (
 	"log"
+	"time"
 )
 
 var _ = log.Println
@@ -150,6 +151,6 @@ func (n *DefaultFsNode) Truncate(file File, size uint64, context *Context) (code
 	return ENOSYS
 }
 
-func (n *DefaultFsNode) Utimens(file File, atime int64, mtime int64, context *Context) (code Status) {
+func (n *DefaultFsNode) Utimens(file File, atime *time.Time, mtime *time.Time, context *Context) (code Status) {
 	return ENOSYS
 }

fuse/fsetattr_test.go

@@ -63,8 +63,8 @@ func (f *MutableDataFile) GetAttr(out *Attr) Status {
 	return OK
 }
 
-func (f *MutableDataFile) Utimens(atimeNs int64, mtimeNs int64) Status {
-	f.Attr.SetNs(atimeNs, mtimeNs, -1)
+func (f *MutableDataFile) Utimens(atime *time.Time, mtime *time.Time) Status {
+	f.Attr.SetTimes(atime, mtime, nil)
 	return OK
 }
 

fuse/fsops.go

@@ -176,19 +176,26 @@ func (c *FileSystemConnector) SetAttr(out *raw.AttrOut, header *raw.InHeader, in
 		code = node.fsInode.Truncate(f, input.Size, (*Context)(&header.Context))
 	}
 	if code.Ok() && (input.Valid&(raw.FATTR_ATIME|raw.FATTR_MTIME|raw.FATTR_ATIME_NOW|raw.FATTR_MTIME_NOW) != 0) {
-		now := int64(0)
-		if input.Valid&raw.FATTR_ATIME_NOW != 0 || input.Valid&raw.FATTR_MTIME_NOW != 0 {
-			now = time.Now().UnixNano()
-		}
+		now := time.Now()
+		var atime *time.Time
+		var mtime *time.Time
 
-		atime := int64(input.Atime*1e9) + int64(input.Atimensec)
+		if input.Valid&raw.FATTR_ATIME != 0 {
 			if input.Valid&raw.FATTR_ATIME_NOW != 0 {
-			atime = now
+				atime = &now
+			} else {
+				t := time.Unix(int64(input.Atime), int64(input.Atimensec))
+				atime = &t
+			}
 		}
 
-		mtime := int64(input.Mtime*1e9) + int64(input.Mtimensec)
+		if input.Valid&raw.FATTR_MTIME != 0 {
 			if input.Valid&raw.FATTR_MTIME_NOW != 0 {
-			mtime = now
+				mtime = &now
+			} else {
+				t := time.Unix(int64(input.Mtime), int64(input.Mtimensec))
+				mtime = &t
+			}
 		}
 
 		code = node.fsInode.Utimens(f, atime, mtime, (*Context)(&header.Context))

fuse/lockingfs.go

@@ -2,6 +2,7 @@ package fuse
 
 import (
 	"sync"
+	"time"
 
 	"github.com/hanwen/go-fuse/raw"
 )
@@ -118,9 +119,9 @@ func (fs *LockingFileSystem) Create(name string, flags uint32, mode uint32, cont
 	return fs.FileSystem.Create(name, flags, mode, context)
 }
 
-func (fs *LockingFileSystem) Utimens(name string, AtimeNs int64, CtimeNs int64, context *Context) (code Status) {
+func (fs *LockingFileSystem) Utimens(name string, Atime *time.Time, Mtime *time.Time, context *Context) (code Status) {
 	defer fs.locked()()
-	return fs.FileSystem.Utimens(name, AtimeNs, CtimeNs, context)
+	return fs.FileSystem.Utimens(name, Atime, Mtime, context)
 }
 
 func (fs *LockingFileSystem) GetXAttr(name string, attr string, context *Context) ([]byte, Status) {

fuse/loopback.go

@@ -111,8 +111,16 @@ func (fs *LoopbackFileSystem) Truncate(path string, offset uint64, context *Cont
 	return ToStatus(os.Truncate(fs.GetPath(path), int64(offset)))
 }
 
-func (fs *LoopbackFileSystem) Utimens(path string, AtimeNs int64, MtimeNs int64, context *Context) (code Status) {
-	return ToStatus(os.Chtimes(fs.GetPath(path), time.Unix(0, AtimeNs), time.Unix(0, MtimeNs)))
+func (fs *LoopbackFileSystem) Utimens(path string, Atime *time.Time, Mtime *time.Time, context *Context) (code Status) {
+	var a time.Time
+	if Atime != nil {
+		a = *Atime
+	}
+	var m time.Time
+	if Mtime != nil {
+		m = *Mtime
+	}
+	return ToStatus(os.Chtimes(fs.GetPath(path), a, m))
 }
 
 func (fs *LoopbackFileSystem) Readlink(name string, context *Context) (out string, code Status) {

fuse/memnode.go

@@ -34,8 +34,8 @@ func (fs *MemNodeFs) newNode() *memNode {
 		fs: fs,
 		id: fs.nextFree,
 	}
-	now := time.Now().UnixNano()
-	n.info.SetNs(now, now, now)
+	now := time.Now()
+	n.info.SetTimes(&now, &now, &now)
 	n.info.Mode = S_IFDIR | 0777
 	fs.nextFree++
 	fs.mutex.Unlock()
@@ -189,27 +189,31 @@ func (n *memNode) Truncate(file File, size uint64, context *Context) (code Statu
 		code = ToStatus(err)
 	}
 	if code.Ok() {
-		n.info.SetNs(-1, -1, time.Now().UnixNano())
+		now := time.Now()
+		n.info.SetTimes(nil, nil, &now)
 		// TODO - should update mtime too?
 		n.info.Size = size
 	}
 	return code
 }
 
-func (n *memNode) Utimens(file File, atime int64, mtime int64, context *Context) (code Status) {
-	n.info.SetNs(int64(atime), int64(mtime), time.Now().UnixNano())
+func (n *memNode) Utimens(file File, atime *time.Time, mtime *time.Time, context *Context) (code Status) {
+	c := time.Now()
+	n.info.SetTimes(atime, mtime, &c)
 	return OK
 }
 
 func (n *memNode) Chmod(file File, perms uint32, context *Context) (code Status) {
 	n.info.Mode = (n.info.Mode ^ 07777) | perms
-	n.info.SetNs(-1, -1, time.Now().UnixNano())
+	now := time.Now()
+	n.info.SetTimes(nil, nil, &now)
 	return OK
 }
 
 func (n *memNode) Chown(file File, uid uint32, gid uint32, context *Context) (code Status) {
 	n.info.Uid = uid
 	n.info.Gid = gid
-	n.info.SetNs(-1, -1, time.Now().UnixNano())
+	now := time.Now()
+	n.info.SetTimes(nil, nil, &now)
 	return OK
 }

fuse/pathfs.go

@@ -6,6 +6,7 @@ import (
 	"path/filepath"
 	"strings"
 	"sync"
+	"time"
 )
 
 var _ = log.Println
@@ -625,7 +626,7 @@ func (n *pathInode) Truncate(file File, size uint64, context *Context) (code Sta
 	return code
 }
 
-func (n *pathInode) Utimens(file File, atime int64, mtime int64, context *Context) (code Status) {
+func (n *pathInode) Utimens(file File, atime *time.Time, mtime *time.Time, context *Context) (code Status) {
 	files := n.inode.Files(O_ANYWRITE)
 	for _, f := range files {
 		// TODO - pass context

fuse/prefixfs.go

@@ -3,6 +3,7 @@ package fuse
 import (
 	"fmt"
 	"path/filepath"
+	"time"
 )
 
 // PrefixFileSystem adds a path prefix to incoming calls.
@@ -87,8 +88,8 @@ func (fs *PrefixFileSystem) Create(name string, flags uint32, mode uint32, conte
 	return fs.FileSystem.Create(fs.prefixed(name), flags, mode, context)
 }
 
-func (fs *PrefixFileSystem) Utimens(name string, AtimeNs int64, CtimeNs int64, context *Context) (code Status) {
-	return fs.FileSystem.Utimens(fs.prefixed(name), AtimeNs, CtimeNs, context)
+func (fs *PrefixFileSystem) Utimens(name string, Atime *time.Time, Mtime *time.Time, context *Context) (code Status) {
+	return fs.FileSystem.Utimens(fs.prefixed(name), Atime, Mtime, context)
 }
 
 func (fs *PrefixFileSystem) GetXAttr(name string, attr string, context *Context) ([]byte, Status) {

unionfs/unionfs.go

@@ -281,8 +281,9 @@ func (fs *UnionFs) Promote(name string, srcResult branchResult, context *fuse.Co
 			code = writable.Chmod(name, srcResult.attr.Mode&07777|0200, context)
 		}
 		if code.Ok() {
-			code = writable.Utimens(name, srcResult.attr.Atimens(),
-				srcResult.attr.Mtimens(), context)
+			aTime := srcResult.attr.AccessTime()
+			mTime := srcResult.attr.ModTime()
+			code = writable.Utimens(name, &aTime, &mTime, context)
 		}
 
 		files := fs.nodeFs.AllFiles(name, 0)
@@ -478,7 +479,7 @@ func (fs *UnionFs) Truncate(path string, size uint64, context *fuse.Context) (co
 	return code
 }
 
-func (fs *UnionFs) Utimens(name string, atime int64, mtime int64, context *fuse.Context) (code fuse.Status) {
+func (fs *UnionFs) Utimens(name string, atime *time.Time, mtime *time.Time, context *fuse.Context) (code fuse.Status) {
 	name = stripSlash(name)
 	r := fs.getBranch(name)
 
@@ -491,7 +492,8 @@ func (fs *UnionFs) Utimens(name string, atime int64, mtime int64, context *fuse.
 		code = fs.fileSystems[0].Utimens(name, atime, mtime, context)
 	}
 	if code.Ok() {
-		r.attr.SetNs(atime, mtime, time.Now().UnixNano())
+		now := time.Now()
+		r.attr.SetTimes(atime, mtime, &now)
 		fs.branchCache.Set(name, r)
 	}
 	return code
@@ -640,7 +642,9 @@ func (fs *UnionFs) promoteDirsTo(filename string) fuse.Status {
 			return fuse.EPERM
 		}
 
-		fs.fileSystems[0].Utimens(d, r.attr.Atimens(), r.attr.Mtimens(), nil)
+		aTime := r.attr.AccessTime()
+		mTime := r.attr.ModTime()
+		fs.fileSystems[0].Utimens(d, &aTime, &mTime, nil)
 		r.branch = 0
 		fs.branchCache.Set(d, r)
 	}