k2safe/go-omni
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test: wait for native request slot release

Browse Source
This commit is contained in:
k2safe
2026-09-22 18:24:51 +08:00
parent 95dc4568f6
commit 4a8feaca36
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
transport/native/server_test.go
View File

@@ -785,6 +785,13 @@ func TestServerConcurrentRequestLimitRecovers(t *testing.T) {
if response.StatusCode != http.StatusOK { if response.StatusCode != http.StatusOK {
t.Fatalf("expected held request to complete, got %d", response.StatusCode) t.Fatalf("expected held request to complete, got %d", response.StatusCode)
} }
deadline := time.Now().Add(time.Second)
for server.Stats().ActiveRequests != 0 && time.Now().Before(deadline) {
time.Sleep(time.Millisecond)
}
if stats := server.Stats(); stats.ActiveRequests != 0 {
t.Fatalf("request slot was not released after response: %+v", stats)
}
thirdConn, err := net.Dial("tcp", listener.Addr().String()) thirdConn, err := net.Dial("tcp", listener.Addr().String())
if err != nil { if err != nil {