diff options
| author | Mission Liao <mission.liao@dexon.org> | 2019-01-03 16:00:45 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-01-03 16:00:45 +0800 |
| commit | 09a00a0580c2fd6e11b17f1793edca5f7bb2f5f8 (patch) | |
| tree | 12362787be4d3b6bcd0051591a7bc0c60d859878 /simulation/peer-server.go | |
| parent | 5739e74781092ac09d8b3a575cddc71b50beedf4 (diff) | |
| download | dexon-consensus-09a00a0580c2fd6e11b17f1793edca5f7bb2f5f8.tar dexon-consensus-09a00a0580c2fd6e11b17f1793edca5f7bb2f5f8.tar.gz dexon-consensus-09a00a0580c2fd6e11b17f1793edca5f7bb2f5f8.tar.bz2 dexon-consensus-09a00a0580c2fd6e11b17f1793edca5f7bb2f5f8.tar.lz dexon-consensus-09a00a0580c2fd6e11b17f1793edca5f7bb2f5f8.tar.xz dexon-consensus-09a00a0580c2fd6e11b17f1793edca5f7bb2f5f8.tar.zst dexon-consensus-09a00a0580c2fd6e11b17f1793edca5f7bb2f5f8.zip | |
simulation: add latency for gossip (#389)
Diffstat (limited to 'simulation/peer-server.go')
| -rw-r--r-- | simulation/peer-server.go | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/simulation/peer-server.go b/simulation/peer-server.go index 14a825a..69ed029 100644 --- a/simulation/peer-server.go +++ b/simulation/peer-server.go @@ -90,7 +90,8 @@ func (p *PeerServer) handleBlockList(id types.NodeID, blocks *BlockList) { } p.verifiedLen += uint64(length) if p.verifiedLen >= p.cfg.Node.MaxBlock { - if err := p.trans.Broadcast(ntfShutdown); err != nil { + if err := p.trans.Broadcast( + p.peers, &test.FixedLatencyModel{}, ntfShutdown); err != nil { panic(err) } } @@ -199,7 +200,8 @@ func (p *PeerServer) Run() { } // Cache peers' info. for _, pubKey := range p.trans.Peers() { - p.peers[types.NewNodeID(pubKey)] = struct{}{} + nID := types.NewNodeID(pubKey) + p.peers[nID] = struct{}{} } // Pick a mater node to execute pending config changes. for nID := range p.peers { @@ -225,7 +227,8 @@ func (p *PeerServer) Run() { break } } - if err := p.trans.Broadcast(ntfReady); err != nil { + if err := p.trans.Broadcast( + p.peers, &test.FixedLatencyModel{}, ntfReady); err != nil { panic(err) } log.Println("Simulation is ready to go with", len(p.peers), "nodes") |