Function doForAtLeast

tempodb/compactor.go:429–443

doForAtLeast executes the function f. It blocks for at least the passed duration but can go longer. if context is cancelled after the function is done we will bail immediately. in the current use case this means that the process is shutting down we don't force f() to cancel, we assume it also respon

(ctx context.Context, dur time.Duration, f func())

// the function is done we will bail immediately. in the current use case this means that the process is shutting down
// we don't force f() to cancel, we assume it also responds to the cancelled context
func doForAtLeast(ctx context.Context, dur time.Duration, f func()) {
	startTime := time.Now()
	f()
	elapsed := time.Since(startTime)

	if elapsed < dur {
		ticker := time.NewTicker(dur - elapsed)
		defer ticker.Stop()

		select {
		case <-ticker.C:
		case <-ctx.Done():
		}
	}
}