(ctx context.Context)
| 783 | } |
| 784 | |
| 785 | func (rw *readerWriter) pollingLoop(ctx context.Context) { |
| 786 | ticker := time.NewTicker(rw.cfg.BlocklistPoll) |
| 787 | |
| 788 | for { |
| 789 | select { |
| 790 | case <-ctx.Done(): |
| 791 | close(rw.pollerShutdownCh) |
| 792 | return |
| 793 | case <-ticker.C: |
| 794 | rw.pollBlocklist(ctx) |
| 795 | } |
| 796 | } |
| 797 | } |
| 798 | |
| 799 | func (rw *readerWriter) pollBlocklist(ctx context.Context) { |
| 800 | blocklist, compactedBlocklist, err := rw.blocklistPoller.Do(ctx, rw.blocklist) |
no test coverage detected