homelab/endlessh-go
1
0
Fork 0
mirror of https://github.com/shizunge/endlessh-go.git synced 2026-06-23 04:10:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: integration test concurrency

Browse Source 
increase timeouts

clean

fix

fix

fix
This commit is contained in:
Ben G
2026-02-27 11:56:41 +01:00
parent 3fd26b15db
commit ebbcd539fc
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
endlessh_integration_test.go
+3 -4
View File
@@ -74,12 +74,12 @@ func TestEndlesshIntegration_MultiplePorts(t *testing.T) {
if err != nil {
t.Fatalf("Failed to connect to server on port %d: %v", port, err)
}
if !waitForLogMatch(&stderr, "ACCEPT host=127.0.0.1", waitForConnectTimeout) {
if !waitForLogMatch(&stderr, `ACCEPT host=(127\.0\.0\.1|::1)`, waitForConnectTimeout) {
t.Errorf("Never saw any ACCEPT log, got logs: %s", stderr.String())
}
conn.Close()
if !waitForLogMatch(&stderr, "CLOSE host=127.0.0.1", waitForConnectTimeout) {
if !waitForLogMatch(&stderr, `CLOSE host=(127\.0\.0\.1|::1)`, waitForConnectTimeout) {
t.Errorf("Never saw any CLOSE log, got logs: %s", stderr.String())
}
}
@@ -158,7 +158,6 @@ func TestEndlesshIntegration_Concurrency(t *testing.T) {
if !waitForLogMatch(&stderr, "Listening on", waitForListenTimeout) {
t.Fatalf("Timeout waiting for server to start, got logs: %s", stderr.String())
}
stderrOutput := stderr.String()
re := regexp.MustCompile(`Listening on .*:(\d+)`)
m := re.FindStringSubmatch(stderrOutput)
@@ -200,7 +199,7 @@ func TestEndlesshIntegration_Concurrency(t *testing.T) {
}
buf := make([]byte, 1024)
conn.SetReadDeadline(time.Now().Add(1 * time.Second))
conn.SetReadDeadline(time.Now().Add(3 * time.Second))
n1, readErr1 := conn.Read(buf)
if readErr1 != nil || n1 == 0 {
if clientID != maxClients { // only log unexpected failures