瀏覽代碼

pkg/transport: extend wait timeout for write

This helps the test to pass safely in semaphore CI.

Based on my manual testing, it may take at most 500ms to return
error in semaphore CI, so I set 1s as a safe value.
Yicheng Qin 10 年之前
父節點
當前提交
d3ebecdddd
共有 2 個文件被更改,包括 4 次插入2 次删除
  1. 2 1
      pkg/transport/timeout_dialer_test.go
  2. 2 1
      pkg/transport/timeout_listener_test.go

+ 2 - 1
pkg/transport/timeout_dialer_test.go

@@ -50,7 +50,8 @@ func TestReadWriteTimeoutDialer(t *testing.T) {
 
 	select {
 	case <-done:
-	case <-time.After(d.wtimeoutd * 10):
+	// It waits 1s more to avoid delay in low-end system.
+	case <-time.After(d.wtimeoutd*10 + time.Second):
 		t.Fatal("wait timeout")
 	}
 

+ 2 - 1
pkg/transport/timeout_listener_test.go

@@ -76,7 +76,8 @@ func TestWriteReadTimeoutListener(t *testing.T) {
 
 	select {
 	case <-done:
-	case <-time.After(wln.wtimeoutd * 10):
+	// It waits 1s more to avoid delay in low-end system.
+	case <-time.After(wln.wtimeoutd*10 + time.Second):
 		t.Fatal("wait timeout")
 	}