go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2024-12-24 10:07:04 +02:00
Code Issues Releases Activity

fix rand panic

Browse Source
This commit is contained in:
Asim Aslam 2020-01-15 21:02:53 +00:00
parent 7c7b0ced5f
commit f20e4daa60
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
network/default.go
View File

@ -334,11 +334,17 @@ func (n *network) advertise(advertChan <-chan *router.Advert) {
// get a list of node peers // get a list of node peers
peers := n.Peers() peers := n.Peers()
// there is no one to send to
if len(peers) == 0 {
continue
}
// advertise to max 3 peers // advertise to max 3 peers
max := len(peers) max := len(peers)
if max > 3 { if max > 3 {
max = 3 max = 3
} }
for i := 0; i < max; i++ { for i := 0; i < max; i++ {
if peer := n.node.GetPeerNode(peers[rnd.Intn(len(peers))].Id()); peer != nil { if peer := n.node.GetPeerNode(peers[rnd.Intn(len(peers))].Id()); peer != nil {
if err := n.sendTo("advert", ControlChannel, peer, msg); err != nil { if err := n.sendTo("advert", ControlChannel, peer, msg); err != nil {
@ -346,6 +352,7 @@ func (n *network) advertise(advertChan <-chan *router.Advert) {
} }
} }
} }
continue continue
} }
@ -1268,6 +1275,12 @@ func (n *network) manage() {
case <-netsync.C: case <-netsync.C:
// get a list of node peers // get a list of node peers
peers := n.Peers() peers := n.Peers()
// skip when there are no peers
if len(peers) == 0 {
continue
}
// pick a random peer from the list of peers and request full sync // pick a random peer from the list of peers and request full sync
peer := n.node.GetPeerNode(peers[rnd.Intn(len(peers))].Id()) peer := n.node.GetPeerNode(peers[rnd.Intn(len(peers))].Id())
// skip if we can't find randmly selected peer // skip if we can't find randmly selected peer