opensource/podman
1
0
Fork 0
mirror of https://github.com/containers/podman.git synced 2025-06-26 04:46:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #17083 from ygalblum/kube-port-test-set-deadline

Browse Source 
E2E Test: Play Kube set deadline to connection to avoid hangs
This commit is contained in:
OpenShift Merge Robot
2023-01-11 13:50:51 -05:00
committed by GitHub
parent f70233aa08 5b1bdf9490
commit 8a0d25f673
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
test/e2e/play_kube_test.go
View File

@ -1689,12 +1689,15 @@ func testHTTPServer(port string, shouldErr bool, expectedResponse string) {
Expect(string(body)).Should(Equal(expectedResponse)) Expect(string(body)).Should(Equal(expectedResponse))
} }
func testEchoServer(connection io.ReadWriter) { func testEchoServer(connection net.Conn) {
stringToSend := "hello world" stringToSend := "hello world"
var err error var err error
var bytesSent int var bytesSent int
interval := 250 * time.Millisecond interval := 250 * time.Millisecond
for i := 0; i < 6; i++ { for i := 0; i < 5; i++ {
err = connection.SetDeadline(time.Now().Add(time.Second))
Expect(err).To(BeNil())
bytesSent, err = fmt.Fprint(connection, stringToSend) bytesSent, err = fmt.Fprint(connection, stringToSend)
if err == nil { if err == nil {
break break
@ -1708,7 +1711,9 @@ func testEchoServer(connection io.ReadWriter) {
stringReceived := make([]byte, bytesSent) stringReceived := make([]byte, bytesSent)
var bytesRead int var bytesRead int
interval = 250 * time.Millisecond interval = 250 * time.Millisecond
for i := 0; i < 6; i++ { for i := 0; i < 5; i++ {
err = connection.SetDeadline(time.Now().Add(time.Second))
Expect(err).To(BeNil())
bytesRead, err = bufio.NewReader(connection).Read(stringReceived) bytesRead, err = bufio.NewReader(connection).Read(stringReceived)
if err == nil { if err == nil {
break break