()
| 153 | } |
| 154 | |
| 155 | func (p *Peer) Disconnect() { |
| 156 | p.t.Helper() |
| 157 | req := &proto.CoordinateRequest{Disconnect: &proto.CoordinateRequest_Disconnect{}} |
| 158 | select { |
| 159 | case <-p.ctx.Done(): |
| 160 | p.t.Errorf("timeout updating node for %s", p.name) |
| 161 | return |
| 162 | case p.reqs <- req: |
| 163 | return |
| 164 | } |
| 165 | } |
| 166 | |
| 167 | func (p *Peer) AssertEventuallyHasDERP(other uuid.UUID, derp int32) { |
| 168 | p.t.Helper() |