Remove custom alarm impl in favor of lower level itimer syscalls

These alarms/signals will now fire if when waiting on a lock (i.e. they
don't depend on the event loops running).

Fixes: #12415

Author: sbc100

src/library.js

@@ -2264,14 +2264,38 @@ mergeInto(LibraryManager.library, {
     return 0;
   },
 
-  // http://pubs.opengroup.org/onlinepubs/000095399/functions/alarm.html
-  alarm__deps: ['raise', '$callUserCallback'],
-  alarm: function(seconds) {
-    setTimeout(function() {
-      callUserCallback(function() {
-        _raise({{{ cDefine('SIGALRM') }}});
-      });
-    }, seconds*1000);
+  $timers: {},
+
+  // Helper function for setitimer that registers timers with the eventloop.
+  // Timers always fire on the main thread, either directly from JS (here) or
+  // or when the main thread is busy waiting calling _emscripten_yield.
+  _setitimer_js__sig: 'iid',
+  _setitimer_js__proxy: 'sync',
+  _setitimer_js__deps: ['$timers', '$callUserCallback',
+                        '_emscripten_timeout', 'emscripten_get_now'],
+  _setitimer_js: function(which, timeout_ms) {
+#if RUNTIME_DEBUG
+    dbg('setitimer_js ' + which + ' timeout=' + timeout_ms);
+#endif
+    if (timers[which]) {
+      clearTimeout(timers[which].id);
+      delete timers[which];
+    }
+
+    if (timeout_ms) {
+      var id = setTimeout(() => {
+#if ASSERTIONS
+        assert(which in timers);
+#endif
+        delete timers[which];
+#if RUNTIME_DEBUG
+        dbg('itimer fired: ' + which);
+#endif
+        callUserCallback(() => __emscripten_timeout(which, _emscripten_get_now()));
+      }, timeout_ms);
+      timers[which] = { id: id, timeout_ms: timeout_ms };
+    }
+    return 0;
   },
 
   // Helper for raise() to avoid signature mismatch failures:

src/shell.js

@@ -318,6 +318,10 @@ if (ENVIRONMENT_IS_SHELL) {
     setTimeout(() => onload(readBinary(f)), 0);
   };
 
+  if (typeof clearTimeout == 'undefined') {
+    globalThis.clearTimeout = (id) => {};
+  }
+
   if (typeof scriptArgs != 'undefined') {
     arguments_ = scriptArgs;
   } else if (typeof arguments != 'undefined') {

system/include/emscripten/threading.h

@@ -289,8 +289,6 @@ void emscripten_check_blocking_allowed(void);
 // Experimental API for syncing loaded code between pthreads.
 void _emscripten_thread_sync_code();
 
-void _emscripten_yield();
-
 #ifdef __cplusplus
 }
 #endif

system/lib/libc/emscripten_syscall_stubs.c

@@ -254,8 +254,6 @@ UNIMPLEMENTED(pipe2, (intptr_t fds, int flags))
 UNIMPLEMENTED(pselect6, (int nfds, intptr_t readfds, intptr_t writefds, intptr_t exceptfds, intptr_t timeout, intptr_t sigmaks))
 UNIMPLEMENTED(recvmmsg, (int sockfd, intptr_t msgvec, size_t vlen, int flags, ...))
 UNIMPLEMENTED(sendmmsg, (int sockfd, intptr_t msgvec, size_t vlen, int flags, ...))
-UNIMPLEMENTED(setitimer, (int which, intptr_t new_value, intptr_t old_value))
-UNIMPLEMENTED(getitimer, (int which, intptr_t old_value))
 UNIMPLEMENTED(shutdown, (int sockfd, int how, int dummy, int dummy2, int dummy3, int dummy4))
 UNIMPLEMENTED(socketpair, (int domain, int type, int protocol, intptr_t fds, int dummy, int dummy2))
 UNIMPLEMENTED(wait4,(int pid, intptr_t wstatus, int options, int rusage))

system/lib/libc/musl/arch/emscripten/bits/syscall.h

@@ -20,8 +20,6 @@
 #define SYS_fchmod		 __syscall_fchmod
 #define SYS_getpriority	 __syscall_getpriority
 #define SYS_setpriority	 __syscall_setpriority
-#define SYS_setitimer		__syscall_setitimer
-#define SYS_getitimer		__syscall_getitimer
 #define SYS_wait4		__syscall_wait4
 #define SYS_setdomainname	__syscall_setdomainname
 #define SYS_uname		__syscall_uname

system/lib/libc/musl/arch/emscripten/syscall_arch.h

@@ -38,8 +38,6 @@ int __syscall_fchmod(int fd, int mode);
 int __syscall_getpriority(int which, int who);
 int __syscall_setpriority(int which, int who, int prio);
 int __syscall_socketcall(int call, intptr_t args);
-int __syscall_setitimer(int which, intptr_t new_value, intptr_t old_value);
-int __syscall_getitimer(int which, intptr_t  old_value);
 int __syscall_wait4(int pid, intptr_t wstatus, int options, int rusage);
 int __syscall_setdomainname(intptr_t name, size_t size);
 int __syscall_uname(intptr_t buf);

system/lib/libc/musl/src/sched/sched_yield.c

@@ -2,7 +2,9 @@
 #include "syscall.h"
 
 #if __EMSCRIPTEN__
+#include <emscripten/emscripten.h>
 #include <emscripten/threading.h>
+#include "threading_internal.h"
 #endif
 
 int sched_yield()
@@ -11,7 +13,7 @@ int sched_yield()
 	// SharedArrayBuffer and wasm threads do not support explicit yielding.
 	// For now we at least call `emscripten_yield` which processes the event queue
 	// (along with other essential tasks).
-	_emscripten_yield();
+	_emscripten_yield(emscripten_get_now());
 	return 0;
 #else
 	return syscall(SYS_sched_yield);

system/lib/libc/musl/src/signal/getitimer.c

@@ -1,8 +1,18 @@
 #include <sys/time.h>
 #include "syscall.h"
 
+#ifdef __EMSCRIPTEN__
+#include <emscripten/emscripten.h>
+void __getitimer(int which, struct itimerval *old, double now);
+#endif
+
 int getitimer(int which, struct itimerval *old)
 {
+#ifdef __EMSCRIPTEN__
+	if (which > ITIMER_PROF) return EINVAL;
+	__getitimer(which, old, emscripten_get_now());
+	return 0;
+#else
 	if (sizeof(time_t) > sizeof(long)) {
 		long old32[4];
 		int r = __syscall(SYS_getitimer, which, old32);
@@ -15,4 +25,5 @@ int getitimer(int which, struct itimerval *old)
 		return __syscall_ret(r);
 	}
 	return syscall(SYS_getitimer, which, old);
+#endif
 }

system/lib/libc/musl/src/signal/setitimer.c

@@ -4,8 +4,72 @@
 
 #define IS32BIT(x) !((x)+0x80000000ULL>>32)
 
+#ifdef __EMSCRIPTEN__
+#include <signal.h>
+#include <stdio.h>
+#include <emscripten/emscripten.h>
+static double _emscripten_timers[3];
+static double _emscripten_intervals[3];
+
+#define MAX(a,b) ((a)>(b)?(a):(b))
+
+int _setitimer_js(int which, double timeout);
+
+void __getitimer(int which, struct itimerval *old, double now)
+{
+	double remaining_ms = MAX(_emscripten_timers[which] - now, 0);
+	old->it_value.tv_sec = remaining_ms / 1000;
+	old->it_value.tv_usec = remaining_ms * 1000;
+	old->it_interval.tv_sec = _emscripten_intervals[which] / 1000;
+	old->it_interval.tv_usec = _emscripten_intervals[which] * 1000;
+}
+
+void _emscripten_timeout(int which, double now)
+{
+	int signum = SIGALRM;
+	if (which == ITIMER_PROF) {
+		signum = SIGPROF;
+	} else if (which == ITIMER_VIRTUAL) {
+		signum = SIGVTALRM;
+	}
+	int next_timeout = _emscripten_intervals[which];
+	if (next_timeout) {
+		_emscripten_timers[which] = now + next_timeout;
+	} else {
+		_emscripten_timers[which] = 0;
+	}
+	_setitimer_js(which, next_timeout);
+	raise(signum);
+}
+
+void _emscripten_check_timers(double now)
+{
+	if (!now) now = emscripten_get_now();
+	for (int which = 0; which < 3; which++) {
+		if (_emscripten_timers[which] && now >= _emscripten_timers[which]) {
+			_emscripten_timeout(which, now);
+		}
+	}
+}
+#endif
+
 int setitimer(int which, const struct itimerval *restrict new, struct itimerval *restrict old)
 {
+#ifdef __EMSCRIPTEN__
+	if (which > ITIMER_PROF) return EINVAL;
+	double now = emscripten_get_now();
+	if (old) {
+		__getitimer(which, old, now);
+	}
+	if (new->it_value.tv_sec || new->it_value.tv_usec) {
+		_emscripten_timers[which] = now + new->it_value.tv_sec * 1000 + new->it_value.tv_usec / 1000;
+		_emscripten_intervals[which] = new->it_interval.tv_sec * 1000 + new->it_interval.tv_usec / 1000;
+	} else {
+		_emscripten_timers[which] = 0;
+		_emscripten_intervals[which] = 0;
+	}
+	return _setitimer_js(which, new->it_value.tv_sec * 1000 + new->it_value.tv_usec / 1000);
+#else
 	if (sizeof(time_t) > sizeof(long)) {
 		time_t is = new->it_interval.tv_sec, vs = new->it_value.tv_sec;
 		long ius = new->it_interval.tv_usec, vus = new->it_value.tv_usec;
@@ -23,4 +87,5 @@ int setitimer(int which, const struct itimerval *restrict new, struct itimerval
 		return __syscall_ret(r);
 	}
 	return syscall(SYS_setitimer, which, new, old);
+#endif
 }

system/lib/pthread/emscripten_futex_wait.c

@@ -64,7 +64,7 @@ static int futex_wait_main_browser_thread(volatile void* addr,
       // We were told to stop waiting, so stop.
       break;
     }
-    _emscripten_yield();
+    _emscripten_yield(now);
 
     // Check the value, as if we were starting the futex all over again.
     // This handles the following case:
@@ -116,7 +116,7 @@ int emscripten_futex_wait(volatile void *addr, uint32_t val, double max_wait_ms)
     return -EINVAL;
   }
 
-  _emscripten_yield();
+  _emscripten_yield(0);
 
   int ret;
   emscripten_conditional_set_current_thread_status(EM_THREAD_STATUS_RUNNING, EM_THREAD_STATUS_WAITFUTEX);