Reduced concurrency and increased wait time in TestPipeConnsCloseWhileReadWriteConcurrent, so it may pass on slow CPUs and/or with -race flag

This commit is contained in:
Aliaksandr Valialkin
2016-03-01 13:57:24 +02:00
parent 1e8901b798
commit 2a92d3c96e
+2 -2
View File
@@ -10,7 +10,7 @@ import (
)
func TestPipeConnsCloseWhileReadWriteConcurrent(t *testing.T) {
concurrency := 10
concurrency := 4
ch := make(chan struct{}, concurrency)
for i := 0; i < concurrency; i++ {
go func() {
@@ -22,7 +22,7 @@ func TestPipeConnsCloseWhileReadWriteConcurrent(t *testing.T) {
for i := 0; i < concurrency; i++ {
select {
case <-ch:
case <-time.After(time.Second):
case <-time.After(3*time.Second):
t.Fatalf("timeout")
}
}