1 Commits

Author SHA1 Message Date
joy.zhou
0d69f13e48 Revert "op: low performance code (#102)"
This reverts commit c2248bed2b.
2021-01-07 16:22:51 +08:00

View File

@@ -256,24 +256,16 @@ func (this *snode) smatch(topic []byte, qos byte, subs *[]interface{}, qoss *[]b
return err return err
} }
// If the key is "#", then these subscribers are added to the result set
n, ok := this.snodes[MWC]
if ok {
n.matchQos(qos, subs, qoss)
}
n, ok = this.snodes[SWC]
if ok {
if err := n.smatch(rem, qos, subs, qoss); err != nil {
return err
}
}
level := string(ntl) level := string(ntl)
n, ok = this.snodes[level]
if ok { for k, n := range this.snodes {
if err := n.smatch(rem, qos, subs, qoss); err != nil { // If the key is "#", then these subscribers are added to the result set
return err if k == MWC {
n.matchQos(qos, subs, qoss)
} else if k == SWC || k == level {
if err := n.smatch(rem, qos, subs, qoss); err != nil {
return err
}
} }
} }