feat: 绑定 Atomics 全局对象方法并接入 test262

This commit is contained in:
2026-09-23 19:08:35 +00:00
parent c5589c98c2
commit a7fa12e588
9 changed files with 267 additions and 46 deletions
@@ -0,0 +1,41 @@
use std::sync::Arc;
use oxide_kernel::bind_methods;
use oxide_kernel::kernel::{KernelCore, KernelSession};
use oxide_types::object::JsObject;
use oxide_types::value::JsValue;
use crate::bindings::bind_global_value;
/// 把 Atomics 全局纯对象及其 10 个原子方法绑定到 global。
///
/// Atomics 非函数对象:原型链落 Object.prototype(`wire_builtin_world_links`),
/// `@@toStringTag` 由 `install_to_string_tags` 统一补装;此处只装方法与全局槽。
pub fn bind_atomics(core: &Arc<KernelCore>, session: &KernelSession, global: &mut JsObject) {
let atomics_ptr = session.builtin_world().atomics_object.as_ptr() as *mut JsObject;
let atomics = unsafe { &mut *atomics_ptr };
let bw = session.builtin_world();
let sf = core.perm_interner().as_ref();
let sh = core.shape_forge().as_ref();
bind_methods!(
bw,
atomics,
sf,
sh,
("load", oxide_builtins::atomics::atomics_load::<crate::vm::Vm>, 2),
("store", oxide_builtins::atomics::atomics_store::<crate::vm::Vm>, 3),
("exchange", oxide_builtins::atomics::atomics_exchange::<crate::vm::Vm>, 3),
("add", oxide_builtins::atomics::atomics_add::<crate::vm::Vm>, 3),
("sub", oxide_builtins::atomics::atomics_sub::<crate::vm::Vm>, 3),
("and", oxide_builtins::atomics::atomics_and::<crate::vm::Vm>, 3),
("or", oxide_builtins::atomics::atomics_or::<crate::vm::Vm>, 3),
("xor", oxide_builtins::atomics::atomics_xor::<crate::vm::Vm>, 3),
("compareExchange", oxide_builtins::atomics::atomics_compare_exchange::<crate::vm::Vm>, 4),
("isLockFree", oxide_builtins::atomics::atomics_is_lock_free::<crate::vm::Vm>, 1),
);
let a_val = JsValue::from_js_object(atomics_ptr);
bind_global_value(core, global, "Atomics", a_val);
}
+2 -3
View File
@@ -8,7 +8,7 @@ use oxide_types::value::JsValue;
use crate::bindings::{bind_global_value, configure_native_constructor};
const STUBS: [(&str, *const (), u8); 6] = [
const STUBS: [(&str, *const (), u8); 5] = [
("Proxy", oxide_builtins::stubs::proxy_stub::<crate::vm::Vm> as *const (), 2),
("WeakMap", oxide_builtins::stubs::weakmap_stub::<crate::vm::Vm> as *const (), 0),
("WeakSet", oxide_builtins::stubs::weakset_stub::<crate::vm::Vm> as *const (), 0),
@@ -18,10 +18,9 @@ const STUBS: [(&str, *const (), u8); 6] = [
oxide_builtins::stubs::finalization_registry_stub::<crate::vm::Vm> as *const (),
1,
),
("Atomics", oxide_builtins::stubs::atomics_stub::<crate::vm::Vm> as *const (), 0),
];
/// 把未实现内置(Proxy/WeakMap/WeakSet/WeakRef/FinalizationRegistry/Atomics)
/// 把未实现内置(Proxy/WeakMap/WeakSet/WeakRef/FinalizationRegistry)
/// 的 stub 构造器绑定到 global,并登记到 `stub_objects` 供快照跟踪。
pub fn bind_stubs(core: &Arc<KernelCore>, session: &mut KernelSession, global: &mut JsObject) {
let builtin_world = Arc::get_mut(&mut session.builtin_world)
+8 -2
View File
@@ -8,6 +8,8 @@ pub mod bind_array;
pub mod bind_array_buffer;
/// AsyncDisposableStack 构造器与原型的 native 方法绑定(含 dirty reset 同步)。
pub mod bind_async_disposable_stack;
/// Atomics 全局纯对象及其 10 个原子方法绑定。
pub mod bind_atomics;
/// BigInt 构造器与原型的 native 方法绑定。
pub mod bind_bigint;
/// Boolean 构造器与原型的 native 方法绑定。
@@ -634,7 +636,7 @@ fn install_to_string_tags(core: &Arc<KernelCore>, session: &KernelSession) {
let sh = core.shape_forge().as_ref();
let tag_id = oxide_types::private_key::WELL_KNOWN_SYMBOL_TO_STRING_TAG;
let tag_key = oxide_types::private_key::make_well_known_symbol_key(tag_id);
let cases: [(*mut JsObject, &str); 13] = [
let cases: [(*mut JsObject, &str); 14] = [
(world.map_proto.as_ptr() as *mut JsObject, "Map"),
(world.array_buffer_proto.as_ptr() as *mut JsObject, "ArrayBuffer"),
(world.shared_array_buffer_proto.as_ptr() as *mut JsObject, "SharedArrayBuffer"),
@@ -648,6 +650,7 @@ fn install_to_string_tags(core: &Arc<KernelCore>, session: &KernelSession) {
(world.math_object.as_ptr() as *mut JsObject, "Math"),
(world.json_object.as_ptr() as *mut JsObject, "JSON"),
(world.symbol_proto.as_ptr() as *mut JsObject, "Symbol"),
(world.atomics_object.as_ptr() as *mut JsObject, "Atomics"),
];
for (ptr, tag) in cases {
// SAFETY: ptr 为当前 builtin world 的内置原型,session 独占期间始终有效。
@@ -887,7 +890,6 @@ fn bind_stub_globals(core: &Arc<KernelCore>, session: &KernelSession, global: &m
oxide_builtins::stubs::finalization_registry_stub::<crate::vm::Vm> as *const (),
1,
),
("Atomics", oxide_builtins::stubs::atomics_stub::<crate::vm::Vm> as *const (), 0),
]
.into_iter()
.enumerate()
@@ -997,6 +999,7 @@ pub fn bind_global_builtin_slots(core: &Arc<KernelCore>, session: &KernelSession
("Math", JsValue::from_js_object(world.math_object.as_ptr() as *mut JsObject)),
("JSON", JsValue::from_js_object(world.json_object.as_ptr() as *mut JsObject)),
("Temporal", JsValue::from_js_object(world.temporal_object.as_ptr() as *mut JsObject)),
("Atomics", JsValue::from_js_object(world.atomics_object.as_ptr() as *mut JsObject)),
] {
bind_existing_global(core, global, name, value);
}
@@ -1188,6 +1191,9 @@ pub fn rebind_dirty_builtins(core: &Arc<KernelCore>, session: &mut KernelSession
if dirty.map_or(true, |d| d.math) {
bind_math::bind_math(core, session, global);
}
if dirty.map_or(true, |d| d.atomics) {
bind_atomics::bind_atomics(core, session, global);
}
if dirty.map_or(true, |d| d.json) {
bind_json::bind_json(core, session, global);
}
@@ -1303,20 +1303,21 @@ fn sab_full_reset_rebinds() {
assert_eq!(text, "true|true|true|true");
}
/// STUBS 表收缩钉:剩余 6 枚 stub 全局仍为 function 且 Atomics 调用仍抛
/// TypeError(占位行为未随 SAB 移出而漂移)。
/// STUBS 表收缩钉:Atomics 移出 stub 后剩 5 枚 stub 全局仍为 function;
/// Atomics 现为纯对象(typeof 'object'),对其调用抛 TypeError(非函数)。
#[test]
fn sab_stubs_shrunk_six_remain() {
fn sab_stubs_shrunk_five_remain() {
let mut vm = Vm::new();
let result = eval(
&mut vm,
"(function () { \
var names = ['Proxy', 'WeakMap', 'WeakSet', 'WeakRef', 'FinalizationRegistry', 'Atomics']; \
var names = ['Proxy', 'WeakMap', 'WeakSet', 'WeakRef', 'FinalizationRegistry']; \
for (var i = 0; i < names.length; i++) { \
if (typeof globalThis[names[i]] !== 'function') { return false; } \
} \
if (typeof globalThis.Atomics !== 'object') { return false; } \
var threw = false; \
try { Atomics.add(new SharedArrayBuffer(4), 0, 1); } catch (e) { threw = e instanceof TypeError; } \
try { globalThis.Atomics(); } catch (e) { threw = e instanceof TypeError; } \
return threw; })()",
)
.unwrap();
@@ -0,0 +1,179 @@
use std::sync::Arc;
use oxide_compiler::compiler::Compiler;
use oxide_types::value::JsValue;
use oxide_vm::vm::Vm;
fn eval(vm: &mut Vm, source: &str) -> Result<JsValue, String> {
let allocator = oxide_parser::Allocator::default();
let program = oxide_parser::parse(&allocator, source).map_err(|e| format!("Parse error: {:?}", e))?;
let module = Compiler::new().compile(&program).map_err(|e| format!("Compile error: {}", e))?;
vm.run(&Arc::new(module))
}
fn truthy(vm: &mut Vm, source: &str) {
let result = eval(vm, source).unwrap();
assert!(result.as_bool(), "expected truthy for: {}", source);
}
/// Atomics 为全局纯对象:typeof 'object'、proto 落 Object.prototype、
/// `@@toStringTag` 为 "Atomics",对其调用抛 TypeError(非函数)。
#[test]
fn atomics_is_plain_object() {
let mut vm = Vm::new();
truthy(
&mut vm,
"typeof Atomics === 'object' \
&& Object.getPrototypeOf(Atomics) === Object.prototype \
&& Atomics[Symbol.toStringTag] === 'Atomics'",
);
truthy(
&mut vm,
"(function () { \
var threw = false; \
try { Atomics(); } catch (e) { threw = e instanceof TypeError; } \
return threw; })()",
);
}
/// 方法元数据钉:name 标签与 length(语料 length 口径)。
#[test]
fn atomics_method_name_and_length() {
let mut vm = Vm::new();
truthy(
&mut vm,
"Atomics.load.name === 'load' && Atomics.load.length === 2 \
&& Atomics.store.length === 3 && Atomics.exchange.length === 3 \
&& Atomics.add.length === 3 && Atomics.compareExchange.length === 4 \
&& Atomics.isLockFree.length === 1",
);
}
/// load:读指定索引(ArrayBuffer 后接整数视图可操作,不强制共享)。
#[test]
fn atomics_load_int32() {
let mut vm = Vm::new();
truthy(
&mut vm,
"(function () { \
var ta = new Int32Array(new ArrayBuffer(16)); \
ta[2] = 0x01008081; \
return Atomics.load(ta, 2) === 0x01008081 && Atomics.load(ta, 0) === 0; })()",
);
}
/// store:写入后读回返回(宽度归一,语料同值原样返回)。
#[test]
fn atomics_store_returns_stored_value() {
let mut vm = Vm::new();
truthy(
&mut vm,
"(function () { \
var ta = new Int32Array(new ArrayBuffer(16)); \
var v = Atomics.store(ta, 1, 0x01008081); \
return v === 0x01008081 && ta[1] === 0x01008081; })()",
);
}
/// exchange:返回旧值、写入新值。
#[test]
fn atomics_exchange_returns_old_value() {
let mut vm = Vm::new();
truthy(
&mut vm,
"(function () { \
var ta = new Int32Array(new ArrayBuffer(16)); \
ta[0] = 7; \
var old = Atomics.exchange(ta, 0, 42); \
return old === 7 && ta[0] === 42; })()",
);
}
/// add/sub:返回旧值、写入结果(有符号域)。
#[test]
fn atomics_add_sub_return_old() {
let mut vm = Vm::new();
truthy(
&mut vm,
"(function () { \
var ta = new Int32Array(new ArrayBuffer(16)); \
ta[0] = 10; \
var r1 = Atomics.add(ta, 0, 5); var a1 = ta[0]; \
var r2 = Atomics.sub(ta, 0, 3); var a2 = ta[0]; \
return r1 === 10 && a1 === 15 && r2 === 15 && a2 === 12; })()",
);
}
/// and/or/xor:返回旧值、按位运算写入。
#[test]
fn atomics_and_or_xor_return_old() {
let mut vm = Vm::new();
truthy(
&mut vm,
"(function () { \
var ta = new Uint8Array(new ArrayBuffer(16)); \
ta[0] = 0b11001100; \
var r1 = Atomics.and(ta, 0, 0b10101010); var a1 = ta[0]; \
var r2 = Atomics.or(ta, 0, 0b00000001); var a2 = ta[0]; \
var r3 = Atomics.xor(ta, 0, 0b00000110); var a3 = ta[0]; \
return r1 === 0b11001100 && a1 === 0b10001000 \
&& r2 === 0b10001000 && a2 === 0b10001001 \
&& r3 === 0b10001001 && a3 === 0b10001111; })()",
);
}
/// compareExchange:相等才写替换值,恒返回旧值。
#[test]
fn atomics_compare_exchange_semantics() {
let mut vm = Vm::new();
truthy(
&mut vm,
"(function () { \
var ta = new Int32Array(new ArrayBuffer(16)); \
ta[0] = 5; \
var no = Atomics.compareExchange(ta, 0, 9, 100); var b0 = ta[0]; \
var yes = Atomics.compareExchange(ta, 0, 5, 100); var b1 = ta[0]; \
return no === 5 && b0 === 5 && yes === 5 && b1 === 100; })()",
);
}
/// BigInt64 宽度:BigInt 域运算、返回旧值。
#[test]
fn atomics_bigint64_load_add() {
let mut vm = Vm::new();
truthy(
&mut vm,
"(function () { \
var ta = new BigInt64Array(new ArrayBuffer(32)); \
ta[0] = 10n; \
var r = Atomics.add(ta, 0, 5n); \
return Atomics.load(ta, 0) === 15n && r === 10n; })()",
);
}
/// isLockFree:1/2/4/8 真、余假。
#[test]
fn atomics_is_lock_free_values() {
let mut vm = Vm::new();
truthy(
&mut vm,
"Atomics.isLockFree(1) === true && Atomics.isLockFree(2) === true \
&& Atomics.isLockFree(4) === true && Atomics.isLockFree(8) === true \
&& Atomics.isLockFree(0) === false && Atomics.isLockFree(3) === false \
&& Atomics.isLockFree(16) === false",
);
}
/// 非整数宽度视图(Float32/Float64/Uint8Clamped)抛 TypeError。
#[test]
fn atomics_rejects_non_integer_views() {
let mut vm = Vm::new();
truthy(
&mut vm,
"(function () { \
function throws(fn) { try { fn(); return false; } catch (e) { return e instanceof TypeError; } } \
return throws(function () { Atomics.load(new Float32Array(new ArrayBuffer(4)), 0); }) \
&& throws(function () { Atomics.store(new Float64Array(new ArrayBuffer(8)), 0, 1); }) \
&& throws(function () { Atomics.load(new Uint8ClampedArray(new ArrayBuffer(4)), 0); }); })()",
);
}