reivilibre/yama
1
0
Fork 0
Code Issues 27 Pull Requests Releases 16 Wiki Activity

Antilint

Browse Source
This commit is contained in:
Olivier 'reivilibre' 2021-11-20 10:41:35 +00:00
parent aebd32da4a
commit 4fa300e575
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
yama/src/pile/integrity.rs
View File

@ -122,7 +122,9 @@ impl<RP: RawPile> RawPile for RawPileIntegrityChecker<RP> {
) -> anyhow::Result<Sender<(ChunkId, Vec<u8>)>> {
// TODO primitive implementation but good enough for now.
// May want metrics later?
let next_stage = self.underlying.build_storage_pipeline(settings, controller_send)?;
let next_stage = self
.underlying
.build_storage_pipeline(settings, controller_send)?;
let (input, receiver) = crossbeam_channel::bounded::<(ChunkId, Vec<u8>)>(64);
std::thread::spawn(move || {
while let Ok((chunk_id, mut chunk)) = receiver.recv() {