salsa/salsa-2022-tests/tests/parallel/parallel_cycle_one_recover.rs
2022-08-09 18:06:39 +08:00

91 lines
2.4 KiB
Rust

//! Test for cycle recover spread across two threads.
//! See `../cycles.rs` for a complete listing of cycle tests,
//! both intra and cross thread.
use crate::setup::Knobs;
use crate::setup::Database as DatabaseImpl;
use salsa::ParallelDatabase;
use crate::setup::Jar;
use crate::setup::Db;
#[salsa::input(jar = Jar)]
pub(crate) struct MyInput {
field: i32
}
#[salsa::tracked(jar = Jar)]
pub(crate) fn a1(db: &dyn Db, input: MyInput) -> i32 {
db.signal(1);
db.wait_for(2);
a2(db, input)
}
#[salsa::tracked(jar = Jar, recovery_fn=recover)]
pub(crate) fn a2(db: &dyn Db, input: MyInput) -> i32 {
b1(db, input)
}
fn recover(db: &dyn Db, _cycle: &salsa::Cycle, key: MyInput) -> i32 {
dbg!("recover");
key.field(db) * 20 + 2
}
#[salsa::tracked(jar = Jar)]
pub(crate) fn b1(db: &dyn Db, input: MyInput) -> i32 {
db.wait_for(1);
db.signal(2);
db.wait_for(3);
b2(db, input)
}
#[salsa::tracked(jar = Jar)]
pub(crate) fn b2(db: &dyn Db, input: MyInput) -> i32 {
a1(db, input)
}
// Recover cycle test:
//
// The pattern is as follows.
//
// Thread A Thread B
// -------- --------
// a1 b1
// | wait for stage 1 (blocks)
// signal stage 1 |
// wait for stage 2 (blocks) (unblocked)
// | signal stage 2
// (unblocked) wait for stage 3 (blocks)
// a2 |
// b1 (blocks -> stage 3) |
// | (unblocked)
// | b2
// | a1 (cycle detected)
// a2 recovery fn executes |
// a1 completes normally |
// b2 completes, recovers
// b1 completes, recovers
#[test]
fn execute() {
let mut db = DatabaseImpl::default();
db.knobs().signal_on_will_block.set(3);
let input = MyInput::new(&mut db, 1);
let thread_a = std::thread::spawn({
let db = db.snapshot();
move || a1(&*db, input)
});
let thread_b = std::thread::spawn({
let db = db.snapshot();
move || b1(&*db, input)
});
// We expect that the recovery function yields
// `1 * 20 + 2`, which is returned (and forwarded)
// to b1, and from there to a2 and a1.
assert_eq!(thread_a.join().unwrap(), 22);
assert_eq!(thread_b.join().unwrap(), 22);
}