aboutsummaryrefslogtreecommitdiff
path: root/core/sync_windows.odin
diff options
context:
space:
mode:
authorGinger Bill <bill@gingerbill.org>2017-06-12 11:48:12 +0100
committerGinger Bill <bill@gingerbill.org>2017-06-12 11:48:12 +0100
commit8fafdb185cefee691e1c2e1990abf8cd3c97ddf4 (patch)
tree8422ecb57d2d4f830ca6b76f54f0ad1a2f19f2a7 /core/sync_windows.odin
parentc2c935ba818167a7056da5ac61687ecd2d97cc59 (diff)
Remove := with var and :: with const
Diffstat (limited to 'core/sync_windows.odin')
-rw-r--r--core/sync_windows.odin36
1 files changed, 18 insertions, 18 deletions
diff --git a/core/sync_windows.odin b/core/sync_windows.odin
index af14db159..0a53ace38 100644
--- a/core/sync_windows.odin
+++ b/core/sync_windows.odin
@@ -1,51 +1,51 @@
#import win32 "sys/windows.odin" when ODIN_OS == "windows";
#import "atomics.odin";
-Semaphore :: struct {
+const Semaphore = struct {
_handle: win32.Handle,
}
-Mutex :: struct {
+const Mutex = struct {
_semaphore: Semaphore,
_counter: i32,
_owner: i32,
_recursion: i32,
}
-current_thread_id :: proc() -> i32 {
+const current_thread_id = proc() -> i32 {
return i32(win32.get_current_thread_id());
}
-semaphore_init :: proc(s: ^Semaphore) {
+const semaphore_init = proc(s: ^Semaphore) {
s._handle = win32.create_semaphore_a(nil, 0, 1<<31-1, nil);
}
-semaphore_destroy :: proc(s: ^Semaphore) {
+const semaphore_destroy = proc(s: ^Semaphore) {
win32.close_handle(s._handle);
}
-semaphore_post :: proc(s: ^Semaphore, count: int) {
+const semaphore_post = proc(s: ^Semaphore, count: int) {
win32.release_semaphore(s._handle, i32(count), nil);
}
-semaphore_release :: proc(s: ^Semaphore) #inline { semaphore_post(s, 1); }
+const semaphore_release = proc(s: ^Semaphore) #inline { semaphore_post(s, 1); }
-semaphore_wait :: proc(s: ^Semaphore) {
+const semaphore_wait = proc(s: ^Semaphore) {
win32.wait_for_single_object(s._handle, win32.INFINITE);
}
-mutex_init :: proc(m: ^Mutex) {
+const mutex_init = proc(m: ^Mutex) {
atomics.store(&m._counter, 0);
atomics.store(&m._owner, current_thread_id());
semaphore_init(&m._semaphore);
m._recursion = 0;
}
-mutex_destroy :: proc(m: ^Mutex) {
+const mutex_destroy = proc(m: ^Mutex) {
semaphore_destroy(&m._semaphore);
}
-mutex_lock :: proc(m: ^Mutex) {
- thread_id := current_thread_id();
+const mutex_lock = proc(m: ^Mutex) {
+ var thread_id = current_thread_id();
if atomics.fetch_add(&m._counter, 1) > 0 {
if thread_id != atomics.load(&m._owner) {
semaphore_wait(&m._semaphore);
@@ -54,12 +54,12 @@ mutex_lock :: proc(m: ^Mutex) {
atomics.store(&m._owner, thread_id);
m._recursion++;
}
-mutex_try_lock :: proc(m: ^Mutex) -> bool {
- thread_id := current_thread_id();
+const mutex_try_lock = proc(m: ^Mutex) -> bool {
+ var thread_id = current_thread_id();
if atomics.load(&m._owner) == thread_id {
atomics.fetch_add(&m._counter, 1);
} else {
- expected: i32 = 0;
+ var expected: i32 = 0;
if atomics.load(&m._counter) != 0 {
return false;
}
@@ -71,9 +71,9 @@ mutex_try_lock :: proc(m: ^Mutex) -> bool {
m._recursion++;
return true;
}
-mutex_unlock :: proc(m: ^Mutex) {
- recursion: i32;
- thread_id := current_thread_id();
+const mutex_unlock = proc(m: ^Mutex) {
+ var recursion: i32;
+ var thread_id = current_thread_id();
assert(thread_id == atomics.load(&m._owner));
m._recursion--;