Method loop

src/bcsdk/watcher.go:92–118

(ctx context.Context)

}

func (w *Watcher) loop(ctx context.Context) {
	defer w.wg.Done()
	defer close(w.out)

	buf := make([]blobcache.Message, 1)
	for {
		n, err := w.svc.Dequeue(ctx, w.qh, buf, blobcache.DequeueOpts{Min: 1})
		if err != nil {
			return
		}
		if n == 0 {
			continue
		}
		tx, err := BeginTx(ctx, w.svc, w.volh, blobcache.TxParams{
			Modify: false,
		})
		if err != nil {
			continue
		}
		select {
		case w.out <- tx:
		case <-ctx.Done():
			tx.Abort(ctx)
			return
		}
	}
}