collab/hmq
3
0
Fork 0
mirror of https://github.com/fhmq/hmq.git synced 2026-04-22 09:48:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Revert "op: low performance code (#102)"

Browse Source 
This reverts commit c2248bed2b.
This commit is contained in:
joy.zhou
2021-01-07 16:22:51 +08:00
committed by GitHub
parent c2248bed2b
commit 0d69f13e48
1 changed files with 9 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
broker/lib/topics/memtopics.go
View File

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