diff options
author | Jimmy Hu <jimmy.hu@dexon.org> | 2018-07-30 09:05:58 +0800 |
---|---|---|
committer | Wei-Ning Huang <aitjcize@gmail.com> | 2018-07-30 09:05:58 +0800 |
commit | 279daea6e004ab6ad9d079ccc35b7c52d79630ad (patch) | |
tree | 6e07c9ddf5608339c216c4657250f7df238bd75e /simulation/simulation.go | |
parent | 568ce1f526d10184af2ccfe342394f57ae689a14 (diff) | |
download | tangerine-consensus-279daea6e004ab6ad9d079ccc35b7c52d79630ad.tar tangerine-consensus-279daea6e004ab6ad9d079ccc35b7c52d79630ad.tar.gz tangerine-consensus-279daea6e004ab6ad9d079ccc35b7c52d79630ad.tar.bz2 tangerine-consensus-279daea6e004ab6ad9d079ccc35b7c52d79630ad.tar.lz tangerine-consensus-279daea6e004ab6ad9d079ccc35b7c52d79630ad.tar.xz tangerine-consensus-279daea6e004ab6ad9d079ccc35b7c52d79630ad.tar.zst tangerine-consensus-279daea6e004ab6ad9d079ccc35b7c52d79630ad.zip |
Add a config that PeerServer can shutdown after receiving enough of block. (#19)
Diffstat (limited to 'simulation/simulation.go')
-rw-r--r-- | simulation/simulation.go | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/simulation/simulation.go b/simulation/simulation.go index 8ec72ea..2ea768e 100644 --- a/simulation/simulation.go +++ b/simulation/simulation.go @@ -34,10 +34,11 @@ func Run(configPath string) { networkType := cfg.Networking.Type + var vs []*Validator + if networkType == config.NetworkTypeFake || networkType == config.NetworkTypeTCPLocal { - var vs []*Validator var network Network if networkType == config.NetworkTypeFake { @@ -71,7 +72,11 @@ func Run(configPath string) { go network.Start() v := NewValidator(id, cfg.Validator, network, nil) go v.Run() + vs = append(vs, v) } - select {} + for _, v := range vs { + v.Wait() + fmt.Printf("Validator %s is shutdown\n", v.GetID()) + } } |