opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-09-10 09:52:20 +08:00
Code Issues Projects Releases Wiki Activity

dht/bootstrap/test: longer timeout, less bias

Browse Source
This commit is contained in:
Juan Batiz-Benet
2015-01-05 07:19:07 -08:00
parent dfcea4c6f1
commit 1d9977c850
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
routing/dht/dht_test.go
View File

@ -3,6 +3,7 @@ package dht
import ( import (
"bytes" "bytes"
"fmt" "fmt"
"math/rand"
"sort" "sort"
"sync" "sync"
"testing" "testing"
@ -76,6 +77,7 @@ func bootstrap(t *testing.T, ctx context.Context, dhts []*IpfsDHT) {
ctx, cancel := context.WithCancel(ctx) ctx, cancel := context.WithCancel(ctx)
rounds := 1 rounds := 1
for i := 0; i < rounds; i++ { for i := 0; i < rounds; i++ {
log.Debugf("bootstrapping round %d/%d\n", i, rounds) log.Debugf("bootstrapping round %d/%d\n", i, rounds)
@ -83,7 +85,10 @@ func bootstrap(t *testing.T, ctx context.Context, dhts []*IpfsDHT) {
// 100 async https://gist.github.com/jbenet/56d12f0578d5f34810b2 // 100 async https://gist.github.com/jbenet/56d12f0578d5f34810b2
// 100 sync https://gist.github.com/jbenet/6c59e7c15426e48aaedd // 100 sync https://gist.github.com/jbenet/6c59e7c15426e48aaedd
// probably because results compound // probably because results compound
for _, dht := range dhts {
start := rand.Intn(len(dhts)) // randomize to decrease bias.
for i := range dhts {
dht := dhts[(start+i)%len(dhts)]
log.Debugf("bootstrapping round %d/%d -- %s\n", i, rounds, dht.self) log.Debugf("bootstrapping round %d/%d -- %s\n", i, rounds, dht.self)
dht.Bootstrap(ctx, 3) dht.Bootstrap(ctx, 3)
} }
@ -309,7 +314,7 @@ func TestProvidesMany(t *testing.T) {
<-time.After(100 * time.Millisecond) <-time.After(100 * time.Millisecond)
t.Logf("bootstrapping them so they find each other", nDHTs) t.Logf("bootstrapping them so they find each other", nDHTs)
ctxT, _ := context.WithTimeout(ctx, 5*time.Second) ctxT, _ := context.WithTimeout(ctx, 20*time.Second)
bootstrap(t, ctxT, dhts) bootstrap(t, ctxT, dhts)
if u.Debug { if u.Debug {