diff options
Diffstat (limited to 'tvix/castore/src/import.rs')
| -rw-r--r-- | tvix/castore/src/import.rs | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/tvix/castore/src/import.rs b/tvix/castore/src/import.rs index 4545f35fc319..c4d410497235 100644 --- a/tvix/castore/src/import.rs +++ b/tvix/castore/src/import.rs @@ -45,21 +45,21 @@ impl From<CastoreError> for Error { } } -// This processes a given [walkdir::DirEntry] and returns a -// proto::node::Node, depending on the type of the entry. -// -// If the entry is a file, its contents are uploaded. -// If the entry is a directory, the Directory is uploaded as well. -// For this to work, it relies on the caller to provide the directory object -// with the previously returned (child) nodes. -// -// It assumes entries to be returned in "contents first" order, means this -// will only be called with a directory if all children of it have been -// visited. If the entry is indeed a directory, it'll also upload that -// directory to the store. For this, the so-far-assembled Directory object for -// this path needs to be passed in. -// -// It assumes the caller adds returned nodes to the directories it assembles. +/// This processes a given [walkdir::DirEntry] and returns a +/// proto::node::Node, depending on the type of the entry. +/// +/// If the entry is a file, its contents are uploaded. +/// If the entry is a directory, the Directory is uploaded as well. +/// For this to work, it relies on the caller to provide the directory object +/// with the previously returned (child) nodes. +/// +/// It assumes entries to be returned in "contents first" order, means this +/// will only be called with a directory if all children of it have been +/// visited. If the entry is indeed a directory, it'll also upload that +/// directory to the store. For this, the so-far-assembled Directory object for +/// this path needs to be passed in. +/// +/// It assumes the caller adds returned nodes to the directories it assembles. #[instrument(skip_all, fields(entry.file_type=?&entry.file_type(),entry.path=?entry.path()))] async fn process_entry<'a, BS>( blob_service: BS, |