fix: use SO_REUSEADDR in delayed listener test to prevent TIME_WAIT flakiness

1 file · +9 -1

M internal/usecase/container/readiness_test.go +9 -1


@@ -6,6 +6,7 @@ import (
6	6		"net/http"
7	7		"net/http/httptest"
8	8		"sync/atomic"
	9	+	"syscall"
9	10		"testing"
10	11		"time"
11	12

@@ -67,7 +68,14 @@ func TestTCPProbe_DelayedListener(t *testing.T) {
67	68		// Re-open after 1 second
68	69		go func() {
69	70		time.Sleep(time.Second)
70		-	newLn, err := net.Listen("tcp", addr)
	71	+	lc := net.ListenConfig{
	72	+	Control: func(network, address string, c syscall.RawConn) error {
	73	+	return c.Control(func(fd uintptr) {
	74	+	_ = syscall.SetsockoptInt(int(fd), syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1)
	75	+	})
	76	+	},
	77	+	}
	78	+	newLn, err := lc.Listen(context.Background(), "tcp", addr)
71	79		if err != nil {
72	80		t.Logf("delayed listener failed to bind: %v", err)
73	81		return

 	"net/http"
 	"net/http/httptest"
 	"sync/atomic"
+	"syscall"
 	"testing"
 	"time"
 	// Re-open after 1 second
 	go func() {
 		time.Sleep(time.Second)
-		newLn, err := net.Listen("tcp", addr)
+		lc := net.ListenConfig{
+			Control: func(network, address string, c syscall.RawConn) error {
+				return c.Control(func(fd uintptr) {
+					_ = syscall.SetsockoptInt(int(fd), syscall.SOL_SOCKET, syscall.SO_REUSEADDR, 1)
+				})
+			},
+		}
+		newLn, err := lc.Listen(context.Background(), "tcp", addr)
 		if err != nil {
 			t.Logf("delayed listener failed to bind: %v", err)
 			return