From 5edb8b11053d1b2cffb045fe219b65f0e877a3cf Mon Sep 17 00:00:00 2001 From: Ivan Kozlovic Date: Sat, 13 Mar 2021 14:59:38 -0700 Subject: [PATCH] Clear timer in case currently set Signed-off-by: Ivan Kozlovic --- server/consumer.go | 1 + 1 file changed, 1 insertion(+) diff --git a/server/consumer.go b/server/consumer.go index e4cbf165..983fddcb 100644 --- a/server/consumer.go +++ b/server/consumer.go @@ -713,6 +713,7 @@ func (o *consumer) setLeader(isLeader bool) { // There is no local interest, but there is GW interest, we // will watch for interest disappearing. // TODO: may need to revisit... + stopAndClearTimer(&o.gwdtmr) o.gwdtmr = time.AfterFunc(o.dthresh, func() { o.watchGWinterest() }) } }