From 98e5523f2f6d36960d32041a2d5a1de96ef6e5a5 Mon Sep 17 00:00:00 2001 From: Colin Davidson Date: Thu, 29 Dec 2022 11:46:43 -0800 Subject: cover openbsd too --- src/threading.cpp | 34 ++++++++++++++++++++++++++++++++++ 1 file changed, 34 insertions(+) (limited to 'src/threading.cpp') diff --git a/src/threading.cpp b/src/threading.cpp index cefe0ce8b..c065663b2 100644 --- a/src/threading.cpp +++ b/src/threading.cpp @@ -504,6 +504,40 @@ gb_internal void tpool_wait_on_addr(Futex *addr, Footex val) { } } +#elif defined(GB_SYSTEM_OPENBSD) + +#include + +typedef std::atomic Futex; +typedef volatile int32_t Footex; + +gb_internal void tpool_wake_addr(Futex *addr) { + int ret = futex((volatile uint32_t *)addr, FUTEX_WAKE | FUTEX_PRIVATE_FLAG, 1, NULL, NULL); + if (ret == -1) { + perror("Futex wake"); + GB_PANIC("futex wake fail"); + } +} + +gb_internal void tpool_wait_on_addr(Futex *addr, Footex val) { + for (;;) { + int ret = futex((volatile uint32_t *)addr, FUTEX_WAIT | FUTEX_PRIVATE_FLAG, val, NULL, NULL); + if (ret != -1) { + if (*addr != val) { + return; + } + + } else { + if (errno == ETIMEDOUT || errno == EINTR) { + continue; + } + + perror("Futex wait"); + GB_PANIC("Failed in futex wait!\n"); + } + } +} + #elif defined(GB_SYSTEM_OSX) typedef std::atomic Futex; -- cgit v1.2.3