github-personal/kubernetes
1
0
Fork 0
mirror of https://github.com/outbackdingo/kubernetes.git synced 2026-01-27 10:19:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: fix TestStructuredAuthenticationConfigReload flake by handling expected network errors

Browse Source 
Signed-off-by: Anish Ramasekar <anish.ramasekar@gmail.com>
This commit is contained in:
Anish Ramasekar
2025-07-29 07:03:22 +00:00
parent 1ce98e3c09
commit 48eef9ce9a
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
test/integration/apiserver/oidc/egress_test.go
View File

@@ -18,15 +18,16 @@ package oidc
import (
"context"
"errors"
"io"
"net"
"net/http"
"strings"
"sync"
"sync/atomic"
"testing"
"time"
utilnet "k8s.io/apimachinery/pkg/util/net"
"k8s.io/apimachinery/pkg/util/wait"
)
@@ -86,7 +87,7 @@ func runEgressProxy(t testing.TB, udsName string, ready chan<- struct{}) {
go func() {
_, err := io.Copy(backendConn, requestHijackedConn)
if err != nil && !strings.Contains(err.Error(), "use of closed network connection") {
if err != nil && !utilnet.IsProbableEOF(err) {
t.Errorf("unexpected writer error: %v", err)
}
close(writerComplete)
@@ -94,7 +95,7 @@ func runEgressProxy(t testing.TB, udsName string, ready chan<- struct{}) {
go func() {
_, err := io.Copy(requestHijackedConn, backendConn)
if err != nil && !strings.Contains(err.Error(), "use of closed network connection") {
if err != nil && !utilnet.IsProbableEOF(err) {
t.Errorf("unexpected reader error: %v", err)
}
close(readerComplete)
@@ -116,7 +117,9 @@ func runEgressProxy(t testing.TB, udsName string, ready chan<- struct{}) {
}
err := server.Shutdown(context.Background())
t.Logf("shutdown exit error: %v", err)
if err != nil && !utilnet.IsProbableEOF(err) {
t.Logf("shutdown exit error: %v", err)
}
})
var once sync.Once
@@ -147,5 +150,7 @@ func runEgressProxy(t testing.TB, udsName string, ready chan<- struct{}) {
}()
err = server.Serve(l)
t.Logf("egress exit error: %v", err)
if err != nil && !errors.Is(err, http.ErrServerClosed) {
t.Logf("egress exit error: %v", err)
}
}