Skip to content
Snippets Groups Projects
Commit 40b1a705 authored by Russel Arbore's avatar Russel Arbore
Browse files

fix

parent a78fb836
No related branches found
No related tags found
1 merge request!143Fork improvements
Pipeline #201363 passed
...@@ -349,19 +349,23 @@ pub fn forkify_loop( ...@@ -349,19 +349,23 @@ pub fn forkify_loop(
}; };
let reduce_id = edit.add_node(reduce); let reduce_id = edit.add_node(reduce);
if edit.get_schedule(init).contains(&Schedule::ParallelReduce) if (!edit.get_node(init).is_reduce()
|| edit && edit.get_schedule(init).contains(&Schedule::ParallelReduce))
.get_schedule(continue_latch) || (!edit.get_node(continue_latch).is_reduce()
.contains(&Schedule::ParallelReduce) && edit
.get_schedule(continue_latch)
.contains(&Schedule::ParallelReduce))
{ {
edit = edit.add_schedule(reduce_id, Schedule::ParallelReduce)?; edit = edit.add_schedule(reduce_id, Schedule::ParallelReduce)?;
} }
if edit if (!edit.get_node(init).is_reduce()
.get_schedule(init) && edit
.contains(&Schedule::TightAssociative) .get_schedule(init)
|| edit .contains(&Schedule::TightAssociative))
.get_schedule(continue_latch) || (!edit.get_node(continue_latch).is_reduce()
.contains(&Schedule::TightAssociative) && edit
.get_schedule(continue_latch)
.contains(&Schedule::TightAssociative))
{ {
edit = edit.add_schedule(reduce_id, Schedule::TightAssociative)?; edit = edit.add_schedule(reduce_id, Schedule::TightAssociative)?;
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment