(t *testing.T, client *derphttp.Client)
| 239 | } |
| 240 | |
| 241 | func recvData(t *testing.T, client *derphttp.Client) []byte { |
| 242 | for { |
| 243 | msg, err := client.Recv() |
| 244 | if errors.Is(err, io.EOF) { |
| 245 | return nil |
| 246 | } |
| 247 | assert.NoError(t, err) |
| 248 | t.Logf("derp: %T", msg) |
| 249 | switch msg := msg.(type) { |
| 250 | case derp.ReceivedPacket: |
| 251 | return msg.Data |
| 252 | default: |
| 253 | // Drop all others! |
| 254 | } |
| 255 | } |
| 256 | } |
| 257 | |
| 258 | func startDERP(t *testing.T, tlsConfig *tls.Config) (*derp.Server, string) { |
| 259 | logf := tailnet.Logger(testutil.Logger(t)) |
no test coverage detected