|
@@ -1,3 +1,4 @@
|
|
|
+use fxhash::FxHashMap;
|
|
|
use slab::Slab;
|
|
|
use std::cell::{Cell, RefCell};
|
|
|
|
|
@@ -7,7 +8,6 @@ use futures_channel::mpsc::UnboundedSender;
|
|
|
use crate::innerlude::*;
|
|
|
|
|
|
pub type FcSlot = *const ();
|
|
|
-// pub heuristics: FxHashMap<FcSlot, Heuristic>,
|
|
|
|
|
|
pub struct Heuristic {
|
|
|
hook_arena_size: usize,
|
|
@@ -21,6 +21,7 @@ pub struct Heuristic {
|
|
|
pub(crate) struct ScopeArena {
|
|
|
bump: Bump,
|
|
|
scopes: RefCell<Vec<*mut Scope>>,
|
|
|
+ pub heuristics: RefCell<FxHashMap<FcSlot, Heuristic>>,
|
|
|
free_scopes: RefCell<Vec<ScopeId>>,
|
|
|
nodes: RefCell<Slab<*const VNode<'static>>>,
|
|
|
pub(crate) sender: UnboundedSender<SchedulerMsg>,
|
|
@@ -31,6 +32,7 @@ impl ScopeArena {
|
|
|
Self {
|
|
|
bump: Bump::new(),
|
|
|
scopes: RefCell::new(Vec::new()),
|
|
|
+ heuristics: RefCell::new(FxHashMap::default()),
|
|
|
free_scopes: RefCell::new(Vec::new()),
|
|
|
nodes: RefCell::new(Slab::new()),
|
|
|
sender,
|
|
@@ -68,33 +70,53 @@ impl ScopeArena {
|
|
|
} else {
|
|
|
let scope_id = ScopeId(self.scopes.borrow().len());
|
|
|
|
|
|
- let old_root = NodeLink {
|
|
|
- link_idx: 0,
|
|
|
- gen_id: 0,
|
|
|
- scope_id,
|
|
|
- };
|
|
|
- let new_root = NodeLink {
|
|
|
- link_idx: 0,
|
|
|
- gen_id: 0,
|
|
|
- scope_id,
|
|
|
+ let (node_capacity, hook_capacity) = {
|
|
|
+ let heuristics = self.heuristics.borrow();
|
|
|
+ if let Some(heuristic) = heuristics.get(&fc_ptr) {
|
|
|
+ (heuristic.node_arena_size, heuristic.hook_arena_size)
|
|
|
+ } else {
|
|
|
+ (0, 0)
|
|
|
+ }
|
|
|
};
|
|
|
|
|
|
- let new_scope = Scope {
|
|
|
+ let mut frames = [BumpFrame::new(node_capacity), BumpFrame::new(node_capacity)];
|
|
|
+
|
|
|
+ frames[0].nodes.get_mut().push({
|
|
|
+ let vnode = frames[0]
|
|
|
+ .bump
|
|
|
+ .alloc(VNode::Text(frames[0].bump.alloc(VText {
|
|
|
+ dom_id: Default::default(),
|
|
|
+ is_static: false,
|
|
|
+ text: "",
|
|
|
+ })));
|
|
|
+ unsafe { std::mem::transmute(vnode as *mut VNode) }
|
|
|
+ });
|
|
|
+
|
|
|
+ frames[1].nodes.get_mut().push({
|
|
|
+ let vnode = frames[1]
|
|
|
+ .bump
|
|
|
+ .alloc(VNode::Text(frames[1].bump.alloc(VText {
|
|
|
+ dom_id: Default::default(),
|
|
|
+ is_static: false,
|
|
|
+ text: "",
|
|
|
+ })));
|
|
|
+ unsafe { std::mem::transmute(vnode as *mut VNode) }
|
|
|
+ });
|
|
|
+
|
|
|
+ let scope = self.bump.alloc(Scope {
|
|
|
sender: self.sender.clone(),
|
|
|
parent_scope,
|
|
|
our_arena_idx: scope_id,
|
|
|
height,
|
|
|
subtree: Cell::new(subtree),
|
|
|
is_subtree_root: Cell::new(false),
|
|
|
- frames: [BumpFrame::new(), BumpFrame::new()],
|
|
|
+ frames,
|
|
|
|
|
|
- hooks: Default::default(),
|
|
|
+ hooks: HookList::new(hook_capacity),
|
|
|
shared_contexts: Default::default(),
|
|
|
caller,
|
|
|
generation: 0.into(),
|
|
|
|
|
|
- old_root: RefCell::new(Some(old_root)),
|
|
|
- new_root: RefCell::new(Some(new_root)),
|
|
|
items: RefCell::new(SelfReferentialItems {
|
|
|
listeners: Default::default(),
|
|
|
borrowed_props: Default::default(),
|
|
@@ -102,16 +124,42 @@ impl ScopeArena {
|
|
|
tasks: Default::default(),
|
|
|
pending_effects: Default::default(),
|
|
|
}),
|
|
|
- };
|
|
|
+ });
|
|
|
|
|
|
- let stable = self.bump.alloc(new_scope);
|
|
|
- self.scopes.borrow_mut().push(stable);
|
|
|
+ self.scopes.borrow_mut().push(scope);
|
|
|
scope_id
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- pub fn try_remove(&self, id: &ScopeId) -> Option<Scope> {
|
|
|
- todo!()
|
|
|
+ pub fn try_remove(&self, id: &ScopeId) -> Option<()> {
|
|
|
+ self.ensure_drop_safety(id);
|
|
|
+
|
|
|
+ let mut scope = unsafe { &mut *self.get_scope_raw(id)? };
|
|
|
+
|
|
|
+ // we're just reusing scopes so we need to clear it out
|
|
|
+ scope.hooks.clear();
|
|
|
+ scope.shared_contexts.get_mut().clear();
|
|
|
+ scope.parent_scope = None;
|
|
|
+ scope.generation.set(0);
|
|
|
+ scope.is_subtree_root.set(false);
|
|
|
+ scope.subtree.set(0);
|
|
|
+
|
|
|
+ let SelfReferentialItems {
|
|
|
+ borrowed_props,
|
|
|
+ listeners,
|
|
|
+ pending_effects,
|
|
|
+ suspended_nodes,
|
|
|
+ tasks,
|
|
|
+ } = scope.items.get_mut();
|
|
|
+
|
|
|
+ borrowed_props.clear();
|
|
|
+ listeners.clear();
|
|
|
+ pending_effects.clear();
|
|
|
+ suspended_nodes.clear();
|
|
|
+ tasks.clear();
|
|
|
+
|
|
|
+ self.free_scopes.borrow_mut().push(*id);
|
|
|
+ Some(())
|
|
|
}
|
|
|
|
|
|
pub fn reserve_node(&self, node: &VNode) -> ElementId {
|
|
@@ -123,16 +171,10 @@ impl ScopeArena {
|
|
|
let node = unsafe { std::mem::transmute::<*const VNode, *const VNode>(node) };
|
|
|
entry.insert(node);
|
|
|
id
|
|
|
-
|
|
|
- // let nodes = self.nodes.borrow_mut();
|
|
|
- // let id = nodes.insert(());
|
|
|
- // let node_id = ElementId(id);
|
|
|
- // node = Some(node_id);
|
|
|
- // node_id
|
|
|
}
|
|
|
|
|
|
pub fn collect_garbage(&self, id: ElementId) {
|
|
|
- todo!()
|
|
|
+ self.nodes.borrow_mut().remove(id.0);
|
|
|
}
|
|
|
|
|
|
// These methods would normally exist on `scope` but they need access to *all* of the scopes
|
|
@@ -152,35 +194,25 @@ impl ScopeArena {
|
|
|
pub(crate) fn ensure_drop_safety(&self, scope_id: &ScopeId) {
|
|
|
let scope = self.get_scope(scope_id).unwrap();
|
|
|
|
|
|
+ let mut items = scope.items.borrow_mut();
|
|
|
+
|
|
|
// make sure we drop all borrowed props manually to guarantee that their drop implementation is called before we
|
|
|
// run the hooks (which hold an &mut Reference)
|
|
|
- // right now, we don't drop
|
|
|
- scope
|
|
|
- .items
|
|
|
- .borrow_mut()
|
|
|
- .borrowed_props
|
|
|
- .drain(..)
|
|
|
- .for_each(|comp| {
|
|
|
- // First drop the component's undropped references
|
|
|
- let scope_id = comp
|
|
|
- .associated_scope
|
|
|
- .get()
|
|
|
- .expect("VComponents should be associated with a valid Scope");
|
|
|
+ // recursively call ensure_drop_safety on all children
|
|
|
+ items.borrowed_props.drain(..).for_each(|comp| {
|
|
|
+ let scope_id = comp
|
|
|
+ .associated_scope
|
|
|
+ .get()
|
|
|
+ .expect("VComponents should be associated with a valid Scope");
|
|
|
|
|
|
- todo!("move this onto virtualdom");
|
|
|
- // let scope = unsafe { &mut *scope_id };
|
|
|
+ self.ensure_drop_safety(&scope_id);
|
|
|
|
|
|
- // scope.ensure_drop_safety();
|
|
|
-
|
|
|
- todo!("drop the component's props");
|
|
|
- // let mut drop_props = comp.drop_props.borrow_mut().take().unwrap();
|
|
|
- // drop_props();
|
|
|
- });
|
|
|
+ let mut drop_props = comp.drop_props.borrow_mut().take().unwrap();
|
|
|
+ drop_props();
|
|
|
+ });
|
|
|
|
|
|
// Now that all the references are gone, we can safely drop our own references in our listeners.
|
|
|
- scope
|
|
|
- .items
|
|
|
- .borrow_mut()
|
|
|
+ items
|
|
|
.listeners
|
|
|
.drain(..)
|
|
|
.for_each(|listener| drop(listener.callback.borrow_mut().take()));
|
|
@@ -212,59 +244,58 @@ impl ScopeArena {
|
|
|
|
|
|
// just forget about our suspended nodes while we're at it
|
|
|
items.suspended_nodes.clear();
|
|
|
+ items.tasks.clear();
|
|
|
+ items.pending_effects.clear();
|
|
|
|
|
|
// guarantee that we haven't screwed up - there should be no latent references anywhere
|
|
|
debug_assert!(items.listeners.is_empty());
|
|
|
- debug_assert!(items.suspended_nodes.is_empty());
|
|
|
debug_assert!(items.borrowed_props.is_empty());
|
|
|
+ debug_assert!(items.suspended_nodes.is_empty());
|
|
|
+ debug_assert!(items.tasks.is_empty());
|
|
|
+ debug_assert!(items.pending_effects.is_empty());
|
|
|
|
|
|
- log::debug!("Borrowed stuff is successfully cleared");
|
|
|
-
|
|
|
- // temporarily cast the vcomponent to the right lifetime
|
|
|
- // let vcomp = scope.load_vcomp();
|
|
|
+ // Todo: see if we can add stronger guarantees around internal bookkeeping and failed component renders.
|
|
|
+ scope.wip_frame().nodes.borrow_mut().clear();
|
|
|
}
|
|
|
|
|
|
let render: &dyn Fn(&Scope) -> Element = unsafe { &*scope.caller };
|
|
|
|
|
|
- // Todo: see if we can add stronger guarantees around internal bookkeeping and failed component renders.
|
|
|
- scope.wip_frame().nodes.borrow_mut().clear();
|
|
|
- if let Some(key) = render(scope) {
|
|
|
- dbg!(key);
|
|
|
+ if let Some(link) = render(scope) {
|
|
|
+ // right now, it's a panic to render a nodelink from another scope
|
|
|
+ // todo: enable this. it should (reasonably) work even if it doesnt make much sense
|
|
|
+ assert_eq!(link.scope_id.get(), Some(*id));
|
|
|
|
|
|
- dbg!(&scope.wip_frame().nodes.borrow_mut());
|
|
|
- // let mut old = scope.old_root.borrow_mut();
|
|
|
- // let mut new = scope.new_root.borrow_mut();
|
|
|
+ // nodelinks are not assigned when called and must be done so through the create/diff phase
|
|
|
+ // however, we need to link this one up since it will never be used in diffing
|
|
|
+ scope.wip_frame().assign_nodelink(&link);
|
|
|
+ debug_assert_eq!(scope.wip_frame().nodes.borrow().len(), 1);
|
|
|
|
|
|
- // let new_old = new.clone();
|
|
|
- // *old = new_old;
|
|
|
- // *new = Some(key);
|
|
|
+ if !scope.items.borrow().tasks.is_empty() {
|
|
|
+ // self.
|
|
|
+ }
|
|
|
|
|
|
- // dbg!(&old);
|
|
|
- // dbg!(&new);
|
|
|
-
|
|
|
- // the user's component succeeded. We can safely cycle to the next frame
|
|
|
- // scope.frames.wip_frame_mut().head_node = unsafe { std::mem::transmute(new_head) };
|
|
|
scope.cycle_frame();
|
|
|
-
|
|
|
true
|
|
|
} else {
|
|
|
false
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ // The head of the bumpframe is the first linked NodeLink
|
|
|
pub fn wip_head(&self, id: &ScopeId) -> &VNode {
|
|
|
let scope = self.get_scope(id).unwrap();
|
|
|
let wip_frame = scope.wip_frame();
|
|
|
let nodes = wip_frame.nodes.borrow();
|
|
|
- let node = nodes.get(0).unwrap();
|
|
|
+ let node: &VNode = unsafe { &**nodes.get(0).unwrap() };
|
|
|
unsafe { std::mem::transmute::<&VNode, &VNode>(node) }
|
|
|
}
|
|
|
|
|
|
+ // The head of the bumpframe is the first linked NodeLink
|
|
|
pub fn fin_head(&self, id: &ScopeId) -> &VNode {
|
|
|
let scope = self.get_scope(id).unwrap();
|
|
|
let wip_frame = scope.fin_frame();
|
|
|
let nodes = wip_frame.nodes.borrow();
|
|
|
- let node: &VNode = nodes.get(0).unwrap();
|
|
|
+ let node: &VNode = unsafe { &**nodes.get(0).unwrap() };
|
|
|
unsafe { std::mem::transmute::<&VNode, &VNode>(node) }
|
|
|
}
|
|
|
|