go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2024-11-24 08:02:32 +02:00
Code Issues Releases Activity

Only limit the number of nodes returned by network resolver.

Browse Source
This commit is contained in:
Milos Gajdos 2019-10-08 15:48:52 +01:00
parent 61800fb7d7
commit fe5846603a
No known key found for this signature in database
GPG Key ID: 8B31058CC55DFD4F
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
network/default.go
View File

@ -171,9 +171,16 @@ func (n *network) resolveNodes() ([]string, error) {
// collect network node addresses
var nodes []string
i := 0
for _, record := range records {
nodes = append(nodes, record.Address)
nodeMap[record.Address] = true
i++
// break once MaxConnection nodes has been reached
if i == MaxConnections {
break
}
}
// use the dns resolver to expand peers
@ -195,15 +202,6 @@ func (n *network) resolveNodes() ([]string, error) {
}
}
// only return MaxConnections nodes
if len(nodes) > MaxConnections {
resNodes := make([]string, MaxConnections)
for i, _ := range resNodes {
resNodes[i] = nodes[i]
}
return resNodes, nil
}
return nodes, nil
}