mirror of
https://github.com/denoland/deno.git
synced 2024-12-26 00:59:24 -05:00
11b1e901ad
Adds support for passing and returning structs as buffers to FFI. This does not implement fastapi support for structs. Needed for certain system APIs such as AppKit on macOS.
246 lines
6.5 KiB
Rust
246 lines
6.5 KiB
Rust
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
|
|
|
|
use std::process::Command;
|
|
use test_util::deno_cmd;
|
|
|
|
#[cfg(debug_assertions)]
|
|
const BUILD_VARIANT: &str = "debug";
|
|
|
|
#[cfg(not(debug_assertions))]
|
|
const BUILD_VARIANT: &str = "release";
|
|
|
|
fn build() {
|
|
let mut build_plugin_base = Command::new("cargo");
|
|
let mut build_plugin =
|
|
build_plugin_base.arg("build").arg("-p").arg("test_ffi");
|
|
if BUILD_VARIANT == "release" {
|
|
build_plugin = build_plugin.arg("--release");
|
|
}
|
|
let build_plugin_output = build_plugin.output().unwrap();
|
|
assert!(build_plugin_output.status.success());
|
|
}
|
|
|
|
#[test]
|
|
fn basic() {
|
|
build();
|
|
|
|
let output = deno_cmd()
|
|
.arg("run")
|
|
.arg("--allow-ffi")
|
|
.arg("--allow-read")
|
|
.arg("--unstable")
|
|
.arg("--quiet")
|
|
.arg(r#"--v8-flags=--allow-natives-syntax"#)
|
|
.arg("tests/test.js")
|
|
.env("NO_COLOR", "1")
|
|
.output()
|
|
.unwrap();
|
|
let stdout = std::str::from_utf8(&output.stdout).unwrap();
|
|
let stderr = std::str::from_utf8(&output.stderr).unwrap();
|
|
if !output.status.success() {
|
|
println!("stdout {}", stdout);
|
|
println!("stderr {}", stderr);
|
|
}
|
|
println!("{:?}", output.status);
|
|
assert!(output.status.success());
|
|
let expected = "\
|
|
something\n\
|
|
[1, 2, 3, 4, 5, 6, 7, 8]\n\
|
|
[4, 5, 6]\n\
|
|
[1, 2, 3, 4, 5, 6, 7, 8] [9, 10]\n\
|
|
[1, 2, 3, 4, 5, 6, 7, 8]\n\
|
|
[ 1, 2, 3, 4, 5, 6 ]\n\
|
|
[ 4, 5, 6 ]\n\
|
|
[ 4, 5, 6 ]\n\
|
|
Hello from pointer!\n\
|
|
pointer!\n\
|
|
false\n\
|
|
true\n\
|
|
false\n\
|
|
true\n\
|
|
false\n\
|
|
579\n\
|
|
true\n\
|
|
579\n\
|
|
579\n\
|
|
5\n\
|
|
5\n\
|
|
579\n\
|
|
8589934590\n\
|
|
-8589934590\n\
|
|
8589934590\n\
|
|
-8589934590\n\
|
|
9007199254740992n\n\
|
|
9007199254740992n\n\
|
|
-9007199254740992n\n\
|
|
9007199254740992n\n\
|
|
9007199254740992n\n\
|
|
-9007199254740992n\n\
|
|
579.9119873046875\n\
|
|
579.912\n\
|
|
true\n\
|
|
false\n\
|
|
579.9119873046875\n\
|
|
579.9119873046875\n\
|
|
579.912\n\
|
|
579.912\n\
|
|
579\n\
|
|
8589934590\n\
|
|
-8589934590\n\
|
|
8589934590\n\
|
|
-8589934590\n\
|
|
9007199254740992n\n\
|
|
9007199254740992n\n\
|
|
-9007199254740992n\n\
|
|
9007199254740992n\n\
|
|
9007199254740992n\n\
|
|
-9007199254740992n\n\
|
|
579.9119873046875\n\
|
|
579.912\n\
|
|
After sleep_blocking\n\
|
|
true\n\
|
|
Before\n\
|
|
true\n\
|
|
After\n\
|
|
true\n\
|
|
logCallback\n\
|
|
1 -1 2 -2 3 -3 4 -4 0.5 -0.5 1 2 3 4 5 6 7 8\n\
|
|
u8: 8\n\
|
|
buf: [1, 2, 3, 4, 5, 6, 7, 8]\n\
|
|
logCallback\n\
|
|
30\n\
|
|
255 65535 4294967295 4294967296 123.456 789.876 -1 -2 -3 -4 -1000 1000 12345.67891 12345.679 12345.67891 12345.679 12345.67891 12345.679 12345.67891\n\
|
|
255 65535 4294967295 4294967296 123.456 789.876 -1 -2 -3 -4 -1000 1000 12345.67891 12345.679 12345.67891 12345.679 12345.67891 12345.679 12345.67891\n\
|
|
0\n\
|
|
0\n\
|
|
0\n\
|
|
0\n\
|
|
78\n\
|
|
78\n\
|
|
STORED_FUNCTION cleared\n\
|
|
STORED_FUNCTION_2 cleared\n\
|
|
Thread safe call counter: 0\n\
|
|
logCallback\n\
|
|
Thread safe call counter: 1\n\
|
|
u8: 8\n\
|
|
Static u32: 42\n\
|
|
Static i64: -1242464576485\n\
|
|
Static ptr: true\n\
|
|
Static ptr value: 42\n\
|
|
Rect { x: 10.0, y: 20.0, w: 100.0, h: 200.0 }\n\
|
|
Rect { x: 10.0, y: 20.0, w: 100.0, h: 200.0 }\n\
|
|
Rect { x: 20.0, y: 20.0, w: 100.0, h: 200.0 }\n\
|
|
Mixed { u8: 3, f32: 12.515, rect: Rect { x: 10.0, y: 20.0, w: 100.0, h: 200.0 }, usize: 12456789, array: [8, 32] }\n\
|
|
arrayBuffer.byteLength: 4\n\
|
|
uint32Array.length: 1\n\
|
|
uint32Array[0]: 42\n\
|
|
uint32Array[0] after mutation: 55\n\
|
|
Static ptr value after mutation: 55\n\
|
|
2264956937\n\
|
|
2264956937\n\
|
|
Correct number of resources\n";
|
|
assert_eq!(stdout, expected);
|
|
assert_eq!(stderr, "");
|
|
}
|
|
|
|
#[test]
|
|
fn symbol_types() {
|
|
build();
|
|
|
|
let output = deno_cmd()
|
|
.arg("check")
|
|
.arg("--unstable")
|
|
.arg("--quiet")
|
|
.arg("tests/ffi_types.ts")
|
|
.env("NO_COLOR", "1")
|
|
.output()
|
|
.unwrap();
|
|
let stdout = std::str::from_utf8(&output.stdout).unwrap();
|
|
let stderr = std::str::from_utf8(&output.stderr).unwrap();
|
|
if !output.status.success() {
|
|
println!("stdout {}", stdout);
|
|
println!("stderr {}", stderr);
|
|
}
|
|
println!("{:?}", output.status);
|
|
assert!(output.status.success());
|
|
assert_eq!(stderr, "");
|
|
}
|
|
|
|
#[test]
|
|
fn thread_safe_callback() {
|
|
build();
|
|
|
|
let output = deno_cmd()
|
|
.arg("run")
|
|
.arg("--allow-ffi")
|
|
.arg("--allow-read")
|
|
.arg("--unstable")
|
|
.arg("--quiet")
|
|
.arg("tests/thread_safe_test.js")
|
|
.env("NO_COLOR", "1")
|
|
.output()
|
|
.unwrap();
|
|
let stdout = std::str::from_utf8(&output.stdout).unwrap();
|
|
let stderr = std::str::from_utf8(&output.stderr).unwrap();
|
|
if !output.status.success() {
|
|
println!("stdout {}", stdout);
|
|
println!("stderr {}", stderr);
|
|
}
|
|
println!("{:?}", output.status);
|
|
assert!(output.status.success());
|
|
let expected = "\
|
|
Callback on main thread\n\
|
|
Callback on worker thread\n\
|
|
Calling callback, isolate should stay asleep until callback is called\n\
|
|
Callback being called\n\
|
|
Isolate should now exit\n";
|
|
assert_eq!(stdout, expected);
|
|
assert_eq!(stderr, "");
|
|
}
|
|
|
|
#[test]
|
|
fn event_loop_integration() {
|
|
build();
|
|
|
|
let output = deno_cmd()
|
|
.arg("run")
|
|
.arg("--allow-ffi")
|
|
.arg("--allow-read")
|
|
.arg("--unstable")
|
|
.arg("--quiet")
|
|
.arg("tests/event_loop_integration.ts")
|
|
.env("NO_COLOR", "1")
|
|
.output()
|
|
.unwrap();
|
|
let stdout = std::str::from_utf8(&output.stdout).unwrap();
|
|
let stderr = std::str::from_utf8(&output.stderr).unwrap();
|
|
if !output.status.success() {
|
|
println!("stdout {}", stdout);
|
|
println!("stderr {}", stderr);
|
|
}
|
|
println!("{:?}", output.status);
|
|
assert!(output.status.success());
|
|
// TODO(aapoalas): The order of logging in thread safe callbacks is
|
|
// unexpected: The callback logs synchronously and creates an asynchronous
|
|
// logging task, which then gets called synchronously before the callback
|
|
// actually yields to the calling thread. This is in contrast to what the
|
|
// logging would look like if the call was coming from within Deno itself,
|
|
// and may lead users to unknowingly run heavy asynchronous tasks from thread
|
|
// safe callbacks synchronously.
|
|
// The fix would be to make sure microtasks are only run after the event loop
|
|
// middleware that polls them has completed its work. This just does not seem
|
|
// to work properly with Linux release builds.
|
|
let expected = "\
|
|
SYNCHRONOUS\n\
|
|
Sync\n\
|
|
STORED_FUNCTION called\n\
|
|
Async\n\
|
|
Timeout\n\
|
|
THREAD SAFE\n\
|
|
Sync\n\
|
|
Async\n\
|
|
STORED_FUNCTION called\n\
|
|
Timeout\n";
|
|
assert_eq!(stdout, expected);
|
|
assert_eq!(stderr, "");
|
|
}
|