Mirrors/coredns
1
0
Fork 0
mirror of https://github.com/coredns/coredns.git synced 2025-10-28 08:44:17 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix(proxy): flaky dial tests (#7349)

Browse Source
This commit is contained in:
Ville Vesilehto
2025-06-05 00:36:59 +03:00
committed by GitHub
parent 9f9aed31cf
commit 11774d9e98
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
plugin/pkg/proxy/connect_test.go
View File

@@ -92,7 +92,7 @@ func TestDial_TransportStoppedDuringRetWait(t *testing.T) {
select { select {
case protoFromDial = <-tr.dial: case protoFromDial = <-tr.dial:
t.Logf("Test: Simulated connManager read '%s' from Dial via test-controlled tr.dial", protoFromDial) t.Logf("Test: Simulated connManager read '%s' from Dial via test-controlled tr.dial", protoFromDial)
case <-time.After(100 * time.Millisecond): case <-time.After(500 * time.Millisecond):
t.Fatal("Test: Timeout waiting for Dial to send on test-controlled tr.dial") t.Fatal("Test: Timeout waiting for Dial to send on test-controlled tr.dial")
} }
@@ -154,7 +154,7 @@ func TestDial_Returns_ErrTransportStoppedRetClosed(t *testing.T) {
t.Fatalf("Test: Dial sent wrong proto on testDialChan: got %s, want udp", proto) t.Fatalf("Test: Dial sent wrong proto on testDialChan: got %s, want udp", proto)
} }
t.Logf("Test: Simulated connManager received '%s' from Dial via testDialChan.", proto) t.Logf("Test: Simulated connManager received '%s' from Dial via testDialChan.", proto)
case <-time.After(100 * time.Millisecond): case <-time.After(500 * time.Millisecond):
// If Dial didn't send, the test is flawed or Dial is stuck before sending. // If Dial didn't send, the test is flawed or Dial is stuck before sending.
wg.Done() wg.Done()
t.Fatal("Test: Timeout waiting for Dial to send on testDialChan.") t.Fatal("Test: Timeout waiting for Dial to send on testDialChan.")
@@ -228,7 +228,7 @@ func TestDial_ConnManagerClosesRetOnStop(t *testing.T) {
} else { } else {
t.Logf("Interaction Dial completed without error.") t.Logf("Interaction Dial completed without error.")
} }
case <-time.After(100 * time.Millisecond): // Timeout for safety if Dial hangs case <-time.After(500 * time.Millisecond): // Timeout for safety if Dial hangs
t.Logf("Timeout waiting for interaction Dial to complete.") t.Logf("Timeout waiting for interaction Dial to complete.")
} }
} }