Method prewarmHeads

internal/connect/commits.go:912–944

prewarmHeads resolves the current HEAD commit of every configured module and registers it, so that a client sending a cached current-HEAD sha hits the commit map without a prior in-session GetCommits. Best-effort and idempotent (prewarmOnce): failures are logged and skipped; a later probeCommitID ca

()

// no file fetch. Intended to run in a background goroutine launched from
// connect.New.
func (h *commitServiceHandler) prewarmHeads() {
	h.prewarmOnce.Do(func() {
		sources := h.api.repo.Repositories()
		log := h.api.log.With(slog.String("component", "prewarm"))
		log.LogAttrs(context.Background(), slog.LevelInfo, "prewarm starting",
			slog.Int("sources", len(sources)),
			slog.Duration("per_call_timeout", h.prewarmTimeout))
		var ok, fail int
		for _, s := range sources {
			owner, module := s.Owner(), s.RepoName()
			if owner == "" || module == "" {
				continue
			}
			ctx, cancel := context.WithTimeout(context.Background(), h.prewarmTimeout)
			meta, err := s.GetMeta(ctx, "") // empty commit = HEAD
			cancel()
			if err != nil || meta.Commit == "" {
				fail++
				log.LogAttrs(context.Background(), slog.LevelWarn, "prewarm source miss",
					slog.String("owner", owner), slog.String("module", module),
					slog.String("repo", module))
				continue
			}
			h.registerResolved(meta.Commit, owner, module)
			ok++
			log.LogAttrs(context.Background(), slog.LevelInfo, "prewarm source resolved",
				slog.String("owner", owner), slog.String("module", module),
				slog.String("repo", module), slog.String("commit", meta.Commit))
		}
		log.LogAttrs(context.Background(), slog.LevelInfo, "prewarm complete",
			slog.Int("resolved", ok), slog.Int("failed", fail))
	})
}

// missCached reports whether sha was recently confirmed absent from every
// configured source (within ProbeNegativeTTL). Caller must NOT hold commitMu.