()
| 194 | } |
| 195 | |
| 196 | func (c *command) runProcesses() { |
| 197 | for _, p := range c.processes { |
| 198 | c.doneWg.Add(1) |
| 199 | |
| 200 | go func(p *process, trig chan bool, wg *sync.WaitGroup) { |
| 201 | defer wg.Done() |
| 202 | defer func() { trig <- true }() |
| 203 | |
| 204 | p.StartObserving() |
| 205 | }(p, c.doneTrig, &c.doneWg) |
| 206 | } |
| 207 | |
| 208 | utils.FatalOnErr(c.tmux.Start()) |
| 209 | } |
| 210 | |
| 211 | func (c *command) waitForExit() { |
| 212 | signal.Notify(c.stopTrig, syscall.SIGINT, syscall.SIGTERM, syscall.SIGHUP) |
no test coverage detected