// Copyright (c) 2012, Suryandaru Triandana // All rights reserved. // // Use of this source code is governed by a BSD-style license that can be // found in the LICENSE file. package storage import ( "os" "path/filepath" ) type plan9FileLock struct { f *os.File } func (fl *plan9FileLock) release() error { return fl.f.Close() } func newFileLock(path string) (fl fileLock, err error) { f, err := os.OpenFile(path, os.O_RDWR|os.O_CREATE, os.ModeExclusive|0644) if err != nil { return } fl = &plan9FileLock{f: f} return } func rename(oldpath, newpath string) error { if _, err := os.Stat(newpath); err == nil { if err := os.Remove(newpath); err != nil { return err } } _, fname := filepath.Split(newpath) return os.Rename(oldpath, fname) } func syncDir(name string) error { f, err := os.Open(name) if err != nil { return err } defer f.Close() if err := f.Sync(); err != nil { return err } return nil }