aboutsummaryrefslogtreecommitdiff
path: root/v_windows/v/vlib/os/filelock/lib_windows.c.v
diff options
context:
space:
mode:
authorIndrajith K L2022-12-03 17:00:20 +0530
committerIndrajith K L2022-12-03 17:00:20 +0530
commitf5c4671bfbad96bf346bd7e9a21fc4317b4959df (patch)
tree2764fc62da58f2ba8da7ed341643fc359873142f /v_windows/v/vlib/os/filelock/lib_windows.c.v
downloadcli-tools-windows-master.tar.gz
cli-tools-windows-master.tar.bz2
cli-tools-windows-master.zip
Adds most of the toolsHEADmaster
Diffstat (limited to 'v_windows/v/vlib/os/filelock/lib_windows.c.v')
-rw-r--r--v_windows/v/vlib/os/filelock/lib_windows.c.v75
1 files changed, 75 insertions, 0 deletions
diff --git a/v_windows/v/vlib/os/filelock/lib_windows.c.v b/v_windows/v/vlib/os/filelock/lib_windows.c.v
new file mode 100644
index 0000000..56cbace
--- /dev/null
+++ b/v_windows/v/vlib/os/filelock/lib_windows.c.v
@@ -0,0 +1,75 @@
+module filelock
+
+import time
+
+fn C.DeleteFileW(&u16) bool
+fn C.CreateFileW(&u16, u32, u32, voidptr, u32, u32, voidptr) voidptr
+fn C.CloseHandle(voidptr) bool
+
+pub fn (mut l FileLock) unlink() {
+ if l.fd != -1 {
+ C.CloseHandle(l.fd)
+ l.fd = -1
+ }
+ t_wide := l.name.to_wide()
+ C.DeleteFileW(t_wide)
+}
+
+pub fn (mut l FileLock) acquire() ?bool {
+ if l.fd != -1 {
+ // lock already acquired by this instance
+ return false
+ }
+ fd := open(l.name)
+ if fd == -1 {
+ return error('cannot create lock file $l.name')
+ }
+ l.fd = fd
+ return true
+}
+
+pub fn (mut l FileLock) release() bool {
+ if l.fd != -1 {
+ C.CloseHandle(l.fd)
+ l.fd = -1
+ t_wide := l.name.to_wide()
+ C.DeleteFileW(t_wide)
+ return true
+ }
+ return false
+}
+
+pub fn (mut l FileLock) wait_acquire(s int) ?bool {
+ fin := time.now().add(s)
+ for time.now() < fin {
+ if l.try_acquire() {
+ return true
+ }
+ time.sleep(1 * time.millisecond)
+ }
+ return false
+}
+
+fn open(f string) voidptr {
+ f_wide := f.to_wide()
+ // locking it
+ fd := C.CreateFileW(f_wide, C.GENERIC_READ | C.GENERIC_WRITE, 0, 0, C.OPEN_ALWAYS,
+ C.FILE_ATTRIBUTE_NORMAL, 0)
+ if fd == C.INVALID_HANDLE_VALUE {
+ fd == -1
+ }
+ return fd
+}
+
+pub fn (mut l FileLock) try_acquire() bool {
+ if l.fd != -1 {
+ // lock already acquired by this instance
+ return false
+ }
+ fd := open(l.name)
+ if fd == -1 {
+ return false
+ }
+ l.fd = fd
+ return true
+}