Skip to content
Snippets Groups Projects

Fork reshape

Merged Aaron Councilman requested to merge fork-reshape into main
1 file
+ 8
0
Compare changes
  • Side-by-side
  • Inline
@@ -719,6 +719,11 @@ pub fn fork_coalesce_helper(
@@ -719,6 +719,11 @@ pub fn fork_coalesce_helper(
};
};
let new_fork = edit.add_node(new_fork);
let new_fork = edit.add_node(new_fork);
 
if edit.get_schedule(outer_fork).contains(&Schedule::ParallelFork)
 
&& edit.get_schedule(inner_fork).contains(&Schedule::ParallelFork) {
 
edit = edit.add_schedule(new_fork, Schedule::ParallelFork)?;
 
}
 
edit = edit.replace_all_uses(inner_fork, new_fork)?;
edit = edit.replace_all_uses(inner_fork, new_fork)?;
edit = edit.replace_all_uses(outer_fork, new_fork)?;
edit = edit.replace_all_uses(outer_fork, new_fork)?;
edit = edit.replace_all_uses(outer_join, inner_join)?;
edit = edit.replace_all_uses(outer_join, inner_join)?;
@@ -1271,6 +1276,9 @@ fn fork_interchange(
@@ -1271,6 +1276,9 @@ fn fork_interchange(
edit = edit.delete_node(old_id)?;
edit = edit.delete_node(old_id)?;
}
}
let new_fork = edit.add_node(new_fork);
let new_fork = edit.add_node(new_fork);
 
if edit.get_schedule(fork).contains(&Schedule::ParallelFork) {
 
edit = edit.add_schedule(new_fork, Schedule::ParallelFork)?;
 
}
edit = edit.replace_all_uses(fork, new_fork)?;
edit = edit.replace_all_uses(fork, new_fork)?;
edit.delete_node(fork)
edit.delete_node(fork)
});
});
Loading