From 641a95063946bf7f4b8fdd1e938a917bc3f75cb2 Mon Sep 17 00:00:00 2001
From: Alexander Neonxp Kiryukhin <i@neonxp.ru>
Date: Thu, 5 Feb 2026 14:35:00 +0300
Subject: initial

---
 locker_unix.go | 30 ++++++++++++++++++++++++++++++
 1 file changed, 30 insertions(+)
 create mode 100644 locker_unix.go

(limited to 'locker_unix.go')

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)
+}
-- 
cgit v1.2.3