forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/network/stream: cleanup for PR

Browse source
This commit is contained in:
Fabio Barone 2019-03-04 18:18:29 -05:00
parent 83ecad8ce7
commit 750845fcd9
3 changed files with 2 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
p2p/simulations/network.go
View file

@ -841,7 +841,7 @@ func (net *Network) snapshot(addServices []string, removeServices []string) (*Sn
}
// longrunning tests may need a longer timeout
var snapshotLoadTimeout = 7200 * time.Second
var snapshotLoadTimeout = 900 * time.Second
// Load loads a network snapshot
func (net *Network) Load(snap *Snapshot) error {

8
swarm/network/stream/delivery_test.go
View file

@ -534,14 +534,6 @@ func testDeliveryFromNodes(t *testing.T, nodes, chunkCount int, skipCheck bool)
return err
}
log.Debug("Waiting for kademlia")
// TODO this does not seem to be correct usage of the function, as the simulation may have no kademlias
/*
if _, err := sim.WaitTillHealthy(ctx); err != nil {
return err
}
*/
//get the pivot node's filestore
item, ok := sim.NodeItem(pivot, bucketKeyFileStore)
if !ok {

2
swarm/network/stream/snapshot_retrieval_test.go
View file

@ -86,7 +86,7 @@ func TestRetrieval(t *testing.T) {
chnkCnt := []int{32}
if *longrunning {
nodeCnt = []int{16, 32, 128}
nodeCnt = []int{16, 32, 64}
chnkCnt = []int{4, 32, 256}
} else if testutil.RaceEnabled {
nodeCnt = []int{4}