diff options
| author | holisticode <holistic.computing@gmail.com> | 2018-07-31 04:55:25 +0800 |
|---|---|---|
| committer | Balint Gabor <balint.g@gmail.com> | 2018-07-31 04:55:25 +0800 |
| commit | d6efa691872efb723ea3177a92da9e9b31c34eba (patch) | |
| tree | 9c7e85c9cab9a2cf1240db47a8de44162f69353e /swarm/network/simulation/connect.go | |
| parent | 3ea8ac6a9ab9e56164707119e9142f06fae4c316 (diff) | |
| download | go-tangerine-d6efa691872efb723ea3177a92da9e9b31c34eba.tar go-tangerine-d6efa691872efb723ea3177a92da9e9b31c34eba.tar.gz go-tangerine-d6efa691872efb723ea3177a92da9e9b31c34eba.tar.bz2 go-tangerine-d6efa691872efb723ea3177a92da9e9b31c34eba.tar.lz go-tangerine-d6efa691872efb723ea3177a92da9e9b31c34eba.tar.xz go-tangerine-d6efa691872efb723ea3177a92da9e9b31c34eba.tar.zst go-tangerine-d6efa691872efb723ea3177a92da9e9b31c34eba.zip | |
Merge netsim mig to master (#17241)
* swarm: merged stream-tests migration to develop
* swarm/network: expose simulation RandomUpNode to use in stream tests
* swarm/network: wait for subs in PeerEvents and fix stream.runSyncTest
* swarm: enforce waitkademlia for snapshot tests
* swarm: fixed syncer tests and snapshot_sync_test
* swarm: linting of simulation package
* swarm: address review comments
* swarm/network/stream: fix delivery_test bugs and refactor
* swarm/network/stream: addressed PR comments @janos
* swarm/network/stream: enforce waitKademlia, improve TestIntervals
* swarm/network/stream: TestIntervals not waiting for chunk to be stored
Diffstat (limited to 'swarm/network/simulation/connect.go')
| -rw-r--r-- | swarm/network/simulation/connect.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/swarm/network/simulation/connect.go b/swarm/network/simulation/connect.go index 3fe82052b..3d0f6cb3f 100644 --- a/swarm/network/simulation/connect.go +++ b/swarm/network/simulation/connect.go @@ -54,7 +54,7 @@ func (s *Simulation) ConnectToLastNode(id discover.NodeID) (err error) { // ConnectToRandomNode connects the node with provieded NodeID // to a random node that is up. func (s *Simulation) ConnectToRandomNode(id discover.NodeID) (err error) { - n := s.randomUpNode(id) + n := s.RandomUpNode(id) if n == nil { return ErrNodeNotFound } @@ -135,7 +135,7 @@ func (s *Simulation) ConnectNodesStar(id discover.NodeID, ids []discover.NodeID) return nil } -// ConnectNodesStar connects all nodes in a star topology +// ConnectNodesStarPivot connects all nodes in a star topology // with the center at already set pivot node. // If ids argument is nil, all nodes that are up will be connected. func (s *Simulation) ConnectNodesStarPivot(ids []discover.NodeID) (err error) { |