Method streamJanitorLoop

coderd/x/chatd/chatd.go:4752–4763

streamJanitorLoop periodically reaps idle chat stream states whose grace period has expired. It is the backstop for the grace-window early-return in cleanupStreamIfIdle; without it, a subscriber that detaches inside grace (the common enterprise relay-drain case, relayDrainTimeout = 200ms vs. 5s grac

(ctx context.Context)

// detaches inside grace (the common enterprise relay-drain case,
// relayDrainTimeout = 200ms vs. 5s grace) pins the state forever.
func (p *Server) streamJanitorLoop(ctx context.Context) {
	ticker := p.clock.NewTicker(streamJanitorInterval, "chatd", "stream-janitor")
	defer ticker.Stop()
	for {
		select {
		case <-ctx.Done():
			return
		case <-ticker.C:
			p.safeSweepIdleStreams(ctx)
		}
	}
}

// safeSweepIdleStreams runs sweepIdleStreams under a panic recovery
// so an unexpected panic in the sweep cannot kill the janitor