mirrors/traefik
1
0
Fork 0
mirror of https://github.com/traefik/traefik.git synced 2025-10-28 06:51:35 +01:00
Code Issues Projects Releases Wiki Activity

Merge branch v3.5 into master

Browse Source
This commit is contained in:
romain 2025-10-23 15:08:33 +02:00
commit 067c7e7152
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/udp/conn_test.go
View File

@ -250,13 +250,19 @@ func TestShutdown(t *testing.T) {
// Start sending packets, to create a "session" with the server. // Start sending packets, to create a "session" with the server.
requireEcho(t, "TEST", conn, time.Second) requireEcho(t, "TEST", conn, time.Second)
shutdownStartedChan := make(chan struct{})
doneChan := make(chan struct{}) doneChan := make(chan struct{})
go func() { go func() {
close(shutdownStartedChan)
err := l.Shutdown(5 * time.Second) err := l.Shutdown(5 * time.Second)
require.NoError(t, err) require.NoError(t, err)
close(doneChan) close(doneChan)
}() }()
// Wait until shutdown has started, and hopefully after 100 ms the listener has stopped accepting new sessions.
<-shutdownStartedChan
time.Sleep(100 * time.Millisecond)
// Make sure that our session is still live even after the shutdown. // Make sure that our session is still live even after the shutdown.
requireEcho(t, "TEST2", conn, time.Second) requireEcho(t, "TEST2", conn, time.Second)