1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
#include <stdbool.h>
#include <sched.h>
#include <threads.h>
#include <emscripten/threading.h>
#include "syscall.h"
#include "threading_internal.h"
static _Atomic pthread_t crashed_thread_id = NULL;
void _emscripten_thread_crashed() {
crashed_thread_id = pthread_self();
}
static void dummy(double now)
{
}
weak_alias(dummy, _emscripten_check_timers);
void _emscripten_yield(double now) {
int is_runtime_thread = emscripten_is_main_runtime_thread();
// When a secondary thread crashes, we need to be able to interrupt the main
// thread even if it's in a blocking/looping on a mutex. We want to avoid
// using the normal proxying mechanism to send this message since it can
// allocate (or otherwise itself crash) so use a low level atomic primitive
// for this signal.
if (is_runtime_thread) {
if (crashed_thread_id) {
// Mark the crashed thread as strongly referenced so that Node.js doesn't
// exit while the pthread is propagating the uncaught exception back to
// the main thread.
_emscripten_thread_set_strongref(crashed_thread_id);
// Return the event loop so we can handle the message from the crashed
// thread.
emscripten_exit_with_live_runtime();
}
// This is no-op in programs that don't include use of itimer/alarm.
_emscripten_check_timers(now);
// Assist other threads by executing proxied operations that are effectively
// singlethreaded.
emscripten_main_thread_process_queued_calls();
}
#ifdef EMSCRIPTEN_DYNAMIC_LINKING
else {
_emscripten_process_dlopen_queue();
}
#endif
}
|
