(seq dag.Seq)
| 138 | } |
| 139 | |
| 140 | func (o *Optimizer) optimizeParallels(seq dag.Seq) { |
| 141 | Walk(seq, func(seq dag.Seq) dag.Seq { |
| 142 | for ops := seq; len(ops) >= 2; ops = ops[1:] { |
| 143 | o.liftIntoParPaths(ops) |
| 144 | } |
| 145 | return seq |
| 146 | }) |
| 147 | } |
| 148 | |
| 149 | // liftIntoParPaths examines seq to see if there's an opportunity to |
| 150 | // lift operations downstream from a parallel op into its parallel paths to |
no test coverage detected