Skip to content

Commit c548dc8

Browse files
naureAurélien Nicolas
andauthored
fix/program-size2: refactor padding_zero (#615)
Follow-up to #611. --------- Co-authored-by: Aurélien Nicolas <[email protected]>
1 parent a1e7462 commit c548dc8

File tree

4 files changed

+39
-43
lines changed

4 files changed

+39
-43
lines changed

ceno_zkvm/src/instructions.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ pub trait Instruction<E: ExtensionField> {
9494
num_padding_instances
9595
};
9696
raw_witin
97-
.par_batch_iter_padding_mut(num_padding_instance_per_batch)
97+
.par_batch_iter_padding_mut(None, num_padding_instance_per_batch)
9898
.with_min_len(MIN_PAR_SIZE)
9999
.for_each(|row| {
100100
row.chunks_mut(num_witin)

ceno_zkvm/src/tables/mod.rs

Lines changed: 29 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,8 @@ use crate::{
22
circuit_builder::CircuitBuilder, error::ZKVMError, scheme::constants::MIN_PAR_SIZE,
33
witness::RowMajorMatrix,
44
};
5-
use ff::Field;
65
use ff_ext::ExtensionField;
6+
use goldilocks::SmallField;
77
use rayon::iter::{IndexedParallelIterator, ParallelIterator};
88
use std::{collections::HashMap, mem::MaybeUninit};
99
mod range;
@@ -46,25 +46,34 @@ pub trait TableCircuit<E: ExtensionField> {
4646
table: &mut RowMajorMatrix<E::BaseField>,
4747
num_witin: usize,
4848
) -> Result<(), ZKVMError> {
49-
// Fill the padding with zeros, if any.
50-
let num_padding_instances = table.num_padding_instances();
51-
if num_padding_instances > 0 {
52-
let nthreads =
53-
std::env::var("RAYON_NUM_THREADS").map_or(8, |s| s.parse::<usize>().unwrap_or(8));
54-
let padding_instance = vec![MaybeUninit::new(E::BaseField::ZERO); num_witin];
55-
let num_padding_instance_per_batch = if num_padding_instances > 256 {
56-
num_padding_instances.div_ceil(nthreads)
57-
} else {
58-
num_padding_instances
59-
};
60-
table
61-
.par_batch_iter_padding_mut(num_padding_instance_per_batch)
62-
.with_min_len(MIN_PAR_SIZE)
63-
.for_each(|row| {
64-
row.chunks_mut(num_witin)
65-
.for_each(|instance| instance.copy_from_slice(padding_instance.as_slice()));
66-
});
67-
}
49+
padding_zero(table, num_witin, None);
6850
Ok(())
6951
}
7052
}
53+
54+
/// Fill the padding with zeros. Start after the given `num_instances`, or detect it from the table.
55+
pub fn padding_zero<F: SmallField>(
56+
table: &mut RowMajorMatrix<F>,
57+
num_cols: usize,
58+
num_instances: Option<usize>,
59+
) {
60+
// Fill the padding with zeros, if any.
61+
let num_padding_instances = table.num_padding_instances();
62+
if num_padding_instances > 0 {
63+
let nthreads =
64+
std::env::var("RAYON_NUM_THREADS").map_or(8, |s| s.parse::<usize>().unwrap_or(8));
65+
let padding_instance = vec![MaybeUninit::new(F::ZERO); num_cols];
66+
let num_padding_instance_per_batch = if num_padding_instances > 256 {
67+
num_padding_instances.div_ceil(nthreads)
68+
} else {
69+
num_padding_instances
70+
};
71+
table
72+
.par_batch_iter_padding_mut(num_instances, num_padding_instance_per_batch)
73+
.with_min_len(MIN_PAR_SIZE)
74+
.for_each(|row| {
75+
row.chunks_mut(num_cols)
76+
.for_each(|instance| instance.copy_from_slice(padding_instance.as_slice()));
77+
});
78+
}
79+
}

ceno_zkvm/src/tables/program.rs

Lines changed: 4 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ use crate::{
77
scheme::constants::MIN_PAR_SIZE,
88
set_fixed_val, set_val,
99
structs::ROMType,
10-
tables::TableCircuit,
10+
tables::{TableCircuit, padding_zero},
1111
utils::i64_to_base,
1212
witness::RowMajorMatrix,
1313
};
@@ -175,16 +175,8 @@ impl<E: ExtensionField> TableCircuit<E> for ProgramTableCircuit<E> {
175175
}
176176
});
177177

178-
assert_eq!(INVALID as u64, 0, "cannot use 0 as program padding");
179-
fixed
180-
.par_iter_mut()
181-
.with_min_len(MIN_PAR_SIZE)
182-
.skip(num_instructions)
183-
.for_each(|row| {
184-
for col in config.record.as_slice() {
185-
set_fixed_val!(row, *col, 0_u64.into());
186-
}
187-
});
178+
assert_eq!(INVALID as u64, 0, "0 padding must be invalid instructions");
179+
padding_zero(&mut fixed, num_fixed, Some(num_instructions));
188180

189181
fixed
190182
}
@@ -212,13 +204,7 @@ impl<E: ExtensionField> TableCircuit<E> for ProgramTableCircuit<E> {
212204
set_val!(row, config.mlt, E::BaseField::from(mlt as u64));
213205
});
214206

215-
witness
216-
.par_iter_mut()
217-
.with_min_len(MIN_PAR_SIZE)
218-
.skip(program.instructions.len())
219-
.for_each(|row| {
220-
set_val!(row, config.mlt, 0_u64);
221-
});
207+
padding_zero(&mut witness, num_witin, Some(program.instructions.len()));
222208

223209
Ok(witness)
224210
}

ceno_zkvm/src/witness.rs

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -87,12 +87,13 @@ impl<T: Sized + Sync + Clone + Send + Copy> RowMajorMatrix<T> {
8787

8888
pub fn par_batch_iter_padding_mut(
8989
&mut self,
90-
num_rows: usize,
90+
num_instances: Option<usize>,
91+
batch_size: usize,
9192
) -> rayon::slice::ChunksMut<'_, MaybeUninit<T>> {
92-
let valid_instance = self.num_instances();
93-
self.values[valid_instance * self.num_col..]
93+
let num_instances = num_instances.unwrap_or(self.num_instances());
94+
self.values[num_instances * self.num_col..]
9495
.as_mut()
95-
.par_chunks_mut(num_rows * self.num_col)
96+
.par_chunks_mut(batch_size * self.num_col)
9697
}
9798

9899
pub fn de_interleaving(mut self) -> Vec<Vec<T>> {

0 commit comments

Comments
 (0)