Skip to content
Closed
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
38 commits
Select commit Hold shift + click to select a range
33b5c4a
[wasm] Bump emscripten to 3.1.34
radekdoulik Mar 27, 2023
dff44d4
Update emsdk deps
radekdoulik Mar 27, 2023
ce1a265
Update icu deps
radekdoulik Mar 27, 2023
ed96a04
Use new images
radekdoulik Mar 27, 2023
8e6a28c
Use emscripten_main_runtime_thread_id
radekdoulik Mar 27, 2023
81672f4
Ignore ExitStatus exceptions
radekdoulik Mar 28, 2023
c2cbb94
Handle UnhandledPromiseRejection for ExitStatus
radekdoulik Mar 28, 2023
f3edd6e
Merge branch 'main' into pr-wasm-emscripten-3-1-34
radekdoulik Mar 28, 2023
4c0cb9e
[wasm][threads] flip YieldFromDispatchLoop; specialize PortableThread…
lambdageek Mar 15, 2023
3d88608
[mono] Implement a LifoJSSemaphore
lambdageek Mar 20, 2023
55b4649
Make managed LowLevelJSSemaphore
lambdageek Mar 20, 2023
8c74dea
copy-paste PortableThreadPool.WorkerThread for threaded WASM
lambdageek Mar 20, 2023
b323f0e
fixup native code for lifo semaphore
lambdageek Mar 21, 2023
51b1fbf
fixup managed code for LowLevelJSSemaphore
lambdageek Mar 21, 2023
3727ff1
Implement PortableThreadPool loop using semaphore callbacks
lambdageek Mar 21, 2023
763edab
manage emscripten event loop from PortableThreadPool.WorkerThread
lambdageek Mar 22, 2023
b45d001
FIXME: thread equality assertion in timeout callback
lambdageek Mar 22, 2023
1f7620c
XXX REVERT ME - minimal async timeout test
lambdageek Mar 22, 2023
06a3cc1
BUGFIX: &wait_entry ===> wait_entry
lambdageek Mar 23, 2023
8574368
nit: log thread id as hex in .ts
lambdageek Mar 23, 2023
c86cb26
XXX minimal sample - fetch on a background thread works
lambdageek Mar 23, 2023
c3cad74
fix non-wasm non-threads builds
lambdageek Mar 24, 2023
e57b262
Add WebWorkerEventLoop internal class to managed event loop keepalive
lambdageek Mar 24, 2023
07eabcd
Start threadpool threads with keepalive checks
lambdageek Mar 24, 2023
474607e
HACK: kind of work around the emscripten_runtime_keepalive_push/pop n…
lambdageek Mar 24, 2023
9f45167
support JS Semaphore with --print-icall-table cross compiler
lambdageek Mar 27, 2023
2e1f31f
make minimal FetchBackground sample more like a unit test
lambdageek Mar 27, 2023
dacc0cb
Share PortableThreadPool.WorkerThread common code
lambdageek Mar 29, 2023
10ca330
make both kinds of lifo semaphore share a base struct
lambdageek Mar 30, 2023
f4a2c02
Unify LowLevelLifoSemaphore for normal and async waiting
lambdageek Mar 30, 2023
42388d8
WebWorkerEventLoop: remove dead code, update comments
lambdageek Mar 31, 2023
853938e
remove unused arg from async wait semaphore
lambdageek Mar 31, 2023
cb8b168
rename native semaphore to LifoSemaphoreAsyncWait
lambdageek Mar 31, 2023
3e8fee4
Rename managed file to LowLevelLifoSemaphore.AsyncWait.Browser.Thread…
lambdageek Mar 31, 2023
552f9a5
Remove unnecessary indirections and allocations from managed AsyncWai…
lambdageek Mar 31, 2023
812524f
fix non-browser+threads builds
lambdageek Mar 31, 2023
50c0f1a
Keep track of unsettled JS interop promises in threadpool workers
lambdageek Apr 3, 2023
c8afaba
change minimal sample's fetch helper to artificially delay
lambdageek Apr 3, 2023
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
remove unused arg from async wait semaphore
don't need both user data and a gchandle
  • Loading branch information
