X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/dc2bf5c81e26595f336b4fee9cbb3f138ed76d31..cd00c7d65d724ea78fe6e59dda333241a7c0775a:/services/keepstore/volume_unix.go diff --git a/services/keepstore/volume_unix.go b/services/keepstore/volume_unix.go index 0cebe43695..4db2a53384 100644 --- a/services/keepstore/volume_unix.go +++ b/services/keepstore/volume_unix.go @@ -103,13 +103,25 @@ func (v *UnixVolume) Touch(loc string) error { if err != nil { return err } - lockfile(f) + defer f.Close() + if e := lockfile(f); e != nil { + return e + } defer unlockfile(f) now := time.Now().Unix() utime := syscall.Utimbuf{now, now} return syscall.Utime(p, &utime) } +func (v *UnixVolume) Mtime(loc string) (time.Time, error) { + p := v.blockPath(loc) + if fi, err := os.Stat(p); err != nil { + return time.Time{}, err + } else { + return fi.ModTime(), nil + } +} + // Read retrieves a block identified by the locator string "loc", and // returns its contents as a byte slice. // @@ -248,7 +260,10 @@ func (v *UnixVolume) Delete(loc string) error { if err != nil { return err } - lockfile(f) + defer f.Close() + if e := lockfile(f); e != nil { + return e + } defer unlockfile(f) // If the block has been PUT more recently than -permission_ttl,