(cmds []*exec.Cmd)
| 271 | } |
| 272 | |
| 273 | func startPipeCommands(cmds []*exec.Cmd) error { |
| 274 | for i := len(cmds) - 1; i >= 0; i-- { |
| 275 | if err := cmds[i].Start(); err != nil { |
| 276 | killStarted(cmds[i+1:]) |
| 277 | return err |
| 278 | } |
| 279 | } |
| 280 | return nil |
| 281 | } |
| 282 | |
| 283 | func waitPipeCommands(ctx context.Context, cmds []*exec.Cmd) error { |
| 284 | done := make(chan error, 1) |
no test coverage detected