Method Put

internal/cache/persistent_lru_cache.go:165–207

Put adds the provided key-value pair to the cache.

(ctx context.Context, key string, data gather.Bytes)

// Put adds the provided key-value pair to the cache.
func (c *PersistentCache) Put(ctx context.Context, key string, data gather.Bytes) {
	if c == nil {
		return
	}

	c.listCacheMutex.Lock()
	defer c.listCacheMutex.Unlock()

	// make sure the cache has enough room for the new item including any protection overhead.
	l := data.Length() + c.storageProtection.OverheadBytes()
	c.pendingWriteBytes += int64(l)
	c.sweepLocked(ctx)

	// LOCK RELEASED for expensive operations
	c.listCacheMutex.Unlock()

	var protected gather.WriteBuffer
	defer protected.Close()

	c.storageProtection.Protect(key, data, &protected)

	if protected.Length() != l {
		log(ctx).Panicf("protection overhead mismatch, assumed %v got %v", l, protected.Length())
	}

	var mtime time.Time

	if err := c.cacheStorage.PutBlob(ctx, blob.ID(key), protected.Bytes(), blob.PutOptions{GetModTime: &mtime}); err != nil {
		c.reportStoreError()

		log(ctx).Errorf("unable to add %v to %v: %v", key, c.description, err)
	}

	c.listCacheMutex.Lock()
	// LOCK RE-ACQUIRED

	c.pendingWriteBytes -= int64(protected.Length())
	c.listCache.AddOrUpdate(blob.Metadata{
		BlobID:    blob.ID(key),
		Length:    int64(protected.Bytes().Length()),
		Timestamp: mtime,
	})
}

// Close closes the instance of persistent cache possibly waiting for at least one sweep to complete.
func (c *PersistentCache) Close(_ context.Context) {