()
| 614 | } |
| 615 | |
| 616 | func (a *pollingDERPClient) Recv() (*tailcfg.DERPMap, error) { |
| 617 | select { |
| 618 | case <-a.ctx.Done(): |
| 619 | return nil, a.ctx.Err() |
| 620 | case dm := <-a.ch: |
| 621 | return dm, nil |
| 622 | } |
| 623 | } |
| 624 | |
| 625 | func (a *pollingDERPClient) pollDERP() { |
| 626 | defer close(a.loopDone) |