#![allow(unsafe_code)]
#![warn(missing_docs)]
mod single_linked_list_pin {
#![allow(unsafe_code)]
#[cfg(not(feature = "std"))]
use alloc::boxed::Box;
use core::pin::Pin;
type NodePtr<T> = Option<Pin<Box<SingleLinkedListPinNode<T>>>>;
struct SingleLinkedListPinNode<T> {
next: NodePtr<T>,
value: T,
}
pub struct SingleLinkedListPinHead<T>(NodePtr<T>);
impl<T> Default for SingleLinkedListPinHead<T> {
fn default() -> Self {
Self(None)
}
}
impl<T> Drop for SingleLinkedListPinHead<T> {
fn drop(&mut self) {
while let Some(mut x) = core::mem::take(&mut self.0) {
self.0 = core::mem::take(unsafe { &mut Pin::get_unchecked_mut(x.as_mut()).next });
}
}
}
impl<T> SingleLinkedListPinHead<T> {
pub fn push_front(&mut self, value: T) -> Pin<&T> {
self.0 = Some(Box::pin(SingleLinkedListPinNode { next: self.0.take(), value }));
unsafe { Pin::new_unchecked(&self.0.as_ref().unwrap().value) }
}
#[allow(unused)]
pub fn iter(&self) -> impl Iterator<Item = Pin<&T>> {
struct I<'a, T>(&'a NodePtr<T>);
impl<'a, T> Iterator for I<'a, T> {
type Item = Pin<&'a T>;
fn next(&mut self) -> Option<Self::Item> {
if let Some(x) = &self.0 {
let r = unsafe { Pin::new_unchecked(&x.value) };
self.0 = &x.next;
Some(r)
} else {
None
}
}
}
I(&self.0)
}
}
#[test]
fn test_list() {
let mut head = SingleLinkedListPinHead::default();
head.push_front(1);
head.push_front(2);
head.push_front(3);
assert_eq!(
head.iter().map(|x: Pin<&i32>| *x.get_ref()).collect::<Vec<i32>>(),
vec![3, 2, 1]
);
}
#[test]
fn big_list() {
let mut head = SingleLinkedListPinHead::default();
for x in 0..100000 {
head.push_front(x);
}
}
}
pub(crate) mod dependency_tracker {
use core::cell::Cell;
use core::pin::Pin;
#[repr(transparent)]
pub struct DependencyListHead<T>(Cell<*const DependencyNode<T>>);
impl<T> Default for DependencyListHead<T> {
fn default() -> Self {
Self(Cell::new(core::ptr::null()))
}
}
impl<T> Drop for DependencyListHead<T> {
fn drop(&mut self) {
unsafe { DependencyListHead::drop(self as *mut Self) };
}
}
impl<T> DependencyListHead<T> {
pub unsafe fn mem_move(from: *mut Self, to: *mut Self) {
(*to).0.set((*from).0.get());
if let Some(next) = (*from).0.get().as_ref() {
debug_assert_eq!(from as *const _, next.prev.get() as *const _);
next.debug_assert_valid();
next.prev.set(to as *const _);
next.debug_assert_valid();
}
}
pub fn swap(from: Pin<&Self>, to: Pin<&Self>) {
Cell::swap(&from.0, &to.0);
unsafe {
if let Some(n) = from.0.get().as_ref() {
debug_assert_eq!(n.prev.get() as *const _, &to.0 as *const _);
n.prev.set(&from.0 as *const _);
n.debug_assert_valid();
}
if let Some(n) = to.0.get().as_ref() {
debug_assert_eq!(n.prev.get() as *const _, &from.0 as *const _);
n.prev.set(&to.0 as *const _);
n.debug_assert_valid();
}
}
}
pub fn is_empty(&self) -> bool {
self.0.get().is_null()
}
pub fn clear(self: Pin<&Self>) {
unsafe {
if let Some(n) = self.0.get().as_ref() {
n.debug_assert_valid();
n.prev.set(core::ptr::null());
}
}
self.0.set(core::ptr::null());
}
pub unsafe fn drop(_self: *mut Self) {
if let Some(next) = (*_self).0.get().as_ref() {
debug_assert_eq!(_self as *const _, next.prev.get() as *const _);
next.debug_assert_valid();
next.prev.set(core::ptr::null());
next.debug_assert_valid();
}
}
pub fn append(&self, node: Pin<&DependencyNode<T>>) {
unsafe {
node.remove();
node.debug_assert_valid();
let old = self.0.get();
if let Some(x) = old.as_ref() {
x.debug_assert_valid();
}
self.0.set(node.get_ref() as *const DependencyNode<_>);
node.next.set(old);
node.prev.set(&self.0 as *const _);
if let Some(old) = old.as_ref() {
old.prev.set((&node.next) as *const _);
old.debug_assert_valid();
}
node.debug_assert_valid();
}
}
pub fn for_each(&self, mut f: impl FnMut(&T)) {
unsafe {
let mut next = self.0.get();
while let Some(node) = next.as_ref() {
node.debug_assert_valid();
next = node.next.get();
f(&node.binding);
}
}
}
}
pub struct DependencyNode<T> {
next: Cell<*const DependencyNode<T>>,
prev: Cell<*const Cell<*const DependencyNode<T>>>,
binding: T,
}
impl<T> DependencyNode<T> {
pub fn new(binding: T) -> Self {
Self { next: Cell::new(core::ptr::null()), prev: Cell::new(core::ptr::null()), binding }
}
pub fn debug_assert_valid(&self) {
unsafe {
debug_assert!(
self.prev.get().is_null()
|| (*self.prev.get()).get() == self as *const DependencyNode<T>
);
debug_assert!(
self.next.get().is_null()
|| (*self.next.get()).prev.get()
== (&self.next) as *const Cell<*const DependencyNode<T>>
);
debug_assert_ne!(self.next.get(), self as *const DependencyNode<T>);
debug_assert_ne!(
self.prev.get(),
(&self.next) as *const Cell<*const DependencyNode<T>>
);
}
}
pub fn remove(&self) {
self.debug_assert_valid();
unsafe {
if let Some(prev) = self.prev.get().as_ref() {
prev.set(self.next.get());
}
if let Some(next) = self.next.get().as_ref() {
next.debug_assert_valid();
next.prev.set(self.prev.get());
next.debug_assert_valid();
}
}
self.prev.set(core::ptr::null());
self.next.set(core::ptr::null());
}
}
impl<T> Drop for DependencyNode<T> {
fn drop(&mut self) {
self.remove();
}
}
}
type DependencyListHead = dependency_tracker::DependencyListHead<*const BindingHolder>;
type DependencyNode = dependency_tracker::DependencyNode<*const BindingHolder>;
#[cfg(not(feature = "std"))]
use alloc::boxed::Box;
use alloc::rc::Rc;
use core::cell::{Cell, RefCell, UnsafeCell};
use core::marker::PhantomPinned;
use core::pin::Pin;
static CONSTANT_PROPERTY_SENTINEL: u32 = 0;
#[derive(Copy, Clone, Debug, Eq, PartialEq)]
enum BindingResult {
KeepBinding,
RemoveBinding,
}
struct BindingVTable {
drop: unsafe fn(_self: *mut BindingHolder),
evaluate: unsafe fn(_self: *mut BindingHolder, value: *mut ()) -> BindingResult,
mark_dirty: unsafe fn(_self: *const BindingHolder, was_dirty: bool),
intercept_set: unsafe fn(_self: *const BindingHolder, value: *const ()) -> bool,
intercept_set_binding:
unsafe fn(_self: *const BindingHolder, new_binding: *mut BindingHolder) -> bool,
}
unsafe trait BindingCallable {
unsafe fn evaluate(self: Pin<&Self>, value: *mut ()) -> BindingResult;
fn mark_dirty(self: Pin<&Self>) {}
unsafe fn intercept_set(self: Pin<&Self>, _value: *const ()) -> bool {
false
}
unsafe fn intercept_set_binding(self: Pin<&Self>, _new_binding: *mut BindingHolder) -> bool {
false
}
const IS_TWO_WAY_BINDING: bool = false;
}
unsafe impl<F: Fn(*mut ()) -> BindingResult> BindingCallable for F {
unsafe fn evaluate(self: Pin<&Self>, value: *mut ()) -> BindingResult {
self(value)
}
}
#[cfg(feature = "std")]
scoped_tls_hkt::scoped_thread_local!(static CURRENT_BINDING : for<'a> Option<Pin<&'a BindingHolder>>);
#[cfg(all(not(feature = "std"), feature = "unsafe-single-threaded"))]
mod unsafe_single_threaded {
use super::BindingHolder;
use core::cell::Cell;
use core::pin::Pin;
use core::ptr::null;
pub(super) struct FakeThreadStorage(Cell<*const BindingHolder>);
impl FakeThreadStorage {
pub const fn new() -> Self {
Self(Cell::new(null()))
}
pub fn set<T>(&self, value: Option<Pin<&BindingHolder>>, f: impl FnOnce() -> T) -> T {
let old = self.0.replace(value.map_or(null(), |v| v.get_ref() as *const BindingHolder));
let res = f();
let new = self.0.replace(old);
assert_eq!(new, value.map_or(null(), |v| v.get_ref() as *const BindingHolder));
res
}
pub fn is_set(&self) -> bool {
!self.0.get().is_null()
}
pub fn with<T>(&self, f: impl FnOnce(Option<Pin<&BindingHolder>>) -> T) -> T {
let local = unsafe { self.0.get().as_ref().map(|x| Pin::new_unchecked(x)) };
let res = f(local);
assert_eq!(self.0.get(), local.map_or(null(), |v| v.get_ref() as *const BindingHolder));
res
}
}
unsafe impl Send for FakeThreadStorage {}
unsafe impl Sync for FakeThreadStorage {}
}
#[cfg(all(not(feature = "std"), feature = "unsafe-single-threaded"))]
static CURRENT_BINDING: unsafe_single_threaded::FakeThreadStorage =
unsafe_single_threaded::FakeThreadStorage::new();
pub fn evaluate_no_tracking<T>(f: impl FnOnce() -> T) -> T {
CURRENT_BINDING.set(None, f)
}
pub fn is_currently_tracking() -> bool {
CURRENT_BINDING.is_set() && CURRENT_BINDING.with(|x| x.is_some())
}
#[repr(C)]
struct BindingHolder<B = ()> {
dependencies: Cell<usize>,
dep_nodes: Cell<single_linked_list_pin::SingleLinkedListPinHead<DependencyNode>>,
vtable: &'static BindingVTable,
dirty: Cell<bool>,
is_two_way_binding: bool,
pinned: PhantomPinned,
#[cfg(slint_debug_property)]
pub debug_name: String,
binding: B,
}
impl BindingHolder {
fn register_self_as_dependency(
self: Pin<&Self>,
property_that_will_notify: *mut DependencyListHead,
#[cfg(slint_debug_property)] other_debug_name: &str,
) {
let node = DependencyNode::new(self.get_ref() as *const _);
let mut dep_nodes = self.dep_nodes.take();
let node = dep_nodes.push_front(node);
unsafe { DependencyListHead::append(&*property_that_will_notify, node) }
self.dep_nodes.set(dep_nodes);
}
}
fn alloc_binding_holder<B: BindingCallable + 'static>(binding: B) -> *mut BindingHolder {
unsafe fn binding_drop<B>(_self: *mut BindingHolder) {
drop(Box::from_raw(_self as *mut BindingHolder<B>));
}
unsafe fn evaluate<B: BindingCallable>(
_self: *mut BindingHolder,
value: *mut (),
) -> BindingResult {
let pinned_holder = Pin::new_unchecked(&*_self);
CURRENT_BINDING.set(Some(pinned_holder), || {
Pin::new_unchecked(&((*(_self as *mut BindingHolder<B>)).binding)).evaluate(value)
})
}
unsafe fn mark_dirty<B: BindingCallable>(_self: *const BindingHolder, _: bool) {
Pin::new_unchecked(&((*(_self as *const BindingHolder<B>)).binding)).mark_dirty()
}
unsafe fn intercept_set<B: BindingCallable>(
_self: *const BindingHolder,
value: *const (),
) -> bool {
Pin::new_unchecked(&((*(_self as *const BindingHolder<B>)).binding)).intercept_set(value)
}
unsafe fn intercept_set_binding<B: BindingCallable>(
_self: *const BindingHolder,
new_binding: *mut BindingHolder,
) -> bool {
Pin::new_unchecked(&((*(_self as *const BindingHolder<B>)).binding))
.intercept_set_binding(new_binding)
}
trait HasBindingVTable {
const VT: &'static BindingVTable;
}
impl<B: BindingCallable> HasBindingVTable for B {
const VT: &'static BindingVTable = &BindingVTable {
drop: binding_drop::<B>,
evaluate: evaluate::<B>,
mark_dirty: mark_dirty::<B>,
intercept_set: intercept_set::<B>,
intercept_set_binding: intercept_set_binding::<B>,
};
}
let holder: BindingHolder<B> = BindingHolder {
dependencies: Cell::new(0),
dep_nodes: Default::default(),
vtable: <B as HasBindingVTable>::VT,
dirty: Cell::new(true), is_two_way_binding: B::IS_TWO_WAY_BINDING,
pinned: PhantomPinned,
#[cfg(slint_debug_property)]
debug_name: Default::default(),
binding,
};
Box::into_raw(Box::new(holder)) as *mut BindingHolder
}
#[repr(transparent)]
#[derive(Default)]
struct PropertyHandle {
handle: Cell<usize>,
}
impl core::fmt::Debug for PropertyHandle {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
let handle = self.handle.get();
write!(
f,
"PropertyHandle {{ handle: 0x{:x}, locked: {}, binding: {} }}",
handle & !0b11,
(handle & 0b01) == 0b01,
(handle & 0b10) == 0b10
)
}
}
impl PropertyHandle {
fn lock_flag(&self) -> bool {
self.handle.get() & 0b1 == 1
}
unsafe fn set_lock_flag(&self, set: bool) {
self.handle.set(if set { self.handle.get() | 0b1 } else { self.handle.get() & !0b1 })
}
fn access<R>(&self, f: impl FnOnce(Option<Pin<&mut BindingHolder>>) -> R) -> R {
assert!(!self.lock_flag(), "Recursion detected");
unsafe {
self.set_lock_flag(true);
scopeguard::defer! { self.set_lock_flag(false); }
let handle = self.handle.get();
let binding = if handle & 0b10 == 0b10 {
Some(Pin::new_unchecked(&mut *((handle & !0b11) as *mut BindingHolder)))
} else {
None
};
f(binding)
}
}
fn remove_binding(&self) {
assert!(!self.lock_flag(), "Recursion detected");
let val = self.handle.get();
if val & 0b10 == 0b10 {
unsafe {
self.set_lock_flag(true);
let binding = (val & !0b11) as *mut BindingHolder;
let const_sentinel = (&CONSTANT_PROPERTY_SENTINEL) as *const u32 as usize;
if (*binding).dependencies.get() == const_sentinel {
self.handle.set(const_sentinel);
(*binding).dependencies.set(0);
} else {
DependencyListHead::mem_move(
(*binding).dependencies.as_ptr() as *mut DependencyListHead,
self.handle.as_ptr() as *mut DependencyListHead,
);
}
((*binding).vtable.drop)(binding);
}
debug_assert!(self.handle.get() & 0b11 == 0);
}
}
unsafe fn set_binding<B: BindingCallable + 'static>(
&self,
binding: B,
#[cfg(slint_debug_property)] debug_name: &str,
) {
let binding = alloc_binding_holder::<B>(binding);
#[cfg(slint_debug_property)]
{
(*binding).debug_name = debug_name.into();
}
self.set_binding_impl(binding);
}
fn set_binding_impl(&self, binding: *mut BindingHolder) {
let previous_binding_intercepted = self.access(|b| {
b.map_or(false, |b| unsafe {
(b.vtable.intercept_set_binding)(&*b as *const BindingHolder, binding)
})
});
if previous_binding_intercepted {
return;
}
self.remove_binding();
debug_assert!((binding as usize) & 0b11 == 0);
debug_assert!(self.handle.get() & 0b11 == 0);
let const_sentinel = (&CONSTANT_PROPERTY_SENTINEL) as *const u32 as usize;
let is_constant = self.handle.get() == const_sentinel;
unsafe {
if is_constant {
(*binding).dependencies.set(const_sentinel);
} else {
DependencyListHead::mem_move(
self.handle.as_ptr() as *mut DependencyListHead,
(*binding).dependencies.as_ptr() as *mut DependencyListHead,
);
}
}
self.handle.set((binding as usize) | 0b10);
if !is_constant {
self.mark_dirty(
#[cfg(slint_debug_property)]
"",
);
}
}
fn dependencies(&self) -> *mut DependencyListHead {
assert!(!self.lock_flag(), "Recursion detected");
if (self.handle.get() & 0b10) != 0 {
self.access(|binding| binding.unwrap().dependencies.as_ptr() as *mut DependencyListHead)
} else {
self.handle.as_ptr() as *mut DependencyListHead
}
}
unsafe fn update<T>(&self, value: *mut T) {
let remove = self.access(|binding| {
if let Some(mut binding) = binding {
if binding.dirty.get() {
binding.dep_nodes.set(Default::default());
let r = (binding.vtable.evaluate)(
binding.as_mut().get_unchecked_mut() as *mut BindingHolder,
value as *mut (),
);
binding.dirty.set(false);
if r == BindingResult::RemoveBinding {
return true;
}
}
}
false
});
if remove {
self.remove_binding()
}
}
fn register_as_dependency_to_current_binding(
self: Pin<&Self>,
#[cfg(slint_debug_property)] debug_name: &str,
) {
if CURRENT_BINDING.is_set() {
CURRENT_BINDING.with(|cur_binding| {
if let Some(cur_binding) = cur_binding {
let dependencies = self.dependencies();
if !core::ptr::eq(
unsafe { *(dependencies as *mut *const u32) },
(&CONSTANT_PROPERTY_SENTINEL) as *const u32,
) {
cur_binding.register_self_as_dependency(
dependencies,
#[cfg(slint_debug_property)]
debug_name,
);
}
}
});
}
}
fn mark_dirty(&self, #[cfg(slint_debug_property)] debug_name: &str) {
#[cfg(not(slint_debug_property))]
let debug_name = "";
unsafe {
let dependencies = self.dependencies();
assert!(
!core::ptr::eq(
*(dependencies as *mut *const u32),
(&CONSTANT_PROPERTY_SENTINEL) as *const u32,
),
"Constant property being changed {}",
debug_name
);
mark_dependencies_dirty(dependencies)
};
}
fn set_constant(&self) {
unsafe {
let dependencies = self.dependencies();
if !core::ptr::eq(
*(dependencies as *mut *const u32),
(&CONSTANT_PROPERTY_SENTINEL) as *const u32,
) {
DependencyListHead::drop(dependencies);
*(dependencies as *mut *const u32) = (&CONSTANT_PROPERTY_SENTINEL) as *const u32
}
}
}
}
impl Drop for PropertyHandle {
fn drop(&mut self) {
self.remove_binding();
debug_assert!(self.handle.get() & 0b11 == 0);
if self.handle.get() as *const u32 != (&CONSTANT_PROPERTY_SENTINEL) as *const u32 {
unsafe {
DependencyListHead::drop(self.handle.as_ptr() as *mut _);
}
}
}
}
unsafe fn mark_dependencies_dirty(dependencies: *mut DependencyListHead) {
debug_assert!(!core::ptr::eq(
*(dependencies as *mut *const u32),
(&CONSTANT_PROPERTY_SENTINEL) as *const u32,
));
DependencyListHead::for_each(&*dependencies, |binding| {
let binding: &BindingHolder = &**binding;
let was_dirty = binding.dirty.replace(true);
(binding.vtable.mark_dirty)(binding as *const BindingHolder, was_dirty);
assert!(
!core::ptr::eq(
*(binding.dependencies.as_ptr() as *mut *const u32),
(&CONSTANT_PROPERTY_SENTINEL) as *const u32,
),
"Const property marked as dirty"
);
if !was_dirty {
mark_dependencies_dirty(binding.dependencies.as_ptr() as *mut DependencyListHead)
}
});
}
pub trait Binding<T> {
fn evaluate(&self, old_value: &T) -> T;
}
impl<T, F: Fn() -> T> Binding<T> for F {
fn evaluate(&self, _value: &T) -> T {
self()
}
}
#[repr(C)]
pub struct Property<T> {
handle: PropertyHandle,
value: UnsafeCell<T>,
pinned: PhantomPinned,
#[cfg(slint_debug_property)]
pub debug_name: RefCell<String>,
}
impl<T: core::fmt::Debug + Clone> core::fmt::Debug for Property<T> {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
#[cfg(slint_debug_property)]
write!(f, "[{}]=", self.debug_name.borrow())?;
write!(
f,
"Property({:?}{})",
self.get_internal(),
if self.is_dirty() { " (dirty)" } else { "" }
)
}
}
impl<T: Default> Default for Property<T> {
fn default() -> Self {
Self {
handle: Default::default(),
value: Default::default(),
pinned: PhantomPinned,
#[cfg(slint_debug_property)]
debug_name: Default::default(),
}
}
}
impl<T: Clone> Property<T> {
pub fn new(value: T) -> Self {
Self {
handle: Default::default(),
value: UnsafeCell::new(value),
pinned: PhantomPinned,
#[cfg(slint_debug_property)]
debug_name: Default::default(),
}
}
pub fn new_named(value: T, _name: &'static str) -> Self {
Self {
handle: Default::default(),
value: UnsafeCell::new(value),
pinned: PhantomPinned,
#[cfg(slint_debug_property)]
debug_name: _name.to_owned().into(),
}
}
pub fn get(self: Pin<&Self>) -> T {
unsafe { self.handle.update(self.value.get()) };
let handle = unsafe { Pin::new_unchecked(&self.handle) };
handle.register_as_dependency_to_current_binding(
#[cfg(slint_debug_property)]
self.debug_name.borrow().as_str(),
);
self.get_internal()
}
pub fn get_untracked(self: Pin<&Self>) -> T {
unsafe { self.handle.update(self.value.get()) };
self.get_internal()
}
fn get_internal(&self) -> T {
self.handle.access(|_| {
unsafe { (*self.value.get()).clone() }
})
}
pub fn set(&self, t: T)
where
T: PartialEq,
{
let previous_binding_intercepted = self.handle.access(|b| {
b.map_or(false, |b| unsafe {
(b.vtable.intercept_set)(&*b as *const BindingHolder, &t as *const T as *const ())
})
});
if !previous_binding_intercepted {
self.handle.remove_binding();
}
let has_value_changed = self.handle.access(|_| unsafe {
*self.value.get() != t && {
*self.value.get() = t;
true
}
});
if has_value_changed {
self.handle.mark_dirty(
#[cfg(slint_debug_property)]
self.debug_name.borrow().as_str(),
);
}
}
pub fn set_binding(&self, binding: impl Binding<T> + 'static) {
unsafe {
self.handle.set_binding(
move |val: *mut ()| {
let val = &mut *(val as *mut T);
*val = binding.evaluate(val);
BindingResult::KeepBinding
},
#[cfg(slint_debug_property)]
self.debug_name.borrow().as_str(),
)
}
self.handle.mark_dirty(
#[cfg(slint_debug_property)]
self.debug_name.borrow().as_str(),
);
}
pub fn is_dirty(&self) -> bool {
self.handle.access(|binding| binding.map_or(false, |b| b.dirty.get()))
}
pub fn mark_dirty(&self) {
self.handle.mark_dirty(
#[cfg(slint_debug_property)]
self.debug_name.borrow().as_str(),
)
}
pub fn set_constant(&self) {
self.handle.set_constant();
}
}
#[test]
fn properties_simple_test() {
use pin_weak::rc::PinWeak;
use std::rc::Rc;
fn g(prop: &Property<i32>) -> i32 {
unsafe { Pin::new_unchecked(prop).get() }
}
#[derive(Default)]
struct Component {
width: Property<i32>,
height: Property<i32>,
area: Property<i32>,
}
let compo = Rc::pin(Component::default());
let w = PinWeak::downgrade(compo.clone());
compo.area.set_binding(move || {
let compo = w.upgrade().unwrap();
g(&compo.width) * g(&compo.height)
});
compo.width.set(4);
compo.height.set(8);
assert_eq!(g(&compo.width), 4);
assert_eq!(g(&compo.height), 8);
assert_eq!(g(&compo.area), 4 * 8);
let w = PinWeak::downgrade(compo.clone());
compo.width.set_binding(move || {
let compo = w.upgrade().unwrap();
g(&compo.height) * 2
});
assert_eq!(g(&compo.width), 8 * 2);
assert_eq!(g(&compo.height), 8);
assert_eq!(g(&compo.area), 8 * 8 * 2);
}
impl<T: PartialEq + Clone + 'static> Property<T> {
pub fn link_two_way(prop1: Pin<&Self>, prop2: Pin<&Self>) {
struct TwoWayBinding<T> {
common_property: Pin<Rc<Property<T>>>,
}
unsafe impl<T: PartialEq + Clone + 'static> BindingCallable for TwoWayBinding<T> {
unsafe fn evaluate(self: Pin<&Self>, value: *mut ()) -> BindingResult {
*(value as *mut T) = self.common_property.as_ref().get();
BindingResult::KeepBinding
}
unsafe fn intercept_set(self: Pin<&Self>, value: *const ()) -> bool {
self.common_property.as_ref().set((*(value as *const T)).clone());
true
}
unsafe fn intercept_set_binding(
self: Pin<&Self>,
new_binding: *mut BindingHolder,
) -> bool {
self.common_property.handle.set_binding_impl(new_binding);
true
}
const IS_TWO_WAY_BINDING: bool = true;
}
#[cfg(slint_debug_property)]
let debug_name = format!("<{}<=>{}>", prop1.debug_name.borrow(), prop2.debug_name.borrow());
let value = prop2.get_internal();
let prop1_handle_val = prop1.handle.handle.get();
if prop1_handle_val & 0b10 == 0b10 {
let holder = unsafe { &*((prop1_handle_val & !0b11) as *const BindingHolder) };
if holder.is_two_way_binding {
unsafe {
let holder =
&*((prop1_handle_val & !0b11) as *const BindingHolder<TwoWayBinding<T>>);
prop2.handle.set_binding(
TwoWayBinding { common_property: holder.binding.common_property.clone() },
#[cfg(slint_debug_property)]
debug_name.as_str(),
);
}
prop2.set(value);
return;
}
};
let prop2_handle_val = prop2.handle.handle.get();
let handle = if prop2_handle_val & 0b10 == 0b10 {
let holder = unsafe { &*((prop2_handle_val & !0b11) as *const BindingHolder) };
if holder.is_two_way_binding {
unsafe {
let holder =
&*((prop2_handle_val & !0b11) as *const BindingHolder<TwoWayBinding<T>>);
prop1.handle.set_binding(
TwoWayBinding { common_property: holder.binding.common_property.clone() },
#[cfg(slint_debug_property)]
debug_name.as_str(),
);
}
return;
}
prop2.handle.handle.set(0);
PropertyHandle { handle: Cell::new(prop2_handle_val) }
} else {
PropertyHandle::default()
};
let common_property = Rc::pin(Property {
handle,
value: UnsafeCell::new(value),
pinned: PhantomPinned,
#[cfg(slint_debug_property)]
debug_name: debug_name.clone().into(),
});
unsafe {
prop1.handle.set_binding(
TwoWayBinding { common_property: common_property.clone() },
#[cfg(slint_debug_property)]
debug_name.as_str(),
);
prop2.handle.set_binding(
TwoWayBinding { common_property },
#[cfg(slint_debug_property)]
debug_name.as_str(),
);
}
}
}
#[test]
fn property_two_ways_test() {
let p1 = Rc::pin(Property::new(42));
let p2 = Rc::pin(Property::new(88));
let depends = Box::pin(Property::new(0));
depends.as_ref().set_binding({
let p1 = p1.clone();
move || p1.as_ref().get() + 8
});
assert_eq!(depends.as_ref().get(), 42 + 8);
Property::link_two_way(p1.as_ref(), p2.as_ref());
assert_eq!(p1.as_ref().get(), 88);
assert_eq!(p2.as_ref().get(), 88);
assert_eq!(depends.as_ref().get(), 88 + 8);
p2.as_ref().set(5);
assert_eq!(p1.as_ref().get(), 5);
assert_eq!(p2.as_ref().get(), 5);
assert_eq!(depends.as_ref().get(), 5 + 8);
p1.as_ref().set(22);
assert_eq!(p1.as_ref().get(), 22);
assert_eq!(p2.as_ref().get(), 22);
assert_eq!(depends.as_ref().get(), 22 + 8);
}
#[test]
fn property_two_ways_test_binding() {
let p1 = Rc::pin(Property::new(42));
let p2 = Rc::pin(Property::new(88));
let global = Rc::pin(Property::new(23));
p2.as_ref().set_binding({
let global = global.clone();
move || global.as_ref().get() + 9
});
let depends = Box::pin(Property::new(0));
depends.as_ref().set_binding({
let p1 = p1.clone();
move || p1.as_ref().get() + 8
});
Property::link_two_way(p1.as_ref(), p2.as_ref());
assert_eq!(p1.as_ref().get(), 23 + 9);
assert_eq!(p2.as_ref().get(), 23 + 9);
assert_eq!(depends.as_ref().get(), 23 + 9 + 8);
global.as_ref().set(55);
assert_eq!(p1.as_ref().get(), 55 + 9);
assert_eq!(p2.as_ref().get(), 55 + 9);
assert_eq!(depends.as_ref().get(), 55 + 9 + 8);
}
#[test]
fn property_two_ways_recurse_from_binding() {
let xx = Rc::pin(Property::new(0));
let p1 = Rc::pin(Property::new(42));
let p2 = Rc::pin(Property::new(88));
let global = Rc::pin(Property::new(23));
let done = Rc::new(Cell::new(false));
xx.set_binding({
let p1 = p1.clone();
let p2 = p2.clone();
let global = global.clone();
let xx_weak = pin_weak::rc::PinWeak::downgrade(xx.clone());
move || {
if !done.get() {
done.set(true);
Property::link_two_way(p1.as_ref(), p2.as_ref());
let xx = xx_weak.upgrade().unwrap();
p1.as_ref().set_binding(move || xx.as_ref().get() + 9);
}
global.as_ref().get() + 2
}
});
assert_eq!(xx.as_ref().get(), 23 + 2);
assert_eq!(p1.as_ref().get(), 23 + 2 + 9);
assert_eq!(p2.as_ref().get(), 23 + 2 + 9);
global.as_ref().set(55);
assert_eq!(p1.as_ref().get(), 55 + 2 + 9);
assert_eq!(p2.as_ref().get(), 55 + 2 + 9);
assert_eq!(xx.as_ref().get(), 55 + 2);
}
#[test]
fn property_two_ways_binding_of_two_way_binding_first() {
let p1_1 = Rc::pin(Property::new(2));
let p1_2 = Rc::pin(Property::new(4));
Property::link_two_way(p1_1.as_ref(), p1_2.as_ref());
assert_eq!(p1_1.as_ref().get(), 4);
assert_eq!(p1_2.as_ref().get(), 4);
let p2 = Rc::pin(Property::new(3));
Property::link_two_way(p1_1.as_ref(), p2.as_ref());
assert_eq!(p1_1.as_ref().get(), 3);
assert_eq!(p1_2.as_ref().get(), 3);
assert_eq!(p2.as_ref().get(), 3);
p1_1.set(6);
assert_eq!(p1_1.as_ref().get(), 6);
assert_eq!(p1_2.as_ref().get(), 6);
assert_eq!(p2.as_ref().get(), 6);
p1_2.set(8);
assert_eq!(p1_1.as_ref().get(), 8);
assert_eq!(p1_2.as_ref().get(), 8);
assert_eq!(p2.as_ref().get(), 8);
p2.set(7);
assert_eq!(p1_1.as_ref().get(), 7);
assert_eq!(p1_2.as_ref().get(), 7);
assert_eq!(p2.as_ref().get(), 7);
}
#[test]
fn property_two_ways_binding_of_two_way_binding_second() {
let p1 = Rc::pin(Property::new(2));
let p2_1 = Rc::pin(Property::new(3));
let p2_2 = Rc::pin(Property::new(5));
Property::link_two_way(p2_1.as_ref(), p2_2.as_ref());
assert_eq!(p2_1.as_ref().get(), 5);
assert_eq!(p2_2.as_ref().get(), 5);
Property::link_two_way(p1.as_ref(), p2_2.as_ref());
assert_eq!(p1.as_ref().get(), 5);
assert_eq!(p2_1.as_ref().get(), 5);
assert_eq!(p2_2.as_ref().get(), 5);
p1.set(6);
assert_eq!(p1.as_ref().get(), 6);
assert_eq!(p2_1.as_ref().get(), 6);
assert_eq!(p2_2.as_ref().get(), 6);
p2_1.set(7);
assert_eq!(p1.as_ref().get(), 7);
assert_eq!(p2_1.as_ref().get(), 7);
assert_eq!(p2_2.as_ref().get(), 7);
p2_2.set(9);
assert_eq!(p1.as_ref().get(), 9);
assert_eq!(p2_1.as_ref().get(), 9);
assert_eq!(p2_2.as_ref().get(), 9);
}
#[test]
fn property_two_ways_binding_of_two_two_way_bindings() {
let p1_1 = Rc::pin(Property::new(2));
let p1_2 = Rc::pin(Property::new(4));
Property::link_two_way(p1_1.as_ref(), p1_2.as_ref());
assert_eq!(p1_1.as_ref().get(), 4);
assert_eq!(p1_2.as_ref().get(), 4);
let p2_1 = Rc::pin(Property::new(3));
let p2_2 = Rc::pin(Property::new(5));
Property::link_two_way(p2_1.as_ref(), p2_2.as_ref());
assert_eq!(p2_1.as_ref().get(), 5);
assert_eq!(p2_2.as_ref().get(), 5);
Property::link_two_way(p1_1.as_ref(), p2_2.as_ref());
assert_eq!(p1_1.as_ref().get(), 5);
assert_eq!(p1_2.as_ref().get(), 5);
assert_eq!(p2_1.as_ref().get(), 5);
assert_eq!(p2_2.as_ref().get(), 5);
p1_1.set(6);
assert_eq!(p1_1.as_ref().get(), 6);
assert_eq!(p1_2.as_ref().get(), 6);
assert_eq!(p2_1.as_ref().get(), 6);
assert_eq!(p2_2.as_ref().get(), 6);
p1_2.set(8);
assert_eq!(p1_1.as_ref().get(), 8);
assert_eq!(p1_2.as_ref().get(), 8);
assert_eq!(p2_1.as_ref().get(), 8);
assert_eq!(p2_2.as_ref().get(), 8);
p2_1.set(7);
assert_eq!(p1_1.as_ref().get(), 7);
assert_eq!(p1_2.as_ref().get(), 7);
assert_eq!(p2_1.as_ref().get(), 7);
assert_eq!(p2_2.as_ref().get(), 7);
p2_2.set(9);
assert_eq!(p1_1.as_ref().get(), 9);
assert_eq!(p1_2.as_ref().get(), 9);
assert_eq!(p2_1.as_ref().get(), 9);
assert_eq!(p2_2.as_ref().get(), 9);
}
mod change_tracker;
pub use change_tracker::*;
mod properties_animations;
pub use crate::items::StateInfo;
pub use properties_animations::*;
struct StateInfoBinding<F> {
dirty_time: Cell<Option<crate::animations::Instant>>,
binding: F,
}
unsafe impl<F: Fn() -> i32> crate::properties::BindingCallable for StateInfoBinding<F> {
unsafe fn evaluate(self: Pin<&Self>, value: *mut ()) -> BindingResult {
let value = &mut *(value as *mut StateInfo);
let new_state = (self.binding)();
let timestamp = self.dirty_time.take();
if new_state != value.current_state {
value.previous_state = value.current_state;
value.change_time = timestamp.unwrap_or_else(crate::animations::current_tick);
value.current_state = new_state;
}
BindingResult::KeepBinding
}
fn mark_dirty(self: Pin<&Self>) {
if self.dirty_time.get().is_none() {
self.dirty_time.set(Some(crate::animations::current_tick()))
}
}
}
pub fn set_state_binding(property: Pin<&Property<StateInfo>>, binding: impl Fn() -> i32 + 'static) {
let bind_callable = StateInfoBinding { dirty_time: Cell::new(None), binding };
unsafe {
property.handle.set_binding(
bind_callable,
#[cfg(slint_debug_property)]
property.debug_name.borrow().as_str(),
)
}
}
#[doc(hidden)]
pub trait PropertyDirtyHandler {
fn notify(self: Pin<&Self>);
}
impl PropertyDirtyHandler for () {
fn notify(self: Pin<&Self>) {}
}
impl<F: Fn()> PropertyDirtyHandler for F {
fn notify(self: Pin<&Self>) {
(self.get_ref())()
}
}
pub struct PropertyTracker<DirtyHandler = ()> {
holder: BindingHolder<DirtyHandler>,
}
impl Default for PropertyTracker<()> {
fn default() -> Self {
static VT: &BindingVTable = &BindingVTable {
drop: |_| (),
evaluate: |_, _| BindingResult::KeepBinding,
mark_dirty: |_, _| (),
intercept_set: |_, _| false,
intercept_set_binding: |_, _| false,
};
let holder = BindingHolder {
dependencies: Cell::new(0),
dep_nodes: Default::default(),
vtable: VT,
dirty: Cell::new(true), is_two_way_binding: false,
pinned: PhantomPinned,
binding: (),
#[cfg(slint_debug_property)]
debug_name: "<PropertyTracker<()>>".into(),
};
Self { holder }
}
}
impl<DirtyHandler> Drop for PropertyTracker<DirtyHandler> {
fn drop(&mut self) {
unsafe {
DependencyListHead::drop(self.holder.dependencies.as_ptr() as *mut DependencyListHead);
}
}
}
impl<DirtyHandler: PropertyDirtyHandler> PropertyTracker<DirtyHandler> {
#[cfg(slint_debug_property)]
pub fn set_debug_name(&mut self, debug_name: String) {
self.holder.debug_name = debug_name;
}
pub fn register_as_dependency_to_current_binding(self: Pin<&Self>) {
if CURRENT_BINDING.is_set() {
CURRENT_BINDING.with(|cur_binding| {
if let Some(cur_binding) = cur_binding {
debug_assert!(!core::ptr::eq(
self.holder.dependencies.get() as *const u32,
(&CONSTANT_PROPERTY_SENTINEL) as *const u32,
));
cur_binding.register_self_as_dependency(
self.holder.dependencies.as_ptr() as *mut DependencyListHead,
#[cfg(slint_debug_property)]
&self.holder.debug_name,
);
}
});
}
}
pub fn is_dirty(&self) -> bool {
self.holder.dirty.get()
}
pub fn evaluate<R>(self: Pin<&Self>, f: impl FnOnce() -> R) -> R {
self.register_as_dependency_to_current_binding();
self.evaluate_as_dependency_root(f)
}
pub fn evaluate_as_dependency_root<R>(self: Pin<&Self>, f: impl FnOnce() -> R) -> R {
self.holder.dep_nodes.set(Default::default());
let pinned_holder = unsafe {
self.map_unchecked(|s| {
core::mem::transmute::<&BindingHolder<DirtyHandler>, &BindingHolder<()>>(&s.holder)
})
};
let r = CURRENT_BINDING.set(Some(pinned_holder), f);
self.holder.dirty.set(false);
r
}
pub fn evaluate_if_dirty<R>(self: Pin<&Self>, f: impl FnOnce() -> R) -> Option<R> {
self.register_as_dependency_to_current_binding();
self.is_dirty().then(|| self.evaluate_as_dependency_root(f))
}
pub fn set_dirty(&self) {
self.holder.dirty.set(true);
unsafe { mark_dependencies_dirty(self.holder.dependencies.as_ptr() as *mut _) };
}
pub fn new_with_dirty_handler(handler: DirtyHandler) -> Self {
unsafe fn mark_dirty<B: PropertyDirtyHandler>(
_self: *const BindingHolder,
was_dirty: bool,
) {
if !was_dirty {
Pin::new_unchecked(&(*(_self as *const BindingHolder<B>)).binding).notify();
}
}
trait HasBindingVTable {
const VT: &'static BindingVTable;
}
impl<B: PropertyDirtyHandler> HasBindingVTable for B {
const VT: &'static BindingVTable = &BindingVTable {
drop: |_| (),
evaluate: |_, _| BindingResult::KeepBinding,
mark_dirty: mark_dirty::<B>,
intercept_set: |_, _| false,
intercept_set_binding: |_, _| false,
};
}
let holder = BindingHolder {
dependencies: Cell::new(0),
dep_nodes: Default::default(),
vtable: <DirtyHandler as HasBindingVTable>::VT,
dirty: Cell::new(true), is_two_way_binding: false,
pinned: PhantomPinned,
binding: handler,
#[cfg(slint_debug_property)]
debug_name: "<PropertyTracker>".into(),
};
Self { holder }
}
}
#[test]
fn test_property_listener_scope() {
let scope = Box::pin(PropertyTracker::default());
let prop1 = Box::pin(Property::new(42));
assert!(scope.is_dirty());
let r = scope.as_ref().evaluate(|| prop1.as_ref().get());
assert_eq!(r, 42);
assert!(!scope.is_dirty()); prop1.as_ref().set(88);
assert!(scope.is_dirty()); let r = scope.as_ref().evaluate(|| prop1.as_ref().get() + 1);
assert_eq!(r, 89);
assert!(!scope.is_dirty());
let r = scope.as_ref().evaluate(|| 12);
assert_eq!(r, 12);
assert!(!scope.is_dirty());
prop1.as_ref().set(1);
assert!(!scope.is_dirty());
scope.as_ref().evaluate_if_dirty(|| panic!("should not be dirty"));
scope.set_dirty();
let mut ok = false;
scope.as_ref().evaluate_if_dirty(|| ok = true);
assert!(ok);
}
#[test]
fn test_nested_property_trackers() {
let tracker1 = Box::pin(PropertyTracker::default());
let tracker2 = Box::pin(PropertyTracker::default());
let prop = Box::pin(Property::new(42));
let r = tracker1.as_ref().evaluate(|| tracker2.as_ref().evaluate(|| prop.as_ref().get()));
assert_eq!(r, 42);
prop.as_ref().set(1);
assert!(tracker2.as_ref().is_dirty());
assert!(tracker1.as_ref().is_dirty());
let r = tracker1
.as_ref()
.evaluate(|| tracker2.as_ref().evaluate_as_dependency_root(|| prop.as_ref().get()));
assert_eq!(r, 1);
prop.as_ref().set(100);
assert!(tracker2.as_ref().is_dirty());
assert!(!tracker1.as_ref().is_dirty());
}
#[test]
fn test_property_dirty_handler() {
let call_flag = Rc::new(Cell::new(false));
let tracker = Box::pin(PropertyTracker::new_with_dirty_handler({
let call_flag = call_flag.clone();
move || {
(*call_flag).set(true);
}
}));
let prop = Box::pin(Property::new(42));
let r = tracker.as_ref().evaluate(|| prop.as_ref().get());
assert_eq!(r, 42);
assert!(!tracker.as_ref().is_dirty());
assert!(!call_flag.get());
prop.as_ref().set(100);
assert!(tracker.as_ref().is_dirty());
assert!(call_flag.get());
call_flag.set(false);
prop.as_ref().set(101);
assert!(tracker.as_ref().is_dirty());
assert!(!call_flag.get());
}
#[test]
fn test_property_tracker_drop() {
let outer_tracker = Box::pin(PropertyTracker::default());
let inner_tracker = Box::pin(PropertyTracker::default());
let prop = Box::pin(Property::new(42));
let r =
outer_tracker.as_ref().evaluate(|| inner_tracker.as_ref().evaluate(|| prop.as_ref().get()));
assert_eq!(r, 42);
drop(inner_tracker);
prop.as_ref().set(200); }
#[test]
fn test_nested_property_tracker_dirty() {
let outer_tracker = Box::pin(PropertyTracker::default());
let inner_tracker = Box::pin(PropertyTracker::default());
let prop = Box::pin(Property::new(42));
let r =
outer_tracker.as_ref().evaluate(|| inner_tracker.as_ref().evaluate(|| prop.as_ref().get()));
assert_eq!(r, 42);
assert!(!outer_tracker.is_dirty());
assert!(!inner_tracker.is_dirty());
inner_tracker.as_ref().set_dirty();
assert!(outer_tracker.is_dirty());
}
#[test]
#[allow(clippy::redundant_closure)]
fn test_nested_property_tracker_evaluate_if_dirty() {
let outer_tracker = Box::pin(PropertyTracker::default());
let inner_tracker = Box::pin(PropertyTracker::default());
let prop = Box::pin(Property::new(42));
let mut cache = 0;
let mut cache_or_evaluate = || {
if let Some(x) = inner_tracker.as_ref().evaluate_if_dirty(|| prop.as_ref().get() + 1) {
cache = x;
}
cache
};
let r = outer_tracker.as_ref().evaluate(|| cache_or_evaluate());
assert_eq!(r, 43);
assert!(!outer_tracker.is_dirty());
assert!(!inner_tracker.is_dirty());
prop.as_ref().set(11);
assert!(outer_tracker.is_dirty());
assert!(inner_tracker.is_dirty());
let r = outer_tracker.as_ref().evaluate(|| cache_or_evaluate());
assert_eq!(r, 12);
}
#[cfg(feature = "ffi")]
pub(crate) mod ffi;