diff --git a/engine/resources.go b/engine/resources.go index 6630e1636..d50b3c524 100755 --- a/engine/resources.go +++ b/engine/resources.go @@ -574,9 +574,12 @@ func (rS *ResourceService) V1AllocateResource(args utils.ArgRSv1ResourceUsage, r } // index it for storing for _, r := range mtcRLs { + if rS.storeInterval == 0 || r.dirty == nil { + continue + } if rS.storeInterval == -1 { rS.StoreResource(r) - } else if r.dirty != nil { + } else { *r.dirty = true // mark it to be saved rS.srMux.Lock() rS.storedResources[r.TenantID()] = true diff --git a/engine/stats.go b/engine/stats.go index d73d31f67..323086b33 100644 --- a/engine/stats.go +++ b/engine/stats.go @@ -213,9 +213,12 @@ func (sS *StatService) processEvent(ev *StatEvent) (err error) { sq.TenantID(), ev.TenantID(), err.Error())) withErrors = true } + if sS.storeInterval == 0 || sq.dirty == nil { // don't save + continue + } if sS.storeInterval == -1 { sS.StoreStatQueue(sq) - } else if sq.dirty != nil { + } else { *sq.dirty = true // mark it to be saved sS.ssqMux.Lock() sS.storedStatQueues[sq.TenantID()] = true