Method
forwardEvents
(ctx context.Context, root string, w *fsWatcher)
Source from the content-addressed store, hash-verified
| 279 | } |
| 280 | |
| 281 | func (e *Engine) forwardEvents(ctx context.Context, root string, w *fsWatcher) { |
| 282 | defer e.wg.Done() |
| 283 | for { |
| 284 | select { |
| 285 | case <-ctx.Done(): |
| 286 | return |
| 287 | case <-e.closeCh: |
| 288 | return |
| 289 | case evts, ok := <-w.Events(): |
| 290 | if !ok { |
| 291 | return |
| 292 | } |
| 293 | select { |
| 294 | case e.eventCh <- rootEvent{root: root, events: evts}: |
| 295 | case <-ctx.Done(): |
| 296 | return |
| 297 | case <-e.closeCh: |
| 298 | return |
| 299 | } |
| 300 | } |
| 301 | } |
| 302 | } |
| 303 | |
| 304 | func (e *Engine) applyEvents(re rootEvent) { |
| 305 | e.mu.Lock() |
Tested by
no test coverage detected