mirror of
https://github.com/salsa-rs/salsa.git
synced 2024-11-25 04:27:52 +00:00
Change uses of fork
to snapshot
This commit is contained in:
parent
83482293c6
commit
461ab22822
2 changed files with 4 additions and 3 deletions
|
@ -786,7 +786,8 @@ where
|
|||
key,
|
||||
input
|
||||
)
|
||||
}).next()
|
||||
})
|
||||
.next()
|
||||
.is_some();
|
||||
|
||||
// Either way, we have to update our entry.
|
||||
|
|
|
@ -96,7 +96,7 @@ fn true_parallel_propagate_panic() {
|
|||
// `thread1` will wait_for a barrier in the start of `sum`. Once it can
|
||||
// continue, it will panic.
|
||||
let thread1 = std::thread::spawn({
|
||||
let db = db.fork();
|
||||
let db = db.snapshot();
|
||||
move || {
|
||||
let v = db.knobs().sum_signal_on_entry.with_value(1, || {
|
||||
db.knobs().sum_wait_for_on_exit.with_value(2, || {
|
||||
|
@ -110,7 +110,7 @@ fn true_parallel_propagate_panic() {
|
|||
// `thread2` will wait until `thread1` has entered sum and then -- once it
|
||||
// has set itself to block -- signal `thread1` to continue.
|
||||
let thread2 = std::thread::spawn({
|
||||
let db = db.fork();
|
||||
let db = db.snapshot();
|
||||
move || {
|
||||
db.knobs().signal.wait_for(1);
|
||||
db.knobs().signal_on_will_block.set(2);
|
||||
|
|
Loading…
Reference in a new issue