Merge pull request #2639 from nats-io/reset-tmr

fix timer not being stopped prior to reset
This commit is contained in:
Matthias Hanel
2021-10-20 12:12:16 -04:00
committed by GitHub

View File

@@ -3160,6 +3160,12 @@ func (s *Server) startGWReplyMapExpiration() {
}
case cttl := <-s.gwrm.ch:
ttl = cttl
if !t.Stop() {
select {
case <-t.C:
default:
}
}
t.Reset(ttl)
case <-s.quitCh:
return