// until approximate remaining size <= maxsize/2
func (c *cache) pruneSessions() {
now := time.Now()
- var size int64
keys := c.sessions.Keys()
- for _, token := range keys {
+ sizes := make([]int64, len(keys))
+ var size int64
+ for i, token := range keys {
ent, ok := c.sessions.Peek(token)
if !ok {
continue
continue
}
if fs, ok := s.fs.Load().(arvados.CustomFileSystem); ok {
- size += fs.MemorySize()
+ sizes[i] = fs.MemorySize()
+ size += sizes[i]
}
}
// Remove tokens until reaching size limit, starting with the
// least frequently used entries (which Keys() returns last).
- for i := len(keys) - 1; i >= 0; i-- {
- token := keys[i]
- if size <= c.cluster.Collections.WebDAVCache.MaxCollectionBytes {
- break
- }
- ent, ok := c.sessions.Peek(token)
- if !ok {
- continue
- }
- s := ent.(*cachedSession)
- fs, _ := s.fs.Load().(arvados.CustomFileSystem)
- if fs == nil {
- continue
+ for i := len(keys) - 1; i >= 0 && size > c.cluster.Collections.WebDAVCache.MaxCollectionBytes; i-- {
+ if sizes[i] > 0 {
+ c.sessions.Remove(keys[i])
+ size -= sizes[i]
}
- c.sessions.Remove(token)
- size -= fs.MemorySize()
}
}