()
| 57 | } |
| 58 | |
| 59 | func (e *eventProcessor) takeBatch() []watch.Event { |
| 60 | e.cond.L.Lock() |
| 61 | defer e.cond.L.Unlock() |
| 62 | |
| 63 | for len(e.buff) == 0 && !e.stopped() { |
| 64 | e.cond.Wait() |
| 65 | } |
| 66 | |
| 67 | batch := e.buff |
| 68 | e.buff = nil |
| 69 | return batch |
| 70 | } |
| 71 | |
| 72 | func (e *eventProcessor) writeBatch(events []watch.Event) { |
| 73 | for _, event := range events { |