lambdageek committed Mar 31, 2023
commit 853938ebb6997f3368db5ec9761e06a9b4082482
Original file line number Diff line number Diff line change
Expand Up @@ -48,9 +48,8 @@ private void CreateAsyncJS(int maximumSignalCount)
[MethodImpl(MethodImplOptions.InternalCall)]
private static extern unsafe void PrepareAsyncWaitInternal(IntPtr semaphore,
int timeoutMs,
/*delegate* unmanaged<IntPtr, GCHandle, IntPtr, void> successCallback*/ void* successCallback,
/*delegate* unmanaged<IntPtr, GCHandle, IntPtr, void> timeoutCallback*/ void* timeoutCallback,
GCHandle handle,
/*delegate* unmanaged<IntPtr, IntPtr, void> successCallback*/ void* successCallback,
/*delegate* unmanaged<IntPtr, IntPtr, void> timeoutCallback*/ void* timeoutCallback,
IntPtr userData);

private sealed record WaitEntry (LowLevelLifoSemaphore Semaphore, Action<LowLevelLifoSemaphore, object?> OnSuccess, Action<LowLevelLifoSemaphore, object?> OnTimeout, object? State);
Expand Down Expand Up @@ -201,23 +200,25 @@ internal void PrepareAsyncWaitCore(int timeout_ms, Action<LowLevelLifoSemaphore,
WaitEntry entry = new (this, onSuccess, onTimeout, state);
GCHandle gchandle = GCHandle.Alloc (entry);
unsafe {
delegate* unmanaged<IntPtr, GCHandle, IntPtr, void> successCallback = &SuccessCallback;
delegate* unmanaged<IntPtr, GCHandle, IntPtr, void> timeoutCallback = &TimeoutCallback;
PrepareAsyncWaitInternal (lifo_semaphore, timeout_ms, successCallback, timeoutCallback, gchandle, IntPtr.Zero);
delegate* unmanaged<IntPtr, IntPtr, void> successCallback = &SuccessCallback;
delegate* unmanaged<IntPtr, IntPtr, void> timeoutCallback = &TimeoutCallback;
PrepareAsyncWaitInternal (lifo_semaphore, timeout_ms, successCallback, timeoutCallback, GCHandle.ToIntPtr(gchandle));
}
}

[UnmanagedCallersOnly]
private static void SuccessCallback(IntPtr lifo_semaphore, GCHandle gchandle, IntPtr user_data)
private static void SuccessCallback(IntPtr lifoSemaphore, IntPtr userData)
{
GCHandle gchandle = GCHandle.FromIntPtr(userData);
WaitEntry entry = (WaitEntry)gchandle.Target!;
gchandle.Free();
entry.OnSuccess(entry.Semaphore, entry.State);
}

