mirror of
https://github.com/portainer/portainer.git
synced 2025-07-22 14:59:41 +02:00
fix(tests): fix data races EE-6867 (#11387)
Some checks are pending
ci / build_images (map[arch:amd64 platform:linux version:]) (push) Waiting to run
ci / build_images (map[arch:amd64 platform:windows version:1809]) (push) Waiting to run
ci / build_images (map[arch:amd64 platform:windows version:ltsc2022]) (push) Waiting to run
ci / build_images (map[arch:arm platform:linux version:]) (push) Waiting to run
ci / build_images (map[arch:arm64 platform:linux version:]) (push) Waiting to run
ci / build_images (map[arch:ppc64le platform:linux version:]) (push) Waiting to run
ci / build_images (map[arch:s390x platform:linux version:]) (push) Waiting to run
ci / build_manifests (push) Blocked by required conditions
/ triage (push) Waiting to run
Lint / Run linters (push) Waiting to run
Test / test-client (push) Waiting to run
Test / test-server (map[arch:amd64 platform:linux]) (push) Waiting to run
Test / test-server (map[arch:amd64 platform:windows version:1809]) (push) Waiting to run
Test / test-server (map[arch:amd64 platform:windows version:ltsc2022]) (push) Waiting to run
Test / test-server (map[arch:arm64 platform:linux]) (push) Waiting to run
Some checks are pending
ci / build_images (map[arch:amd64 platform:linux version:]) (push) Waiting to run
ci / build_images (map[arch:amd64 platform:windows version:1809]) (push) Waiting to run
ci / build_images (map[arch:amd64 platform:windows version:ltsc2022]) (push) Waiting to run
ci / build_images (map[arch:arm platform:linux version:]) (push) Waiting to run
ci / build_images (map[arch:arm64 platform:linux version:]) (push) Waiting to run
ci / build_images (map[arch:ppc64le platform:linux version:]) (push) Waiting to run
ci / build_images (map[arch:s390x platform:linux version:]) (push) Waiting to run
ci / build_manifests (push) Blocked by required conditions
/ triage (push) Waiting to run
Lint / Run linters (push) Waiting to run
Test / test-client (push) Waiting to run
Test / test-server (map[arch:amd64 platform:linux]) (push) Waiting to run
Test / test-server (map[arch:amd64 platform:windows version:1809]) (push) Waiting to run
Test / test-server (map[arch:amd64 platform:windows version:ltsc2022]) (push) Waiting to run
Test / test-server (map[arch:arm64 platform:linux]) (push) Waiting to run
This commit is contained in:
parent
573f003226
commit
bd3440bf3c
2 changed files with 11 additions and 4 deletions
|
@ -1,6 +1,7 @@
|
||||||
package chisel
|
package chisel
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"context"
|
||||||
"net"
|
"net"
|
||||||
"net/http"
|
"net/http"
|
||||||
"testing"
|
"testing"
|
||||||
|
@ -28,12 +29,17 @@ func TestPingAgentPanic(t *testing.T) {
|
||||||
ln, err := net.ListenTCP("tcp", &net.TCPAddr{IP: net.IPv4(127, 0, 0, 1), Port: 0})
|
ln, err := net.ListenTCP("tcp", &net.TCPAddr{IP: net.IPv4(127, 0, 0, 1), Port: 0})
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
srv := &http.Server{Handler: mux}
|
||||||
|
|
||||||
|
errCh := make(chan error)
|
||||||
go func() {
|
go func() {
|
||||||
require.NoError(t, http.Serve(ln, mux))
|
errCh <- srv.Serve(ln)
|
||||||
}()
|
}()
|
||||||
|
|
||||||
s.getTunnelDetails(endpointID)
|
s.getTunnelDetails(endpointID)
|
||||||
s.tunnelDetailsMap[endpointID].Port = ln.Addr().(*net.TCPAddr).Port
|
s.tunnelDetailsMap[endpointID].Port = ln.Addr().(*net.TCPAddr).Port
|
||||||
|
|
||||||
require.Error(t, s.pingAgent(endpointID))
|
require.Error(t, s.pingAgent(endpointID))
|
||||||
|
require.NoError(t, srv.Shutdown(context.Background()))
|
||||||
|
require.ErrorIs(t, <-errCh, http.ErrServerClosed)
|
||||||
}
|
}
|
||||||
|
|
|
@ -138,13 +138,14 @@ func agentServer(t *testing.T) string {
|
||||||
Handler: h,
|
Handler: h,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
errCh := make(chan error)
|
||||||
go func() {
|
go func() {
|
||||||
err := s.Serve(l)
|
errCh <- s.Serve(l)
|
||||||
require.ErrorIs(t, err, http.ErrServerClosed)
|
|
||||||
}()
|
}()
|
||||||
|
|
||||||
t.Cleanup(func() {
|
t.Cleanup(func() {
|
||||||
s.Shutdown(context.Background())
|
require.NoError(t, s.Shutdown(context.Background()))
|
||||||
|
require.ErrorIs(t, <-errCh, http.ErrServerClosed)
|
||||||
})
|
})
|
||||||
|
|
||||||
return "http://" + l.Addr().String()
|
return "http://" + l.Addr().String()
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue