(event watch.Event)
| 80 | } |
| 81 | |
| 82 | func (e *eventProcessor) push(event watch.Event) { |
| 83 | e.cond.L.Lock() |
| 84 | defer e.cond.L.Unlock() |
| 85 | defer e.cond.Signal() |
| 86 | e.buff = append(e.buff, event) |
| 87 | } |
| 88 | |
| 89 | func (e *eventProcessor) stopped() bool { |
| 90 | select { |
no outgoing calls