From ca773bf07b9b12fb8eece9e0988bcbcea2b556e1 Mon Sep 17 00:00:00 2001 From: antmanler Date: Wed, 10 Jul 2019 21:41:44 +0800 Subject: [PATCH] Make sure Sublist.All collect all subscriptions --- server/sublist.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/server/sublist.go b/server/sublist.go index 27dbedb2..b9c49bde 100644 --- a/server/sublist.go +++ b/server/sublist.go @@ -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) } }