fix: 原生盒 mark 边收集去对象预过滤——盒内字符串/BigInt 边并入 live 标记闭合 sweep 悬垂

This commit is contained in:
2026-09-12 18:10:03 +00:00
parent e368751f59
commit 473f73a1f6
9 changed files with 349 additions and 90 deletions
+9 -17
View File
@@ -492,28 +492,20 @@ pub(crate) fn async_holds_suspended_for_in(obj: &JsObject) -> bool {
!state.suspended.for_in_iters.is_empty()
}
/// 异步状态内所有对象引用的扁平列表(GC mark 边)。
/// 异步状态内全部引用边的扁平列表(GC mark 边):对象/字符串/BigInt 均产出,
/// 消费侧按值类型分发到对象栈与存活集。
pub(crate) fn async_native_edges(obj: &JsObject) -> Vec<JsValue> {
let Some(state) = async_state_mut(obj) else {
return Vec::new();
};
let mut edges = Vec::new();
let push = |v: JsValue, edges: &mut Vec<JsValue>| {
if v.is_object() {
edges.push(v);
}
};
push(state.callee, &mut edges);
edges.extend(state.args.iter().copied().filter(|v| v.is_object()));
push(state.result, &mut edges);
push(state.promise, &mut edges);
push(state.resolve, &mut edges);
push(state.reject, &mut edges);
state.suspended.for_each_value(|v| {
if v.is_object() {
edges.push(v);
}
});
edges.push(state.callee);
edges.extend(state.args.iter().copied());
edges.push(state.result);
edges.push(state.promise);
edges.push(state.resolve);
edges.push(state.reject);
state.suspended.for_each_value(|v| edges.push(v));
edges
}
+12 -20
View File
@@ -878,35 +878,27 @@ pub(crate) fn async_generator_holds_suspended_for_in(obj: &JsObject) -> bool {
!state.suspended.for_in_iters.is_empty()
}
/// 异步生成器状态内所有对象引用的扁平列表(GC mark 边)。
/// 异步生成器状态内全部引用边的扁平列表(GC mark 边):对象/字符串/BigInt
/// 均产出,消费侧按值类型分发到对象栈与存活集。
pub(crate) fn async_generator_native_edges(obj: &JsObject) -> Vec<JsValue> {
let Some(state) = async_gen_state_mut(obj) else {
return Vec::new();
};
let mut edges = Vec::new();
let push = |v: JsValue, edges: &mut Vec<JsValue>| {
if v.is_object() {
edges.push(v);
}
};
push(state.callee, &mut edges);
edges.extend(state.args.iter().copied().filter(|v| v.is_object()));
push(state.result, &mut edges);
edges.push(state.callee);
edges.extend(state.args.iter().copied());
edges.push(state.result);
for req in state.queue.iter() {
push(req.promise, &mut edges);
push(req.resolve, &mut edges);
push(req.reject, &mut edges);
edges.push(req.promise);
edges.push(req.resolve);
edges.push(req.reject);
}
if let Some(req) = &state.current {
push(req.promise, &mut edges);
push(req.resolve, &mut edges);
push(req.reject, &mut edges);
edges.push(req.promise);
edges.push(req.resolve);
edges.push(req.reject);
}
state.suspended.for_each_value(|v| {
if v.is_object() {
edges.push(v);
}
});
state.suspended.for_each_value(|v| edges.push(v));
edges
}
+6 -14
View File
@@ -873,25 +873,17 @@ pub(crate) fn generator_holds_suspended_for_in(obj: &JsObject) -> bool {
!state.suspended.for_in_iters.is_empty()
}
/// 生成器状态内所有对象引用的扁平列表(GC mark 边)。
/// 生成器状态内全部引用边的扁平列表(GC mark 边):对象/字符串/BigInt 均产出,
/// 消费侧按值类型分发到对象栈与存活集。
pub(crate) fn generator_native_edges(obj: &JsObject) -> Vec<JsValue> {
let Some(state) = generator_state_mut(obj) else {
return Vec::new();
};
let mut edges = Vec::new();
let push = |v: JsValue, edges: &mut Vec<JsValue>| {
if v.is_object() {
edges.push(v);
}
};
push(state.callee, &mut edges);
edges.extend(state.args.iter().copied().filter(|v| v.is_object()));
push(state.result, &mut edges);
state.suspended.for_each_value(|v| {
if v.is_object() {
edges.push(v);
}
});
edges.push(state.callee);
edges.extend(state.args.iter().copied());
edges.push(state.result);
state.suspended.for_each_value(|v| edges.push(v));
edges
}
+9 -13
View File
@@ -1811,30 +1811,26 @@ fn promise_state_mut(obj: &JsObject) -> Option<&mut PromiseState> {
}
}
/// Promise 状态盒内所有对象引用(GC mark 边)。
/// Promise 状态盒内全部值边(GC mark 边):对象/字符串/BigInt 均产出,
/// 消费侧按值类型分发到对象栈与存活集。
pub(crate) fn promise_native_edges(obj: &JsObject) -> Vec<JsValue> {
let Some(state) = promise_state_ref(obj) else {
return Vec::new();
};
let mut edges = Vec::new();
let push = |v: JsValue, edges: &mut Vec<JsValue>| {
if v.is_object() {
edges.push(v);
}
};
push(state.result, &mut edges);
push(state.resolve_fn, &mut edges);
push(state.reject_fn, &mut edges);
edges.push(state.result);
edges.push(state.resolve_fn);
edges.push(state.reject_fn);
// 结算链指针:克隆恒为 session 表成员,凭这条边在原件/旧克隆仍存活时被
// 同轮置活,结算传导不会读到悬垂克隆。
if !state.promoted_clone.is_null() {
edges.push(JsValue::from_js_object(state.promoted_clone));
}
for r in &state.reactions {
push(r.promise, &mut edges);
push(r.resolve, &mut edges);
push(r.reject, &mut edges);
push(r.handler, &mut edges);
edges.push(r.promise);
edges.push(r.resolve);
edges.push(r.reject);
edges.push(r.handler);
}
edges
}
+118 -1
View File
@@ -1180,7 +1180,7 @@ mod tests {
use super::*;
use crate::vm::{CallFrame, FrameContinuation};
use oxide_builtins::{array_buffer, data_view, map, set, typed_array};
use oxide_builtins::{array_buffer, data_view, disposable_stack, map, set, typed_array};
use oxide_runtime_api::NativeResult;
fn plain_object(vm: &mut Vm) -> *mut JsObject {
@@ -1499,6 +1499,37 @@ mod tests {
val
}
/// 分配一个原型指向 DisposableStack.prototype 的占位对象并写入寄存器,
/// 作为构造器调用的 `this`。
fn dispose_stack_this(vm: &mut Vm, reg: u8) -> JsValue {
let proto = vm.session.builtin_world().disposable_stack_proto.as_ptr() as *mut JsObject;
let obj = vm.epoch.alloc(JsObject::new_empty(
oxide_kernel::shape_forge::EMPTY_SHAPE_ID,
JsValue::from_js_object(proto),
));
// 测试辅助函数绕过 alloc_object,需手动置位 EPOCH_BIT。
unsafe { (*obj).set_is_epoch(true) };
let val = JsValue::from_js_object(obj);
vm.regs[reg as usize] = val;
val
}
/// 置函数位标志的占位对象(通过 `is_callable` 判定),供 adopt 的
/// onDispose 槽使用;测试不调用它。
fn function_placeholder(vm: &mut Vm) -> JsValue {
let proto = vm.session.builtin_world().object_proto.as_ptr() as *mut JsObject;
let obj = vm.epoch.alloc(JsObject::new_empty(
oxide_kernel::shape_forge::EMPTY_SHAPE_ID,
JsValue::from_js_object(proto),
));
// 测试辅助函数绕过 alloc_object,需手动置位 EPOCH_BIT。
unsafe {
(*obj).set_is_epoch(true);
(*obj).set_function(true);
}
JsValue::from_js_object(obj)
}
#[test]
fn reset_maybe_collect_collects_after_threshold() {
let mut vm = vm_with_low_threshold();
@@ -1624,6 +1655,92 @@ mod tests {
assert_eq!(vm.gc_state.session_object_ptrs.len(), 2);
}
/// 盒持唯一引用的 session 串与 BigInt 经 Map native 边进入存活集:
/// 清寄存器仅留 Map 根后完整收集,两值仍登记在 session 表。
#[test]
fn session_gc_traces_map_string_and_bigint_value() {
let mut vm = vm_with_low_threshold();
map_this(&mut vm, 3);
let map_value = native_ok(map::map_constructor(&mut vm, &[3]));
let str = vm.new_string("map-box-string");
let str_ptr = str.as_string_ptr_mut();
let bi = vm.new_bigint(num_bigint::BigInt::from(121932631112635269u128));
let bi_ptr = bi.as_bigint_ptr() as *mut num_bigint::BigInt;
vm.regs[0] = map_value;
vm.regs[1] = JsValue::int(1);
vm.regs[2] = str;
native_ok(map::map_set(&mut vm, &[0, 1, 2]));
vm.regs[1] = JsValue::int(2);
vm.regs[2] = bi;
native_ok(map::map_set(&mut vm, &[0, 1, 2]));
let map_session = vm.promote_object(map_value.as_js_object_ptr());
vm.regs.fill(JsValue::undefined());
vm.regs[0] = JsValue::from_js_object(map_session);
collect(&mut vm);
// 只断言表成员——sweep 已释放的指针解引用即 UB。
assert!(vm.gc_state.session_string_ptrs.contains(&str_ptr));
assert!(vm.gc_state.session_bigint_ptrs.borrow().contains(&bi_ptr));
}
/// 盒持唯一引用的 session 串与 BigInt 经 Set native 边进入存活集:
/// 清寄存器仅留 Set 根后完整收集,两值仍登记在 session 表。
#[test]
fn session_gc_traces_set_string_and_bigint_value() {
let mut vm = vm_with_low_threshold();
set_this(&mut vm, 2);
let set_value = native_ok(set::set_constructor(&mut vm, &[2]));
let str = vm.new_string("set-box-string");
let str_ptr = str.as_string_ptr_mut();
let bi = vm.new_bigint(num_bigint::BigInt::from(987654321987654321u128));
let bi_ptr = bi.as_bigint_ptr() as *mut num_bigint::BigInt;
vm.regs[0] = set_value;
vm.regs[1] = str;
native_ok(set::set_add(&mut vm, &[0, 1]));
vm.regs[1] = bi;
native_ok(set::set_add(&mut vm, &[0, 1]));
let set_session = vm.promote_object(set_value.as_js_object_ptr());
vm.regs.fill(JsValue::undefined());
vm.regs[0] = JsValue::from_js_object(set_session);
collect(&mut vm);
// 只断言表成员——sweep 已释放的指针解引用即 UB。
assert!(vm.gc_state.session_string_ptrs.contains(&str_ptr));
assert!(vm.gc_state.session_bigint_ptrs.borrow().contains(&bi_ptr));
}
/// 盒持唯一引用的 session 串与 BigInt 经资源栈条目边进入存活集:
/// adopt 入栈后清寄存器仅留栈根,完整收集后两值仍登记在 session 表。
#[test]
fn session_gc_traces_dispose_stack_string_and_bigint_value() {
let mut vm = vm_with_low_threshold();
dispose_stack_this(&mut vm, 3);
let stack_value = native_ok(disposable_stack::disposable_stack_constructor(&mut vm, &[3]));
let on_dispose = function_placeholder(&mut vm);
let str = vm.new_string("stack-box-string");
let str_ptr = str.as_string_ptr_mut();
let bi = vm.new_bigint(num_bigint::BigInt::from(4611686018427387904u128));
let bi_ptr = bi.as_bigint_ptr() as *mut num_bigint::BigInt;
vm.regs[0] = stack_value;
vm.regs[1] = str;
vm.regs[2] = on_dispose;
native_ok(disposable_stack::disposable_stack_adopt(&mut vm, &[0, 1, 2]));
vm.regs[1] = bi;
native_ok(disposable_stack::disposable_stack_adopt(&mut vm, &[0, 1, 2]));
let stack_session = vm.promote_object(stack_value.as_js_object_ptr());
vm.regs.fill(JsValue::undefined());
vm.regs[0] = JsValue::from_js_object(stack_session);
collect(&mut vm);
// 只断言表成员——sweep 已释放的指针解引用即 UB。
assert!(vm.gc_state.session_string_ptrs.contains(&str_ptr));
assert!(vm.gc_state.session_bigint_ptrs.borrow().contains(&bi_ptr));
}
#[test]
fn session_gc_keeps_shared_array_buffer_alive_through_view_native_edges() {
let mut vm = vm_with_low_threshold();