Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
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
33 changes: 19 additions & 14 deletions src/lib/libbrowser.js
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,10 @@

// Utilities for browser environments
var LibraryBrowser = {
$workerHandles__internal: true,
$workerHandles__deps: ['$HandleAllocator'],
$workerHandles: 'new HandleAllocator();',

$Browser__deps: [
'$callUserCallback',
'$getFullscreenElement',
Expand All @@ -24,7 +28,6 @@ var LibraryBrowser = {
isFullscreen: false,
pointerLock: false,
moduleContextCreatedCallbacks: [],
workers: [],
preloadedImages: {},
preloadedAudios: {},

Expand Down Expand Up @@ -717,20 +720,21 @@ var LibraryBrowser = {

// To avoid creating worker parent->child chains, always proxies to execute on the main thread.
emscripten_create_worker__proxy: 'sync',
emscripten_create_worker__deps: ['$UTF8ToString', 'realloc'],
emscripten_create_worker__deps: ['$UTF8ToString', 'realloc', '$workerHandles'],
emscripten_create_worker: (url) => {
url = UTF8ToString(url);
var id = Browser.workers.length;
var worker = new Worker(url);
var info = {
worker: new Worker(url),
worker,
callbacks: [],
awaited: 0,
buffer: 0,
};
info.worker.onmessage = (msg) => {
var id = workerHandles.allocate(info);
worker.onmessage = (msg) => {
if (ABORT) return;
var info = Browser.workers[id];
if (!info) return; // worker was destroyed meanwhile
if (!workerHandles.has(id)) return; // worker was destroyed meanwhile
var info = workerHandles.get(id);
var callbackId = msg.data['callbackId'];
var callbackInfo = info.callbacks[callbackId];
if (!callbackInfo) return; // no callback or callback removed meanwhile
Expand All @@ -750,23 +754,23 @@ var LibraryBrowser = {
callbackInfo.func(0, 0, callbackInfo.arg);
}
};
Browser.workers.push(info);
return id;
},

emscripten_destroy_worker__deps: ['free'],
emscripten_destroy_worker__deps: ['free', '$workerHandles'],
emscripten_destroy_worker__proxy: 'sync',
emscripten_destroy_worker: (id) => {
var info = Browser.workers[id];
var info = workerHandles.get(id);
info.worker.terminate();
_free(info.buffer);
Browser.workers[id] = null;
workerHandles.free(id);
},

emscripten_call_worker__deps: ['$workerHandles'],
emscripten_call_worker__proxy: 'sync',
emscripten_call_worker: (id, funcName, data, size, callback, arg) => {
funcName = UTF8ToString(funcName);
var info = Browser.workers[id];
var info = workerHandles.get(id);
var callbackId = -1;
if (callback) {
// If we are waiting for a response from the worker we need to keep
Expand Down Expand Up @@ -826,10 +830,11 @@ var LibraryBrowser = {
},
#endif

emscripten_get_worker_queue_size__deps: ['$workerHandles'],
emscripten_get_worker_queue_size__proxy: 'sync',
emscripten_get_worker_queue_size: (id) => {
var info = Browser.workers[id];
if (!info) return -1;
if (!workerHandles.has(id)) return -1;
var info = workerHandles.get(id);
return info.awaited;
},

Expand Down
4 changes: 2 additions & 2 deletions test/codesize/test_codesize_hello_dylink_all.json
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
{
"a.out.js": 268247,
"a.out.js": 268245,
"a.out.nodebug.wasm": 587640,
"total": 855887,
"total": 855885,
"sent": [
"IMG_Init",
"IMG_Load",
Expand Down
Loading