mirror of
https://github.com/akvorado/akvorado.git
synced 2025-12-12 06:24:10 +01:00
common/helpers: fix race condition when checking last access on expire
This commit is contained in:
3
common/helpers/cache/cache.go
vendored
3
common/helpers/cache/cache.go
vendored
@@ -105,7 +105,8 @@ func (c *Cache[K, V]) DeleteLastAccessedBefore(before time.Time) int {
|
|||||||
c.mu.Lock()
|
c.mu.Lock()
|
||||||
defer c.mu.Unlock()
|
defer c.mu.Unlock()
|
||||||
for k, v := range c.items {
|
for k, v := range c.items {
|
||||||
if v.LastAccessed < before.Unix() {
|
last := atomic.LoadInt64(&v.LastAccessed)
|
||||||
|
if last < before.Unix() {
|
||||||
delete(c.items, k)
|
delete(c.items, k)
|
||||||
count++
|
count++
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user