gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 11:24:44 -07:00
Code Issues Packages Projects Releases Wiki Activity

Fix for memory expiration and age timer

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2020-06-18 14:02:11 -07:00
parent a13402cd01
commit 95462cde57
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
server/memstore.go
View File

@@ -215,11 +215,17 @@ func (ms *memStore) expireMsgs() {
ms.deleteFirstMsgOrPanic()
} else {
if !ok {
ms.ageChk.Stop()
ms.ageChk = nil
if ms.ageChk != nil {
ms.ageChk.Stop()
ms.ageChk = nil
}
} else {
fireIn := time.Duration(sm.ts-now) + ms.cfg.MaxAge
ms.ageChk.Reset(fireIn)
if ms.ageChk != nil {
ms.ageChk.Reset(fireIn)
} else {
ms.ageChk = time.AfterFunc(fireIn, ms.expireMsgs)
}
}
return
}