salsa/tests/accumulate-reuse.rs
Niko Matsakis 8a39bf029b wip
2024-07-16 06:04:01 -04:00

92 lines
2 KiB
Rust

//! Accumulator re-use test.
//!
//! Tests behavior when a query's only inputs
//! are the accumulated values from another query.
mod common;
use common::{HasLogger, Logger};
use expect_test::expect;
use salsa::prelude::*;
use test_log::test;
#[salsa::db]
trait Db: salsa::Database + HasLogger {}
#[salsa::input]
struct List {
value: u32,
next: Option<List>,
}
#[salsa::accumulator]
#[derive(Clone, Debug)]
struct Integers(u32);
#[salsa::tracked]
fn compute(db: &dyn Db, input: List) -> u32 {
db.push_log(format!("compute({:?})", input,));
// always pushes 0
Integers(0).accumulate(db);
let result = if let Some(next) = input.next(db) {
let next_integers = compute::accumulated::<Integers>(db, next);
let v = input.value(db) + next_integers.iter().map(|i| i.0).sum::<u32>();
v
} else {
input.value(db)
};
// return value changes
result
}
#[salsa::db]
#[derive(Default)]
struct Database {
storage: salsa::Storage<Self>,
logger: Logger,
}
#[salsa::db]
impl salsa::Database for Database {
fn salsa_event(&self, _event: salsa::Event) {}
}
#[salsa::db]
impl Db for Database {}
impl HasLogger for Database {
fn logger(&self) -> &Logger {
&self.logger
}
}
#[test]
fn test1() {
let mut db = Database::default();
let l1 = List::new(&db, 1, None);
let l2 = List::new(&db, 2, Some(l1));
assert_eq!(compute(&db, l2), 2);
db.assert_logs(expect![[r#"
[
"compute(List { [salsa id]: 1 })",
"compute(List { [salsa id]: 0 })",
]"#]]);
// When we mutate `l1`, we should re-execute `compute` for `l1`,
// but we should not have to re-execute `compute` for `l2`.
// The only input for `compute(l1)` is the accumulated values from `l1`,
// which have not changed.
l1.set_value(&mut db).to(2);
assert_eq!(compute(&db, l2), 2);
db.assert_logs(expect![[r#"
[
"compute(List { [salsa id]: 1 })",
"compute(List { [salsa id]: 0 })",
]"#]]);
}