89 lines
2.0 KiB
Go
89 lines
2.0 KiB
Go
package dirivcache
|
|
|
|
import (
|
|
"sync"
|
|
"time"
|
|
)
|
|
|
|
const (
|
|
maxEntries = 100
|
|
expireTime = 1 * time.Second
|
|
)
|
|
|
|
type cacheEntry struct {
|
|
// DirIV of the directory.
|
|
iv []byte
|
|
// Relative ciphertext path of the directory.
|
|
cDir string
|
|
}
|
|
|
|
// DirIVCache stores up to "maxEntries" directory IVs.
|
|
type DirIVCache struct {
|
|
// data in the cache, indexed by relative plaintext path
|
|
// of the directory.
|
|
data map[string]cacheEntry
|
|
|
|
// The DirIV of the root directory gets special treatment because it
|
|
// cannot change (the root directory cannot be renamed or deleted).
|
|
// It is unaffected by the expiry timer and cache clears.
|
|
rootDirIV []byte
|
|
|
|
// expiry is the time when the whole cache expires.
|
|
// The cached entry my become out-of-date if the ciphertext directory is
|
|
// modifed behind the back of gocryptfs. Having an expiry time limits the
|
|
// inconstency to one second, like attr_timeout does for the kernel
|
|
// getattr cache.
|
|
expiry time.Time
|
|
|
|
sync.RWMutex
|
|
}
|
|
|
|
// Lookup - fetch entry for "dir" from the cache
|
|
func (c *DirIVCache) Lookup(dir string) ([]byte, string) {
|
|
c.RLock()
|
|
defer c.RUnlock()
|
|
if dir == "" {
|
|
return c.rootDirIV, ""
|
|
}
|
|
if c.data == nil {
|
|
return nil, ""
|
|
}
|
|
if time.Since(c.expiry) > 0 {
|
|
c.data = nil
|
|
return nil, ""
|
|
}
|
|
v := c.data[dir]
|
|
return v.iv, v.cDir
|
|
}
|
|
|
|
// Store - write entry for "dir" into the cache
|
|
func (c *DirIVCache) Store(dir string, iv []byte, cDir string) {
|
|
c.Lock()
|
|
defer c.Unlock()
|
|
if dir == "" {
|
|
c.rootDirIV = iv
|
|
}
|
|
if c.data == nil {
|
|
c.data = make(map[string]cacheEntry, maxEntries)
|
|
// Set expiry time one second into the future
|
|
c.expiry = time.Now().Add(expireTime)
|
|
}
|
|
// Delete a random entry from the map if reached maxEntries
|
|
if len(c.data) >= maxEntries {
|
|
for k := range c.data {
|
|
delete(c.data, k)
|
|
break
|
|
}
|
|
}
|
|
c.data[dir] = cacheEntry{iv, cDir}
|
|
}
|
|
|
|
// Clear ... clear the cache.
|
|
// Called from fusefrontend when directories are renamed or deleted.
|
|
func (c *DirIVCache) Clear() {
|
|
c.Lock()
|
|
defer c.Unlock()
|
|
// Will be re-initialized in the next Store()
|
|
c.data = nil
|
|
}
|