fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-05-10 13:47:10 +00:00
Code Issues Projects Releases Wiki Activity

DialSeeds takes an addrbook

Browse Source
This commit is contained in:
Ethan Buchman 2017-03-05 21:57:07 -05:00
parent 56eebb95ee
commit c94bc2bc2b
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
switch.go
View File

@ -297,15 +297,29 @@ func (sw *Switch) startInitPeer(peer *Peer) {
} }
// Dial a list of seeds asynchronously in random order // Dial a list of seeds asynchronously in random order
func (sw *Switch) DialSeeds(seeds []string) error { func (sw *Switch) DialSeeds(addrBook *AddrBook, seeds []string) error {
netAddrs, err := NewNetAddressStrings(seeds) netAddrs, err := NewNetAddressStrings(seeds)
if err != nil { if err != nil {
return err return err
} }
if addrBook != nil {
// add seeds to `addrBook`
ourAddrS := sw.nodeInfo.ListenAddr
ourAddr, _ := NewNetAddressString(ourAddrS)
for _, netAddr := range netAddrs {
// do not add ourselves
if netAddr.Equals(ourAddr) {
continue
}
addrBook.AddAddress(netAddr, ourAddr)
}
addrBook.Save()
}
// permute the list, dial them in random order. // permute the list, dial them in random order.
perm := rand.Perm(len(seeds)) perm := rand.Perm(len(netAddrs))
for i := 0; i < len(perm); i++ { for i := 0; i < len(perm); i++ {
go func(i int) { go func(i int) {
time.Sleep(time.Duration(rand.Int63n(3000)) * time.Millisecond) time.Sleep(time.Duration(rand.Int63n(3000)) * time.Millisecond)