Method _pruneCacheLength

db/channel_cache_single.go:270–290

Internal helper that prunes a single channel's cache. Caller MUST be holding the lock.

(ctx context.Context)

// Internal helper that prunes a single channel's cache. Caller MUST be holding the lock.
func (c *singleChannelCacheImpl) _pruneCacheLength(ctx context.Context) (pruned int) {
	// If we are over max length, prune it down to max length
	if len(c.logs) > c.options.ChannelCacheMaxLength {
		pruned = len(c.logs) - c.options.ChannelCacheMaxLength
		for i := 0; i < pruned; i++ {
			c.UpdateCacheUtilization(c.logs[i], -1)
			delete(c.cachedDocIDs, c.logs[i].DocID)
		}
		c.validFrom = c.logs[pruned-1].Sequence + 1
		c.logs = c.logs[pruned:]
	}

	if pruned > 0 {
		// Only enter trace log line if trace is enabled, to avoid the cost of UD() calls
		if base.LogTraceEnabled(ctx, base.KeyCache) {
			base.TracefCtx(ctx, base.KeyCache, "Pruned %d entries from channel %q", pruned, base.UD(c.channelID))
		}
	}

	return pruned
}

func (c *singleChannelCacheImpl) pruneCacheAge(ctx context.Context) {
	c.lock.Lock()