Method Stop

db/change_cache.go:215–237

Stops the cache. Clears its state and tells the housekeeping task to stop.

(ctx context.Context)

// Stops the cache. Clears its state and tells the housekeeping task to stop.
func (c *changeCache) Stop(ctx context.Context) {

	if !c.started.IsTrue() {
		// changeCache never started - nothing to stop
		return
	}

	if !c.stopped.CompareAndSwap(false, true) {
		base.WarnfCtx(ctx, "changeCache was already stopped")
		return
	}

	// Signal to background goroutines that the changeCache has been stopped, so they can exit
	// their loop
	close(c.terminator)

	// Wait for changeCache background tasks to finish.
	waitForBGTCompletion(ctx, BGTCompletionMaxWait, c.backgroundTasks, c.db.Name)

	c.lock.Lock()
	c.logsDisabled = true
	c.lock.Unlock()
}

// Empty out all channel caches.
func (c *changeCache) Clear(ctx context.Context) error {