[nar info cache] Only fillNarInfoCache in perf-sensitive code path

Author: savil

internal/boxcli/featureflag/remove_nixpkgs.go

@@ -4,4 +4,4 @@ package featureflag
 // It leverages the search index to directly map <package>@<version> to
 // the /nix/store/<hash>-<package>-<version> that can be fetched from
 // cache.nixpkgs.org.
-var RemoveNixpkgs = disable("REMOVE_NIXPKGS")
+var RemoveNixpkgs = enable("REMOVE_NIXPKGS")

internal/devpkg/narinfo_cache.go

@@ -36,7 +36,8 @@ var isNarInfoInCache = struct {
 }
 
 // IsInBinaryCache returns true if the package is in the binary cache.
-// ALERT: Callers must call FillNarInfoCache before calling this function.
+// ALERT: Callers in a perf-sensitive code path should call FillNarInfoCache
+// before calling this function.
 func (p *Package) IsInBinaryCache() (bool, error) {
 
 	if eligible, err := p.isEligibleForBinaryCache(); err != nil {
@@ -50,38 +51,58 @@ func (p *Package) IsInBinaryCache() (bool, error) {
 	exists, ok := isNarInfoInCache.status[p.Raw]
 	isNarInfoInCache.lock.RUnlock()
 	if !ok {
-		return false, errors.Errorf(
-			"narInfo cache miss: %v. Call FillNarInfoCache before invoking IsInBinaryCache",
-			p.Raw,
-		)
+		// Fallback to synchronously filling the nar info cache
+		if err := p.fillNarInfoCache(); err != nil {
+			return false, err
+		}
+
+		// Check again
+		isNarInfoInCache.lock.RLock()
+		exists, ok = isNarInfoInCache.status[p.Raw]
+		isNarInfoInCache.lock.RUnlock()
+		if !exists {
+			return false, errors.Errorf(
+				"narInfo cache miss: %v. Should be filled by now",
+				p.Raw,
+			)
+		}
 	}
 	return exists, nil
 }
 
 // FillNarInfoCache checks the remote binary cache for the narinfo of each
 // package in the list, and caches the result.
-// Callers of IsInBinaryCache must call this function first.
+// Callers of IsInBinaryCache may call this function first as a perf-optimization.
 func FillNarInfoCache(ctx context.Context, packages ...*Package) error {
 	if !featureflag.RemoveNixpkgs.Enabled() {
 		return nil
 	}
 
+	eligiblePackages := []*Package{}
+	for _, p := range packages {
+		// NOTE: isElgibleForBinaryCache also ensures the package is
+		// resolved in the lockfile, which must be done before the concurrent
+		// section in this function below.
+		isEligible, err := p.isEligibleForBinaryCache()
+		// If the package is not eligible or there is an error in determining that, then skip it.
+		if isEligible && err == nil {
+			eligiblePackages = append(eligiblePackages, p)
+		}
+	}
+	if len(eligiblePackages) == 0 {
+		return nil
+	}
+
 	// Pre-compute values read in fillNarInfoCache
 	// so they can be read from multiple go-routines without locks
 	_, err := nix.Version()
 	if err != nil {
 		return err
 	}
 	_ = nix.System()
-	for _, p := range packages {
-		_, err := p.lockfile.Resolve(p.Raw)
-		if err != nil {
-			return err
-		}
-	}
 
 	group, _ := errgroup.WithContext(ctx)
-	for _, p := range packages {
+	for _, p := range eligiblePackages {
 		// If the package's NarInfo status is already known, skip it
 		isNarInfoInCache.lock.RLock()
 		_, ok := isNarInfoInCache.status[p.Raw]
@@ -105,15 +126,11 @@ func FillNarInfoCache(ctx context.Context, packages ...*Package) error {
 }
 
 // fillNarInfoCache fills the cache value for the narinfo of this package,
-// if it is eligible for the binary cache.
+// assuming it is eligible for the binary cache. Callers are responsible
+// for checking isEligibleForBinaryCache before calling this function.
+//
 // NOTE: this must be concurrency safe.
 func (p *Package) fillNarInfoCache() error {
-	if eligible, err := p.isEligibleForBinaryCache(); err != nil {
-		return err
-	} else if !eligible {
-		return nil
-	}
-
 	sysInfo, err := p.sysInfoIfExists()
 	if err != nil {
 		return err
@@ -146,6 +163,8 @@ func (p *Package) fillNarInfoCache() error {
 	return nil
 }
 
+// isEligibleForBinaryCache returns true if the package is eligible for the binary cache.
+// NOTE: package must be resolved.
 func (p *Package) isEligibleForBinaryCache() (bool, error) {
 	sysInfo, err := p.sysInfoIfExists()
 	if err != nil {

internal/devpkg/package.go

@@ -427,9 +427,6 @@ func (p *Package) LegacyToVersioned() string {
 // EnsureNixpkgsPrefetched will prefetch flake for the nixpkgs registry for the package.
 // This is an internal method, and should not be called directly.
 func EnsureNixpkgsPrefetched(ctx context.Context, w io.Writer, pkgs []*Package) error {
-	if err := FillNarInfoCache(ctx, pkgs...); err != nil {
-		return err
-	}
 	for _, input := range pkgs {
 		if err := input.ensureNixpkgsPrefetched(w); err != nil {
 			return err

internal/impl/packages.go

@@ -42,12 +42,6 @@ func (d *Devbox) Add(ctx context.Context, platforms, excludePlatforms []string,
 	// replace it.
 	pkgs := devpkg.PackageFromStrings(lo.Uniq(pkgsNames), d.lockfile)
 
-	// Fill in narinfo cache for all packages, even if the package-names are bogus
-	// (we'll just not use the result later)
-	if err := devpkg.FillNarInfoCache(ctx, pkgs...); err != nil {
-		return err
-	}
-
 	// addedPackageNames keeps track of the possibly transformed (versioned)
 	// names of added packages (even if they are already in config). We use this
 	// to know the exact name to mark as allowed insecure later on.
@@ -65,15 +59,6 @@ func (d *Devbox) Add(ctx context.Context, platforms, excludePlatforms []string,
 		}
 	}
 
-	// Fill in the narinfo cache for versioned newPackages as well
-	versionedPackages := map[string]*devpkg.Package{}
-	for _, pkg := range newPackages {
-		versionedPackages[pkg.Versioned()] = devpkg.PackageFromString(pkg.Versioned(), d.lockfile)
-	}
-	if err := devpkg.FillNarInfoCache(ctx, lo.Values(versionedPackages)...); err != nil {
-		return err
-	}
-
 	for _, pkg := range newPackages {
 
 		// On the other hand, if there's a package with same canonical name, replace
@@ -89,7 +74,7 @@ func (d *Devbox) Add(ctx context.Context, platforms, excludePlatforms []string,
 
 		// validate that the versioned package exists in the search endpoint.
 		// if not, fallback to legacy vanilla nix.
-		versionedPkg := versionedPackages[pkg.Versioned()]
+		versionedPkg := devpkg.PackageFromString(pkg.Versioned(), d.lockfile)
 
 		packageNameForConfig := pkg.Raw
 		ok, err := versionedPkg.ValidateExists()
@@ -363,12 +348,7 @@ func (d *Devbox) removePackagesFromProfile(ctx context.Context, pkgs []string) e
 		return err
 	}
 
-	packages := devpkg.PackageFromStrings(pkgs, d.lockfile)
-	if err := devpkg.FillNarInfoCache(ctx, packages...); err != nil {
-		return err
-	}
-
-	for _, pkg := range packages {
+	for _, pkg := range devpkg.PackageFromStrings(pkgs, d.lockfile) {
 		index, err := nixprofile.ProfileListIndex(&nixprofile.ProfileListIndexArgs{
 			Lockfile:   d.lockfile,
 			Writer:     d.writer,
@@ -438,9 +418,6 @@ func (d *Devbox) pendingPackagesForInstallation(ctx context.Context) ([]*devpkg.
 	if err != nil {
 		return nil, err
 	}
-	if err := devpkg.FillNarInfoCache(ctx, packages...); err != nil {
-		return nil, err
-	}
 	for _, pkg := range packages {
 		_, err := nixprofile.ProfileListIndex(&nixprofile.ProfileListIndexArgs{
 			Items:      items,

internal/impl/update.go

@@ -49,10 +49,6 @@ func (d *Devbox) Update(ctx context.Context, pkgs ...string) error {
 		}
 	}
 
-	if err := devpkg.FillNarInfoCache(ctx, pendingPackagesToUpdate...); err != nil {
-		return err
-	}
-
 	for _, pkg := range pendingPackagesToUpdate {
 		if _, _, isVersioned := searcher.ParseVersionedPackage(pkg.Raw); !isVersioned {
 			if err = d.attemptToUpgradeFlake(pkg); err != nil {

internal/nix/nixprofile/profile.go

@@ -201,12 +201,6 @@ type ProfileInstallArgs struct {
 func ProfileInstall(ctx context.Context, args *ProfileInstallArgs) error {
 	input := devpkg.PackageFromString(args.Package, args.Lockfile)
 
-	// Fill in the narinfo cache for the input package. It's okay to call this for a single package
-	// because installing is a slow operation anyway.
-	if err := devpkg.FillNarInfoCache(ctx, input); err != nil {
-		return err
-	}
-
 	inCache, err := input.IsInBinaryCache()
 	if err != nil {
 		return err

internal/shellgen/flake_input.go

@@ -84,11 +84,6 @@ func flakeInputs(ctx context.Context, packages []*devpkg.Package) ([]*flakeInput
 	// which refer to `nix.Input` in most of the codebase.
 	flakeInputs := map[string]*flakeInput{}
 
-	// Fill the NarInfo Cache so we can check IsInBinaryCache() for each package, below.
-	if err := devpkg.FillNarInfoCache(ctx, packages...); err != nil {
-		return nil, err
-	}
-
 	packages = lo.Filter(packages, func(item *devpkg.Package, _ int) bool {
 		// Include packages (like local or remote flakes) that cannot be
 		// fetched from a Binary Cache Store.

internal/shellgen/flake_plan.go

@@ -38,6 +38,13 @@ func newFlakePlan(ctx context.Context, devbox devboxer) (*flakePlan, error) {
 	if err != nil {
 		return nil, err
 	}
+
+	// Fill the NarInfo Cache concurrently as a perf-optimization, prior to invoking
+	// IsInBinaryCache in flakeInputs() and in the flake.nix template.
+	if err := devpkg.FillNarInfoCache(ctx, packages...); err != nil {
+		return nil, err
+	}
+
 	flakeInputs, err := flakeInputs(ctx, packages)
 	if err != nil {
 		return nil, err

testscripts/add/add.test.txt

@@ -2,6 +2,14 @@
 
 exec devbox init
 
+# Add a package that is not part of the Devbox Search index.
+# This exercises the fallback codepath for adding packages.
+exec devbox add stdenv.cc.cc.lib
+json.superset devbox.json expected_devbox1.json
+
+# Add regular packages. Even though this is the more common scenario,
+# we test this later, because the source.path below removes "devbox"
+# from the PATH.
 ! exec rg --version
 ! exec vim --version
 exec devbox add ripgrep vim
@@ -10,9 +18,26 @@ exec devbox shellenv
 source.path
 exec rg --version
 exec vim --version
+json.superset devbox.json expected_devbox2.json
 
 -- devbox.json --
 {
   "packages": [
   ]
 }
+
+-- expected_devbox1.json --
+{
+  "packages": [
+    "stdenv.cc.cc.lib"
+  ]
+}
+
+-- expected_devbox2.json --
+{
+  "packages": [
+    "ripgrep@latest",
+    "vim@latest",
+    "stdenv.cc.cc.lib"
+  ]
+}