opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-08-06 19:44:01 +08:00
Code Issues Projects Releases Wiki Activity

p2p/test/reconnect: fixed race condition

Browse Source
This commit is contained in:
Juan Batiz-Benet
2015-01-20 10:57:45 -08:00
parent 0b9bef1ea9
commit 239e82390f
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
p2p/test/reconnects/reconnect_test.go
View File

@ -188,16 +188,16 @@ func SubtestConnSendDisc(t *testing.T, hosts []host.Host) {
defer wg.Done()
go sF(s)
log.Debugf("getting handle %d", i)
log.Debugf("getting handle %d", j)
sc := <-ss // wait to get handle.
log.Debugf("spawning worker %d", i)
log.Debugf("spawning worker %d", j)
for i := 0; i < numMsgs; i++ {
for k := 0; k < numMsgs; k++ {
sc.send <- struct{}{}
<-sc.sent
log.Debugf("%d sent %d", j, i)
log.Debugf("%d sent %d", j, k)
<-sc.read
log.Debugf("%d read %d", j, i)
log.Debugf("%d read %d", j, k)
}
sc.close_ <- struct{}{}
<-sc.closed