diff options
author | Florian Klink <flokli@flokli.de> | 2023-03-10T22·24+0100 |
---|---|---|
committer | clbot <clbot@tvl.fyi> | 2023-03-11T14·12+0000 |
commit | b049b88d2d7bcb9caef158ffdf9cd931c62d2511 (patch) | |
tree | 904030b3aaddf712ddc3259ecdd3a872d7afc3ee /tvix/store/src/import.rs | |
parent | 2dc93f8de26ba15106fe8a086bb85ca50c09860a (diff) |
refactor(tvix/store): factor out hash update into function r/5952
We're using this in a bunch of places. Let's move it into a helper function. Change-Id: I118fba35f6d343704520ba37280e4ca52a61da44 Reviewed-on: https://cl.tvl.fyi/c/depot/+/8251 Autosubmit: flokli <flokli@flokli.de> Tested-by: BuildkiteCI Reviewed-by: raitobezarius <tvl@lahfa.xyz>
Diffstat (limited to 'tvix/store/src/import.rs')
-rw-r--r-- | tvix/store/src/import.rs | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/tvix/store/src/import.rs b/tvix/store/src/import.rs index bd911cc2e81d..564363f1ff1a 100644 --- a/tvix/store/src/import.rs +++ b/tvix/store/src/import.rs @@ -1,4 +1,7 @@ -use crate::{chunkservice::upload_chunk, proto}; +use crate::{ + chunkservice::{update_hasher, upload_chunk}, + proto, +}; use std::{ collections::HashMap, fmt::Debug, @@ -138,12 +141,8 @@ fn process_entry<BS: BlobService, CS: ChunkService + std::marker::Sync, DS: Dire let chunk_len = chunk.data.len() as u32; - // update calculate blob hash, and use rayon if data is > 128KiB. - if chunk_len > 128 * 1024 { - blob_hasher.update_rayon(&chunk.data); - } else { - blob_hasher.update(&chunk.data); - } + // update calculate blob hash + update_hasher(&mut blob_hasher, &chunk.data); let chunk_digest = upload_chunk(chunk_service, chunk.data)?; |