unistack-org/micro
4
0
Fork 3
Code Issues 20 Pull Requests 1 Actions Packages Projects Releases 282 Wiki Activity

fix divide by zero bug

Browse Source
This commit is contained in:
Asim Aslam 2019-10-19 08:11:05 +01:00
parent d3140c0fc2
commit a89d1edc41
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
broker/http_broker.go
View File

@ -560,11 +560,6 @@ func (h *httpBroker) Publish(topic string, msg *Message, opts ...PublishOption)
srv := func(s []*registry.Service, b []byte) { srv := func(s []*registry.Service, b []byte) {
for _, service := range s { for _, service := range s {
// only process if we have nodes
if len(service.Nodes) == 0 {
continue
}
var nodes []*registry.Node var nodes []*registry.Node
for _, node := range service.Nodes { for _, node := range service.Nodes {
@ -581,6 +576,11 @@ func (h *httpBroker) Publish(topic string, msg *Message, opts ...PublishOption)
nodes = append(nodes, node) nodes = append(nodes, node)
} }
// only process if we have nodes
if len(nodes) == 0 {
continue
}
switch service.Version { switch service.Version {
// broadcast version means broadcast to all nodes // broadcast version means broadcast to all nodes
case broadcastVersion: case broadcastVersion: