diff options
author | Andy Finch <andyfinch7@gmail.com> | 2020-02-09 13:54:16 -0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-02-09 10:54:16 -0800 |
commit | 1abd408770f6dc4205a471bb79d48b643f53074d (patch) | |
tree | b0d3c0e40932e7885158b65aee33db7968c80db2 /core/isolate.rs | |
parent | 61c5bb86db42a2d575f51e966dbc77f711c64054 (diff) |
No longer require aligned buffer for shared queue (#3935)
Fixes: #3925
Diffstat (limited to 'core/isolate.rs')
-rw-r--r-- | core/isolate.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/core/isolate.rs b/core/isolate.rs index 55ba52d5c..3892d6d75 100644 --- a/core/isolate.rs +++ b/core/isolate.rs @@ -781,7 +781,7 @@ pub mod tests { Mode::Async => { assert_eq!(control.len(), 1); assert_eq!(control[0], 42); - let buf = vec![43u8, 0, 0, 0].into_boxed_slice(); + let buf = vec![43u8].into_boxed_slice(); Op::Async(futures::future::ok(buf).boxed()) } Mode::AsyncUnref => { @@ -790,14 +790,14 @@ pub mod tests { let fut = async { // This future never finish. futures::future::pending::<()>().await; - let buf = vec![43u8, 0, 0, 0].into_boxed_slice(); + let buf = vec![43u8].into_boxed_slice(); Ok(buf) }; Op::AsyncUnref(fut.boxed()) } Mode::OverflowReqSync => { assert_eq!(control.len(), 100 * 1024 * 1024); - let buf = vec![43u8, 0, 0, 0].into_boxed_slice(); + let buf = vec![43u8].into_boxed_slice(); Op::Sync(buf) } Mode::OverflowResSync => { @@ -811,7 +811,7 @@ pub mod tests { } Mode::OverflowReqAsync => { assert_eq!(control.len(), 100 * 1024 * 1024); - let buf = vec![43u8, 0, 0, 0].into_boxed_slice(); + let buf = vec![43u8].into_boxed_slice(); Op::Async(futures::future::ok(buf).boxed()) } Mode::OverflowResAsync => { @@ -1007,7 +1007,7 @@ pub mod tests { let control = new Uint8Array(100 * 1024 * 1024); let response = Deno.core.dispatch(1, control); assert(response instanceof Uint8Array); - assert(response.length == 4); + assert(response.length == 1); assert(response[0] == 43); assert(asyncRecv == 0); "#, @@ -1046,7 +1046,7 @@ pub mod tests { r#" let asyncRecv = 0; Deno.core.setAsyncHandler(1, (buf) => { - assert(buf.byteLength === 4); + assert(buf.byteLength === 1); assert(buf[0] === 43); asyncRecv++; }); |