Merge pull request #14 from paritytech/subshard

Subshard

Cargo.toml

@@ -20,8 +20,9 @@ panic = "abort"
 opt-level = 1
 
 [dev-dependencies]
-criterion = { version = "0.4.0", default-features = false, features = ["cargo_bench_support"] }
+criterion = { version = "0.5.1", default-features = false, features = ["cargo_bench_support"] }
 quickcheck = { version = "1.0.3", default-features = false }
+rand = { version = "0.8.4", features = [ "small_rng"] }
 
 [[bench]]
 name = "all"

benches/all.rs

@@ -86,8 +86,13 @@ fn bench_all(c: &mut Criterion) {
 			group.throughput(Throughput::Bytes(pov.len() as u64));
 			group.bench_with_input(BenchmarkId::from_parameter(param), &n_chunks, |b, &n| {
 				b.iter(|| {
-					let _pov: Vec<u8> =
-						reconstruct_from_systematic(n, chunks.clone(), pov.len()).unwrap();
+					let _pov: Vec<u8> = reconstruct_from_systematic(
+						n,
+						chunks.len(),
+						&mut chunks.iter().map(Vec::as_slice),
+						pov.len(),
+					)
+					.unwrap();
 				});
 			});
 		}

fuzz/fuzz_targets/round_trip.rs

@@ -16,7 +16,8 @@ fuzz_target!(|data: (Vec<u8>, u16)| {
 	let threshold = systematic_recovery_threshold(n_chunks).unwrap();
 	let reconstructed_systematic: Vec<u8> = reconstruct_from_systematic(
 		n_chunks,
-		chunks.iter().cloned().take(threshold as usize).collect(),
+		chunks.len(),
+		&mut chunks.iter().map(Vec::as_slice),
 		data.len(),
 	)
 	.unwrap();