(cmds []*exec.Cmd)
| 250 | } |
| 251 | |
| 252 | func startPipeCommands(cmds []*exec.Cmd) error { |
| 253 | for i := len(cmds) - 1; i >= 0; i-- { |
| 254 | if err := cmds[i].Start(); err != nil { |
| 255 | killStarted(cmds[i+1:]) |
| 256 | return err |
| 257 | } |
| 258 | } |
| 259 | return nil |
| 260 | } |
| 261 | |
| 262 | func waitPipeCommands(ctx context.Context, cmds []*exec.Cmd) error { |
| 263 | done := make(chan error, 1) |
no test coverage detected