aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBen Johnson <benbjohnson@yahoo.com>2017-01-31 07:53:51 -0700
committerBen Johnson <benbjohnson@yahoo.com>2017-01-31 07:53:51 -0700
commit82ecdfe9ef1584f4e25e491188d8b302cc8e2d76 (patch)
tree4f9c4486e1fb31ceea335d15aa3bda4e99155021
parentMerge pull request #651 from zweizeichen/master (diff)
downloaddedo-82ecdfe9ef1584f4e25e491188d8b302cc8e2d76.tar.gz
dedo-82ecdfe9ef1584f4e25e491188d8b302cc8e2d76.tar.xz
Revert "replace unix implementation to be the same as solaris to fix an issue with glusterfs"
This reverts commit ca9f2088aab4fc9832e587655f0026875bddbf9b.
-rw-r--r--bolt_unix.go24
1 files changed, 7 insertions, 17 deletions
diff --git a/bolt_unix.go b/bolt_unix.go
index 50cbbc0..cad62dd 100644
--- a/bolt_unix.go
+++ b/bolt_unix.go
@@ -21,21 +21,16 @@ func flock(db *DB, mode os.FileMode, exclusive bool, timeout time.Duration) erro
} else if timeout > 0 && time.Since(t) > timeout {
return ErrTimeout
}
- var lock syscall.Flock_t
- lock.Start = 0
- lock.Len = 0
- lock.Pid = 0
- lock.Whence = 0
- lock.Pid = 0
+ flag := syscall.LOCK_SH
if exclusive {
- lock.Type = syscall.F_WRLCK
- } else {
- lock.Type = syscall.F_RDLCK
+ flag = syscall.LOCK_EX
}
- err := syscall.FcntlFlock(db.file.Fd(), syscall.F_SETLK, &lock)
+
+ // Otherwise attempt to obtain an exclusive lock.
+ err := syscall.Flock(int(db.file.Fd()), flag|syscall.LOCK_NB)
if err == nil {
return nil
- } else if err != syscall.EAGAIN {
+ } else if err != syscall.EWOULDBLOCK {
return err
}
@@ -46,12 +41,7 @@ func flock(db *DB, mode os.FileMode, exclusive bool, timeout time.Duration) erro
// funlock releases an advisory lock on a file descriptor.
func funlock(db *DB) error {
- var lock syscall.Flock_t
- lock.Start = 0
- lock.Len = 0
- lock.Type = syscall.F_UNLCK
- lock.Whence = 0
- return syscall.FcntlFlock(uintptr(db.file.Fd()), syscall.F_SETLK, &lock)
+ return syscall.Flock(int(db.file.Fd()), syscall.LOCK_UN)
}
// mmap memory maps a DB's data file.