Method waitForSequence

db/change_cache.go:1048–1065

waitForSequence blocks up to maxWaitTime until the given sequence has been received.

(ctx context.Context, sequence uint64, maxWaitTime time.Duration)

// waitForSequence blocks up to maxWaitTime until the given sequence has been received.
func (c *changeCache) waitForSequence(ctx context.Context, sequence uint64, maxWaitTime time.Duration) error {
	startTime := time.Now()

	worker := func() (bool, error, interface{}) {
		if c.getNextSequence() >= sequence+1 {
			base.DebugfCtx(ctx, base.KeyCache, "waitForSequence(%d) took %v", sequence, time.Since(startTime))
			return false, nil, nil
		}
		// retry
		return true, nil, nil
	}

	ctx, cancel := context.WithDeadline(ctx, startTime.Add(maxWaitTime))
	sleeper := base.SleeperFuncCtx(base.CreateMaxDoublingSleeperFunc(math.MaxInt64, 1, 100), ctx)
	err, _ := base.RetryLoop(ctx, fmt.Sprintf("waitForSequence(%d)", sequence), worker, sleeper)
	cancel()
	return err
}

// waitForSequenceNotSkipped blocks up to maxWaitTime until the given sequence has been received or skipped.
func (c *changeCache) waitForSequenceNotSkipped(ctx context.Context, sequence uint64, maxWaitTime time.Duration) error {