diff options
| author | gluk256 <gluk256@gmail.com> | 2019-03-22 18:20:17 +0800 |
|---|---|---|
| committer | Viktor Trón <viktor.tron@gmail.com> | 2019-03-22 18:20:17 +0800 |
| commit | 8d04154691ef497f18816ac720f58b650d25e1e2 (patch) | |
| tree | 724d259eaa5c92f6b17e72f65d723fb604af842a /swarm/network/simulation/kademlia.go | |
| parent | 09924cbcaab5106951fb67648315131bb4024ac5 (diff) | |
| download | go-tangerine-8d04154691ef497f18816ac720f58b650d25e1e2.tar go-tangerine-8d04154691ef497f18816ac720f58b650d25e1e2.tar.gz go-tangerine-8d04154691ef497f18816ac720f58b650d25e1e2.tar.bz2 go-tangerine-8d04154691ef497f18816ac720f58b650d25e1e2.tar.lz go-tangerine-8d04154691ef497f18816ac720f58b650d25e1e2.tar.xz go-tangerine-8d04154691ef497f18816ac720f58b650d25e1e2.tar.zst go-tangerine-8d04154691ef497f18816ac720f58b650d25e1e2.zip | |
p2p/simulations: wait until all connections are recreated when uploading snapshot (#19312)
* swarm/network/simulation: test cases refactored
* swarm/pss: minor refactoring
* swarm/simulation: UploadSnapshot updated
* swarm/network: style fix
* swarm/pss: bugfix
Diffstat (limited to 'swarm/network/simulation/kademlia.go')
| -rw-r--r-- | swarm/network/simulation/kademlia.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/swarm/network/simulation/kademlia.go b/swarm/network/simulation/kademlia.go index 4b880aa0c..00e870a07 100644 --- a/swarm/network/simulation/kademlia.go +++ b/swarm/network/simulation/kademlia.go @@ -103,7 +103,7 @@ func (s *Simulation) kademlias() (ks map[enode.ID]*network.Kademlia) { // in the snapshot are registered in the kademlia. // It differs from WaitTillHealthy, which waits only until all the kademlias are // healthy (it might happen even before all the connections are established). -func (s *Simulation) WaitTillSnapshotRecreated(ctx context.Context, snap simulations.Snapshot) error { +func (s *Simulation) WaitTillSnapshotRecreated(ctx context.Context, snap *simulations.Snapshot) error { expected := getSnapshotConnections(snap.Conns) ticker := time.NewTicker(150 * time.Millisecond) defer ticker.Stop() |