Method addToCache

db/channel_cache_single.go:186–204

Low-level method to add a LogEntry to a single channel's cache.

(ctx context.Context, change *LogEntry, isRemoval bool)

// Low-level method to add a LogEntry to a single channel's cache.
func (c *singleChannelCacheImpl) addToCache(ctx context.Context, change *LogEntry, isRemoval bool) {
	c.lock.Lock()
	defer c.lock.Unlock()

	if c.wouldBeImmediatelyPruned(change) {
		base.InfofCtx(ctx, base.KeyCache, "Not adding change #%d doc %q / %q ==> channel %q, since it will be immediately pruned",
			change.Sequence, base.UD(change.DocID), change.RevID, base.UD(c.channelID))
		return
	}

	if !isRemoval {
		c._appendChange(ctx, change)
	} else {
		removalChange := *change
		removalChange.Flags |= channels.Removed
		c._appendChange(ctx, &removalChange)
	}
	c._pruneCacheLength(ctx)
}

// If certain conditions are met, it's possible that this change will be added and then
// immediately pruned, which causes the issues described in https://github.com/couchbase/sync_gateway/issues/2662