Method acquireLoop

coderd/x/chatd/chatd.go:4351–4384

(ctx context.Context)

}

func (p *Server) acquireLoop(ctx context.Context) {
	acquireTicker := p.clock.NewTicker(
		p.pendingChatAcquireInterval,
		"chatd",
		"acquire",
	)
	defer acquireTicker.Stop()

	staleRecoveryInterval := p.inFlightChatStaleAfter / staleRecoveryIntervalDivisor
	staleTicker := p.clock.NewTicker(
		staleRecoveryInterval,
		"chatd",
		"stale-recovery",
	)
	defer staleTicker.Stop()

	for {
		select {
		case <-ctx.Done():
			return
		case <-acquireTicker.C:
			p.processOnce(ctx)
		case <-p.wakeCh:
			p.processOnce(ctx)
		case <-staleTicker.C:
			p.recoverStaleChats(ctx)
			if debugSvc := p.existingDebugService(); debugSvc != nil {
				if _, err := debugSvc.FinalizeStale(ctx); err != nil {
					p.logger.Warn(ctx, "failed to finalize stale chat debug rows", slog.Error(err))
				}
			}
		}
	}
}

// signalWake wakes the run loop so it calls processOnce immediately.
// Non-blocking: if a signal is already pending it is a no-op.