gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Make sure Sublist.All collect all subscriptions

Browse Source
This commit is contained in:
antmanler
2019-07-10 21:41:44 +08:00
parent 074c87d49e
commit ca773bf07b
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/sublist.go
View File

@@ -1047,14 +1047,14 @@ func (s *Sublist) addAllNodeToSubs(n *node, subs *[]*subscription) {
func (s *Sublist) collectAllSubs(l *level, subs *[]*subscription) {
for _, n := range l.nodes {
s.addAllNodeToSubs(n, subs)
s.collectLocalSubs(n.next, subs)
s.collectAllSubs(n.next, subs)
}
if l.pwc != nil {
s.addAllNodeToSubs(l.pwc, subs)
s.collectLocalSubs(l.pwc.next, subs)
s.collectAllSubs(l.pwc.next, subs)
}
if l.fwc != nil {
s.addAllNodeToSubs(l.fwc, subs)
s.collectLocalSubs(l.fwc.next, subs)
s.collectAllSubs(l.fwc.next, subs)
}
}