use oxide_kernel::shape_forge::EMPTY_SHAPE_ID; use oxide_types::object::JsObject; use oxide_types::value::JsValue; use crate::set::SetKey; use oxide_runtime_api::{NativeResult, VmHost}; macro_rules! native_try { ($expr:expr) => { match $expr { Ok(value) => value, Err(err) => return NativeResult::Err(err), } }; } pub(crate) type MapInner = indexmap::IndexMap; /// 取出 Map 对象 native-data 槽中存储的 `IndexMap` 指针。 /// /// # 调用方维护的安全性契约 /// /// 指针在 Map `JsObject` 存活期间有效:`JsObject` 分配于当前 `Epoch` arena, /// native builtin 执行期间不会调用 `Epoch::reset()`。持有分配的 /// `Box` 由 `new_map_inner()` 创建,进程退出前不释放(生命周期与 /// epoch 绑定,属有意为之)。native 调用为单线程,同一 Map 对象同时至多 /// 存在一个活 `*mut` 别名。 fn get_map_inner(vm: &mut H, this_val: JsValue) -> Result<*mut MapInner, JsValue> { if !this_val.is_object() { return Err(crate::error::create_type_error(vm, "called on non-Map object")); } let map_ptr = this_val.as_js_object_ptr(); if map_ptr.is_null() { return Err(crate::error::create_type_error(vm, "Map internal state invalid")); } // SAFETY: map_ptr 是当前 Epoch bump 分配的 JsObject 的非空、对齐指针; // native 执行期间 epoch 不重置,指针在本调用内有效。 let map_obj = unsafe { &*map_ptr }; if !map_obj.is_map() { return Err(crate::error::create_type_error( vm, "Map.prototype method called on incompatible receiver", )); } // SAFETY: native_data 持有 `alloc_map` 写入的裸指针,即有效的 // 堆分配 `Box>`;IndexMap 至多要求 8 字节对齐, // 全局分配器满足该要求。 let inner_ptr = map_obj.native_data() as *mut MapInner; if inner_ptr.is_null() { return Err(crate::error::create_type_error(vm, "Map internal state invalid")); } Ok(inner_ptr) } fn new_map_inner() -> *mut MapInner { Box::into_raw(Box::new(MapInner::new())) } fn alloc_map(vm: &mut H) -> *mut JsObject { let map_proto = vm.session().builtin_world().map_proto.as_ptr() as *mut JsObject; let mut obj = JsObject::new_empty(EMPTY_SHAPE_ID, JsValue::from_js_object(map_proto)); obj.set_map(true); let inner = new_map_inner(); obj.set_native_data(inner as *mut u8); vm.alloc_object(obj) } /// 收集 Map 中作为对象引用的键和值(GC 根边),供跨 epoch 遍历/重写时追踪。 pub fn map_native_edges(obj: &JsObject) -> Vec { if !obj.is_map() { return Vec::new(); } let inner = obj.native_data() as *const MapInner; if inner.is_null() { return Vec::new(); } unsafe { (*inner) .iter() .flat_map(|(key, value)| [key.0, *value]) .filter(|value: &JsValue| value.is_object()) .collect() } } /// 克隆 Map 的 native 数据到新对象,用 `rewrite` 改写其中的对象引用 /// (供跨 epoch 的对象重写/克隆流程使用)。 pub fn clone_map_native_with_rewrite(src: &JsObject, dst: &mut JsObject, mut rewrite: F) where F: FnMut(JsValue) -> JsValue, { if !src.is_map() { return; } let inner = src.native_data() as *const MapInner; if inner.is_null() { dst.set_native_data(std::ptr::null_mut()); return; } let mut cloned = MapInner::new(); unsafe { for (key, value) in (*inner).iter() { let new_key = if key.0.is_object() { SetKey(rewrite(key.0)) } else { *key }; let new_value = if value.is_object() { rewrite(*value) } else { *value }; cloned.insert(new_key, new_value); } } dst.set_native_data(Box::into_raw(Box::new(cloned)) as *mut u8); } /// 原地重写 Map 的 native 数据,用 `rewrite` 改写其中的对象引用。 pub fn rewrite_map_native(obj: &mut JsObject, mut rewrite: F) where F: FnMut(JsValue) -> JsValue, { if !obj.is_map() { return; } let inner = obj.native_data() as *mut MapInner; if inner.is_null() { return; } unsafe { let mut rewritten = MapInner::with_capacity((*inner).len()); for (key, value) in (*inner).iter() { let new_key = if key.0.is_object() { SetKey(rewrite(key.0)) } else { *key }; let new_value = if value.is_object() { rewrite(*value) } else { *value }; rewritten.insert(new_key, new_value); } *inner = rewritten; } } /// 释放 Map 的 native 数据(IndexMap),返回释放的字节数供泄漏统计。 pub fn drop_map_native(obj: &mut JsObject) -> u64 { if !obj.is_map() { return 0; } let inner = obj.native_data() as *mut MapInner; if inner.is_null() { return 0; } unsafe { let boxed: Box = Box::from_raw(inner); let bytes = std::mem::size_of::() + boxed.capacity() * std::mem::size_of::<(SetKey, JsValue)>(); drop(boxed); obj.set_native_data(std::ptr::null_mut()); bytes as u64 } } /// `Map` 构造函数:创建带空 IndexMap native 数据的 Map 对象。 pub fn map_constructor(vm: &mut H, _args: &[u8]) -> NativeResult { let map_obj = alloc_map(vm); NativeResult::Ok(JsValue::from_js_object(map_obj)) } /// `Map.prototype.set(key, value)`:插入/更新键值对,返回 this。 pub fn map_set(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); let key = vm.reg(if args.len() > 1 { args[1] } else { 0 }); let val = vm.reg(if args.len() > 2 { args[2] } else { 0 }); unsafe { (*inner).insert(SetKey(key), val); } NativeResult::Ok(this_val) } /// `Map.prototype.get(key)`:返回 key 对应的值;不存在返回 undefined。 pub fn map_get(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); let key = vm.reg(if args.len() > 1 { args[1] } else { 0 }); let found = unsafe { (*inner).get(&SetKey(key)).copied() }; NativeResult::Ok(found.unwrap_or(JsValue::undefined())) } /// `Map.prototype.has(key)`:key 是否存在。 pub fn map_has(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); let key = vm.reg(if args.len() > 1 { args[1] } else { 0 }); let found = unsafe { (*inner).contains_key(&SetKey(key)) }; NativeResult::Ok(JsValue::bool(found)) } /// `Map.prototype.delete(key)`:删除键并返回是否删除成功。 pub fn map_delete(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); let key = vm.reg(if args.len() > 1 { args[1] } else { 0 }); let removed = unsafe { (*inner).shift_remove(&SetKey(key)) }; NativeResult::Ok(JsValue::bool(removed.is_some())) } /// `Map.prototype.clear()`:清空全部键值对,返回 undefined。 pub fn map_clear(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); unsafe { (*inner).clear(); } NativeResult::Ok(JsValue::undefined()) } /// `Map.prototype.size` getter:返回键值对数量。 pub fn map_size(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); NativeResult::Ok(JsValue::float(unsafe { (*inner).len() } as f64)) } /// `Map.prototype.entries()`:返回按插入序迭代 `[key, value]` 对的迭代器。 pub fn map_entries(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let _inner = native_try!(get_map_inner(vm, this_val)); NativeResult::Ok(crate::iterator::make_mode_iterator( vm, this_val, crate::iterator::map_entries_iter_next:: as *const (), )) } /// `Map.prototype.values()`:返回按插入序迭代值的迭代器。 pub fn map_values(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let _inner = native_try!(get_map_inner(vm, this_val)); NativeResult::Ok(crate::iterator::make_mode_iterator( vm, this_val, crate::iterator::map_values_iter_next:: as *const (), )) } /// `Map.prototype.keys()`:返回按插入序迭代键的迭代器。 pub fn map_keys(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let _inner = native_try!(get_map_inner(vm, this_val)); NativeResult::Ok(crate::iterator::make_mode_iterator( vm, this_val, crate::iterator::map_keys_iter_next:: as *const (), )) }