Test: rework concurrentExchange (#576)
See issue #575. Try to fix (and maybe trigger it)
This commit is contained in:
parent
99c447f9f6
commit
7994cb36ea
|
@ -568,11 +568,11 @@ func TestConcurrentExchanges(t *testing.T) {
|
||||||
wg.Add(len(r))
|
wg.Add(len(r))
|
||||||
for i := 0; i < len(r); i++ {
|
for i := 0; i < len(r); i++ {
|
||||||
go func(i int) {
|
go func(i int) {
|
||||||
|
defer wg.Done()
|
||||||
r[i], _, _ = c.Exchange(m.Copy(), addrstr)
|
r[i], _, _ = c.Exchange(m.Copy(), addrstr)
|
||||||
if r[i] == nil {
|
if r[i] == nil {
|
||||||
t.Fatalf("response %d is nil", i)
|
t.Errorf("response %d is nil", i)
|
||||||
}
|
}
|
||||||
wg.Done()
|
|
||||||
}(i)
|
}(i)
|
||||||
}
|
}
|
||||||
select {
|
select {
|
||||||
|
|
Loading…
Reference in New Issue