summaryrefslogtreecommitdiff
path: root/core/isolate.rs
diff options
context:
space:
mode:
authorAndy Finch <andyfinch7@gmail.com>2020-02-09 13:54:16 -0500
committerGitHub <noreply@github.com>2020-02-09 10:54:16 -0800
commit1abd408770f6dc4205a471bb79d48b643f53074d (patch)
treeb0d3c0e40932e7885158b65aee33db7968c80db2 /core/isolate.rs
parent61c5bb86db42a2d575f51e966dbc77f711c64054 (diff)
No longer require aligned buffer for shared queue (#3935)
Fixes: #3925
Diffstat (limited to 'core/isolate.rs')
-rw-r--r--core/isolate.rs12
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++;
});