aboutsummaryrefslogtreecommitdiff
path: root/core/sync_linux.odin
diff options
context:
space:
mode:
authorgingerBill <bill@gingerbill.org>2018-05-21 20:47:52 +0100
committergingerBill <bill@gingerbill.org>2018-05-21 20:47:52 +0100
commit5b6770f3d297c0639bdbe8b1b029616c16669165 (patch)
tree79053a455efde40e77b4dc5ef1aa92f59c907523 /core/sync_linux.odin
parent718b80ba398b8980c37f79dded101bcf20d187d2 (diff)
Parse directories to be packages
Diffstat (limited to 'core/sync_linux.odin')
-rw-r--r--core/sync_linux.odin93
1 files changed, 0 insertions, 93 deletions
diff --git a/core/sync_linux.odin b/core/sync_linux.odin
deleted file mode 100644
index b77d51e0a..000000000
--- a/core/sync_linux.odin
+++ /dev/null
@@ -1,93 +0,0 @@
-import "core:atomics.odin"
-import "core:os.odin"
-
-Semaphore :: struct {
- // _handle: win32.Handle,
-}
-
-Mutex :: struct {
- _semaphore: Semaphore,
- _counter: i32,
- _owner: i32,
- _recursion: i32,
-}
-
-current_thread_id :: proc() -> i32 {
- return i32(os.current_thread_id());
-}
-
-semaphore_init :: proc(s: ^Semaphore) {
- // s._handle = win32.CreateSemaphoreA(nil, 0, 1<<31-1, nil);
-}
-
-semaphore_destroy :: proc(s: ^Semaphore) {
- // win32.CloseHandle(s._handle);
-}
-
-semaphore_post :: proc(s: ^Semaphore, count: int) {
- // win32.ReleaseSemaphore(s._handle, cast(i32)count, nil);
-}
-
-semaphore_release :: inline proc(s: ^Semaphore) {
- semaphore_post(s, 1);
-}
-
-semaphore_wait :: proc(s: ^Semaphore) {
- // win32.WaitForSingleObject(s._handle, win32.INFINITE);
-}
-
-
-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) {
- semaphore_destroy(&m._semaphore);
-}
-mutex_lock :: proc(m: ^Mutex) {
- thread_id := current_thread_id();
- if atomics.fetch_add(&m._counter, 1) > 0 {
- if thread_id != atomics.load(&m._owner) {
- semaphore_wait(&m._semaphore);
- }
- }
- atomics.store(&m._owner, thread_id);
- m._recursion += 1;
-}
-mutex_try_lock :: proc(m: ^Mutex) -> bool {
- thread_id := current_thread_id();
- if atomics.load(&m._owner) == thread_id {
- atomics.fetch_add(&m._counter, 1);
- } else {
- expected: i32 = 0;
- if atomics.load(&m._counter) != 0 {
- return false;
- }
- if atomics.compare_exchange(&m._counter, expected, 1) == 0 {
- return false;
- }
- atomics.store(&m._owner, thread_id);
- }
- m._recursion += 1;
- return true;
-}
-mutex_unlock :: proc(m: ^Mutex) {
- recursion: i32;
- thread_id := current_thread_id();
- assert(thread_id == atomics.load(&m._owner));
-
- m._recursion -= 1;
- recursion = m._recursion;
- if recursion == 0 {
- atomics.store(&m._owner, thread_id);
- }
-
- if atomics.fetch_add(&m._counter, -1) > 1 {
- if recursion == 0 {
- semaphore_release(&m._semaphore);
- }
- }
-}
-