maurice/snix
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

refactor(tvix/*/import): rename direntry_stream, entries_per_depths

Browse source 
Align these names and comments with the two users, to make it more
obvious we're doing the same thing here, just use a different method to
come up with entries_per_depths.

Change-Id: I42058e397588b6b57a6299e87183bef27588b228
Reviewed-on: https://cl.tvl.fyi/c/depot/+/11415
Tested-by: BuildkiteCI
Autosubmit: flokli <flokli@flokli.de>
Reviewed-by: Connor Brewster <cbrewster@hey.com>
This commit is contained in:
Florian Klink 2024-04-13 19:22:37 +03:00 • committed by clbot
parent bcc00fba8f
commit b70744fda6
2 changed files with 10 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

9
tvix/castore/src/import.rs
View file

@ -143,11 +143,12 @@ where
BS: AsRef<dyn BlobService> + Clone,
DS: AsRef<dyn DirectoryService>,
{
let entries = walk_path_for_ingestion(path)?;
let entries_stream = leveled_entries_to_stream(entries);
pin_mut!(entries_stream);
// produce the leveled-key vector of DirEntry.
let entries_per_depths = walk_path_for_ingestion(path)?;
let direntry_stream = leveled_entries_to_stream(entries_per_depths);
pin_mut!(direntry_stream);
ingest_entries(blob_service, directory_service, entries_stream).await
ingest_entries(blob_service, directory_service, direntry_stream).await
}
/// The Merkle invariant checker is an internal structure to perform bookkeeping of all directory