summaryrefslogtreecommitdiff
path: root/core/shared_queue.js
diff options
context:
space:
mode:
Diffstat (limited to 'core/shared_queue.js')
-rw-r--r--core/shared_queue.js17
1 files changed, 2 insertions, 15 deletions
diff --git a/core/shared_queue.js b/core/shared_queue.js
index b413f011e..75f370ce4 100644
--- a/core/shared_queue.js
+++ b/core/shared_queue.js
@@ -151,27 +151,14 @@ SharedQueue Binary Layout
function handleAsyncMsgFromRust(buf) {
if (buf) {
- handleAsyncMsgFromRustInner(buf);
+ asyncHandler(buf);
} else {
while ((buf = shift()) != null) {
- handleAsyncMsgFromRustInner(buf);
+ asyncHandler(buf);
}
}
}
- function handleAsyncMsgFromRustInner(buf) {
- // DataView to extract cmdId value.
- const dataView = new DataView(buf.buffer, buf.byteOffset, 4);
- const promiseId = dataView.getInt32(0);
- // Uint8 buffer view shifted right and shortened 4 bytes to remove cmdId from view window.
- const bufViewFinal = new Uint8Array(
- buf.buffer,
- buf.byteOffset + 4,
- buf.byteLength - 4
- );
- asyncHandler(promiseId, bufViewFinal);
- }
-
function dispatch(control, zeroCopy = null) {
maybeInit();
// First try to push control to shared.