(e *proto.TelemetryEvent)
| 895 | } |
| 896 | |
| 897 | func (c *Conn) sendTelemetryBackground(e *proto.TelemetryEvent) { |
| 898 | c.mutex.Lock() |
| 899 | defer c.mutex.Unlock() |
| 900 | select { |
| 901 | case <-c.closed: |
| 902 | return |
| 903 | default: |
| 904 | } |
| 905 | c.telemetryWg.Add(1) |
| 906 | go func() { |
| 907 | defer c.telemetryWg.Done() |
| 908 | c.telemetrySink.SendTelemetryEvent(e) |
| 909 | }() |
| 910 | } |
| 911 | |
| 912 | // Watch for changes in the connection type (P2P<->DERP) and send telemetry events. |
| 913 | func (c *Conn) watchConnChange() { |
no test coverage detected