[UnmanagedCallersOnly]
private static void TimeoutCallback(IntPtr lifo_semaphore, GCHandle gchandle, IntPtr user_data)
private static void TimeoutCallback(IntPtr lifoSemaphore, IntPtr userData)
{
GCHandle gchandle = GCHandle.FromIntPtr(userData);
WaitEntry entry = (WaitEntry)gchandle.Target!;
gchandle.Free();
entry.OnTimeout(entry.Semaphore, entry.State);
Expand Down
2 changes: 1 addition & 1 deletion src/mono/mono/metadata/icall-decl.h
Original file line number Diff line number Diff line change
Expand Up @@ -186,7 +186,7 @@ ICALL_EXPORT void ves_icall_System_Threading_LowLevelLifoSemaphore_ReleaseIn

/* include these declarations if we're in the threaded wasm runtime, or if we're building a wasm-targeting cross compiler and we need to support --print-icall-table */
#if (defined(HOST_BROWSER) && !defined(DISABLE_THREADS)) || (defined(TARGET_WASM) && defined(ENABLE_ICALL_SYMBOL_MAP))
ICALL_EXPORT void ves_icall_System_Threading_LowLevelLifoSemaphore_PrepareAsyncWaitInternal (gpointer sem_ptr, gint32 timeout_ms, gpointer success_cb, gpointer timeout_cb, gpointer gchandle, gpointer user_data);
ICALL_EXPORT void ves_icall_System_Threading_LowLevelLifoSemaphore_PrepareAsyncWaitInternal (gpointer sem_ptr, gint32 timeout_ms, gpointer success_cb, gpointer timeout_cb, intptr_t user_data);

ICALL_EXPORT void ves_icall_System_Threading_WebWorkerEventLoop_KeepalivePushInternal (void);
ICALL_EXPORT void ves_icall_System_Threading_WebWorkerEventLoop_KeepalivePopInternal (void);
Expand Down
6 changes: 3 additions & 3 deletions src/mono/mono/metadata/threads.c
Original file line number Diff line number Diff line change
Expand Up @@ -5060,11 +5060,11 @@ ves_icall_System_Threading_LowLevelLifoSemaphore_ReleaseInternal (gpointer sem_p

#if defined(HOST_BROWSER) && !defined(DISABLE_THREADS)
void
ves_icall_System_Threading_LowLevelLifoSemaphore_PrepareAsyncWaitInternal (gpointer sem_ptr, gint32 timeout_ms, gpointer success_cb, gpointer timedout_cb, gpointer gchandle, gpointer user_data)
ves_icall_System_Threading_LowLevelLifoSemaphore_PrepareAsyncWaitInternal (gpointer sem_ptr, gint32 timeout_ms, gpointer success_cb, gpointer timedout_cb, intptr_t user_data)
{
LifoJSSemaphore *sem = (LifoJSSemaphore *)sem_ptr;
g_assert (sem->base.kind == LIFO_SEMAPHORE_ASYNC_JS);
mono_lifo_js_semaphore_prepare_wait (sem, timeout_ms, (LifoJSSemaphoreCallbackFn)success_cb, (LifoJSSemaphoreCallbackFn)timedout_cb, (uint32_t)(MonoGCHandle)gchandle, user_data);
mono_lifo_js_semaphore_prepare_wait (sem, timeout_ms, (LifoJSSemaphoreCallbackFn)success_cb, (LifoJSSemaphoreCallbackFn)timedout_cb, user_data);
}

void
Expand Down Expand Up @@ -5106,7 +5106,7 @@ ves_icall_System_Threading_WebWorkerEventLoop_KeepalivePopInternal (void)
* need to be defined */
#if defined(TARGET_WASM) && defined(ENABLE_ICALL_SYMBOL_MAP)
void
ves_icall_System_Threading_LowLevelLifoSemaphore_PrepareAsyncWaitInternal (gpointer sem_ptr, gint32 timeout_ms, gpointer success_cb, gpointer timedout_cb, gpointer gchandle, gpointer user_data)
ves_icall_System_Threading_LowLevelLifoSemaphore_PrepareAsyncWaitInternal (gpointer sem_ptr, gint32 timeout_ms, gpointer success_cb, gpointer timedout_cb, intptr_t user_data)
{
g_assert_not_reached();
}
Expand Down
18 changes: 6 additions & 12 deletions src/mono/mono/utils/lifo-semaphore.c
Original file line number Diff line number Diff line change
Expand Up @@ -187,14 +187,13 @@ mono_lifo_js_semaphore_prepare_wait (LifoJSSemaphore *sem,
int32_t timeout_ms,
LifoJSSemaphoreCallbackFn success_cb,
LifoJSSemaphoreCallbackFn timeout_cb,
uint32_t gchandle,
void *user_data)
intptr_t user_data)
{
mono_coop_mutex_lock (&sem->base.mutex);
if (sem->pending_signals > 0) {
sem->pending_signals--;
mono_coop_mutex_unlock (&sem->base.mutex);
success_cb (sem, gchandle, user_data); // FIXME: queue microtask
success_cb (sem, user_data); // FIXME: queue microtask
return;
}

Expand All @@ -210,7 +209,6 @@ mono_lifo_js_semaphore_prepare_wait (LifoJSSemaphore *sem,
wait_entry->success_cb = success_cb;
wait_entry->timeout_cb = timeout_cb;
wait_entry->sem = sem;
wait_entry->gchandle = gchandle;
wait_entry->user_data = user_data;
wait_entry->thread = pthread_self();
wait_entry->state = LIFO_JS_WAITING;
Expand Down Expand Up @@ -257,8 +255,7 @@ lifo_js_wait_entry_on_timeout (void *wait_entry_as_user_data)
LifoJSSemaphore *sem = wait_entry->sem;
gboolean call_timeout_cb = FALSE;
LifoJSSemaphoreCallbackFn timeout_cb = NULL;
uint32_t gchandle = 0;
void *user_data = NULL;
intptr_t user_data = 0;
mono_coop_mutex_lock (&sem->base.mutex);
switch (wait_entry->state) {
case LIFO_JS_WAITING:
Expand All @@ -267,7 +264,6 @@ lifo_js_wait_entry_on_timeout (void *wait_entry_as_user_data)
/* unlink and free the wait entry, run the user timeout_cb. */
lifo_js_wait_entry_unlink (&sem->head, wait_entry);
timeout_cb = wait_entry->timeout_cb;
gchandle = wait_entry->gchandle;
user_data = wait_entry->user_data;
g_free (wait_entry);
call_timeout_cb = TRUE;
Expand All @@ -285,7 +281,7 @@ lifo_js_wait_entry_on_timeout (void *wait_entry_as_user_data)
}
mono_coop_mutex_unlock (&sem->base.mutex);
if (call_timeout_cb) {
timeout_cb (sem, gchandle, user_data);
timeout_cb (sem, user_data);
}
}

Expand All @@ -298,8 +294,7 @@ lifo_js_wait_entry_on_success (void *wait_entry_as_user_data)
LifoJSSemaphore *sem = wait_entry->sem;
gboolean call_success_cb = FALSE;
LifoJSSemaphoreCallbackFn success_cb = NULL;
uint32_t gchandle = 0;
void *user_data = NULL;
intptr_t user_data = 0;
mono_coop_mutex_lock (&sem->base.mutex);
switch (wait_entry->state) {
case LIFO_JS_SIGNALED:
Expand All @@ -314,7 +309,6 @@ lifo_js_wait_entry_on_success (void *wait_entry_as_user_data)
g_assert (wait_entry->refcount == 1);
lifo_js_wait_entry_unlink (&sem->head, wait_entry);
success_cb = wait_entry->success_cb;
gchandle = wait_entry->gchandle;
user_data = wait_entry->user_data;
g_free (wait_entry);
call_success_cb = TRUE;
Expand All @@ -325,7 +319,7 @@ lifo_js_wait_entry_on_success (void *wait_entry_as_user_data)
}
mono_coop_mutex_unlock (&sem->base.mutex);
g_assert (call_success_cb);
success_cb (sem, gchandle, user_data);
success_cb (sem, user_data);
}

#endif /* HOST_BROWSER && !DISABLE_THREADS */
8 changes: 3 additions & 5 deletions src/mono/mono/utils/lifo-semaphore.h
Original file line number Diff line number Diff line change
Expand Up @@ -61,17 +61,16 @@ typedef struct _LifoJSSemaphore LifoJSSemaphore;
*/
typedef struct _LifoJSSemaphoreWaitEntry LifoJSSemaphoreWaitEntry;

typedef void (*LifoJSSemaphoreCallbackFn)(LifoJSSemaphore *semaphore, uint32_t gch, void *user_data);
typedef void (*LifoJSSemaphoreCallbackFn)(LifoJSSemaphore *semaphore, intptr_t user_data);

struct _LifoJSSemaphoreWaitEntry {
LifoJSSemaphoreWaitEntry *previous;
LifoJSSemaphoreWaitEntry *next;
LifoJSSemaphoreCallbackFn success_cb;
LifoJSSemaphoreCallbackFn timeout_cb;
LifoJSSemaphore *sem;
void *user_data;
intptr_t user_data;
pthread_t thread;
uint32_t gchandle; // what do we want in here?
int32_t js_timeout_id; // only valid to access from the waiting thread
/* state and refcount are protected by the semaphore mutex */
uint16_t state; /* 0 waiting, 1 signaled, 2 signaled - timeout ignored */
Expand Down Expand Up @@ -131,8 +130,7 @@ void
mono_lifo_js_semaphore_prepare_wait (LifoJSSemaphore *semaphore, int32_t timeout_ms,
LifoJSSemaphoreCallbackFn success_cb,
LifoJSSemaphoreCallbackFn timeout_cb,
uint32_t gchandle,
void *user_data);
intptr_t user_data);

void
mono_lifo_js_semaphore_release (LifoJSSemaphore *semaphore, uint32_t count);
Expand Down