aboutsummaryrefslogtreecommitdiff
path: root/locker_unix.go
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--locker_unix.go30
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)
+}