encounter/nod-rs
1
0
Fork 0
mirror of https://github.com/encounter/nod-rs.git synced 2025-12-13 15:16:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

add scrub_update_partition for CISO

Browse Source
This commit is contained in:
Manuel Quarneti
2025-09-15 17:39:13 +02:00
parent 5e17e7063e
commit a1b2a0d96a
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
nod/src/io/ciso.rs
View File

@@ -123,7 +123,9 @@ impl BlockReader for BlockReaderCISO {
Ok(Block::new(block_idx, block_size, BlockKind::Raw)) Ok(Block::new(block_idx, block_size, BlockKind::Raw))
} }
fn block_size(&self) -> u32 { self.header.block_size.get() } fn block_size(&self) -> u32 {
self.header.block_size.get()
}
fn meta(&self) -> DiscMeta { fn meta(&self) -> DiscMeta {
let mut result = DiscMeta { let mut result = DiscMeta {
@@ -145,6 +147,7 @@ struct BlockProcessorCISO {
lfg: LaggedFibonacci, lfg: LaggedFibonacci,
disc_id: [u8; 4], disc_id: [u8; 4],
disc_num: u8, disc_num: u8,
scrub_update_partition: bool,
} }
impl Clone for BlockProcessorCISO { impl Clone for BlockProcessorCISO {
@@ -156,6 +159,7 @@ impl Clone for BlockProcessorCISO {
lfg: LaggedFibonacci::default(), lfg: LaggedFibonacci::default(),
disc_id: self.disc_id, disc_id: self.disc_id,
disc_num: self.disc_num, disc_num: self.disc_num,
scrub_update_partition: self.scrub_update_partition,
} }
} }
} }
@@ -178,7 +182,7 @@ impl BlockProcessor for BlockProcessorCISO {
&mut self.lfg, &mut self.lfg,
self.disc_id, self.disc_id,
self.disc_num, self.disc_num,
false self.scrub_update_partition,
)? { )? {
CheckBlockResult::Normal => { CheckBlockResult::Normal => {
BlockResult { block_idx, disc_data, block_data, meta: CheckBlockResult::Normal } BlockResult { block_idx, disc_data, block_data, meta: CheckBlockResult::Normal }
@@ -265,6 +269,7 @@ impl DiscWriter for DiscWriterCISO {
lfg: LaggedFibonacci::default(), lfg: LaggedFibonacci::default(),
disc_id, disc_id,
disc_num, disc_num,
scrub_update_partition: options.scrub_update_partition,
}, },
self.block_count, self.block_count,
options.processor_threads, options.processor_threads,
@@ -318,7 +323,11 @@ impl DiscWriter for DiscWriterCISO {
Ok(finalization) Ok(finalization)
} }
fn progress_bound(&self) -> u64 { self.disc_size } fn progress_bound(&self) -> u64 {
self.disc_size
}
fn weight(&self) -> DiscWriterWeight { DiscWriterWeight::Medium } fn weight(&self) -> DiscWriterWeight {
DiscWriterWeight::Medium
}
} }