diff options
Diffstat (limited to 'locker_unix.go')
| -rw-r--r-- | locker_unix.go | 30 |
1 files changed, 30 insertions, 0 deletions
diff --git a/locker_unix.go b/locker_unix.go new file mode 100644 index 0000000..8d08751 --- /dev/null +++ b/locker_unix.go @@ -0,0 +1,30 @@ +//go:build !windows +// +build !windows + +package fqueue + +import "golang.org/x/sys/unix" + +func lock(fd int, wait bool) error { + lock := unix.Flock_t{ + Type: unix.F_WRLCK, // эксклюзивная блокировка записи + Whence: 0, // SEEK_SET + Start: 0, + Len: 0, // блокируем весь файл + } + cmd := unix.F_SETLK + if wait { + cmd = unix.F_SETLKW // блокирующий вызов + } + return unix.FcntlFlock(uintptr(fd), cmd, &lock) +} + +func unlock(fd int) error { + lock := unix.Flock_t{ + Type: unix.F_UNLCK, + Whence: 0, + Start: 0, + Len: 0, + } + return unix.FcntlFlock(uintptr(fd), unix.F_SETLK, &lock) +} |
