Method getPartial

internal/cache/persistent_lru_cache.go:132–162

getPartial fetches the contents of a cached blob when (length < 0) or a subset of it (when length >= 0) and returns true if it is found.

(ctx context.Context, key string, offset, length int64, output *gather.WriteBuffer)

// getPartial fetches the contents of a cached blob when (length < 0) or a subset
// of it (when length >= 0) and returns true if it is found.
func (c *PersistentCache) getPartial(ctx context.Context, key string, offset, length int64, output *gather.WriteBuffer) bool {
	if c == nil {
		return false
	}

	var tmp gather.WriteBuffer
	defer tmp.Close()

	if err := c.cacheStorage.GetBlob(ctx, blob.ID(key), offset, length, &tmp); err == nil {
		sp := c.storageProtection

		if length >= 0 {
			// do not perform integrity check on partial reads
			sp = cacheprot.NoProtection()
		}

		if err := sp.Verify(key, tmp.Bytes(), output); err == nil {
			c.getPartialCacheHit(ctx, key, length, output)

			return true
		}

		c.reportMalformedData()
		c.deleteInvalidBlob(ctx, key)
	}

	// cache miss
	c.reportMissBytes(max(length, 0))

	return false
}

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