[backfill] walk the mst while a filtered car streams
357 unmodified linesExpand all358359360361362363364365366362363364365366367368206 unmodified linesExpand all357 unmodified linesExpand all let mut filtered = filtered_car::FilteredCar::new(filter.clone(), false).unwrap(); for chunk in car_bytes.chunks(BODY_CHUNK) { filtered.push(chunk).unwrap(); } let repo = filtered.finish().unwrap(); let mut scanner = SparseScanner::new(repo.ranges, repo.blocks); scanner.rule_out(repo.ruled_out); let scan = scanner.scan(mst_root).unwrap().unwrap(); (scanner.take_blocks(), scan) let mut repo = filtered.finish().unwrap(); let scan = repo.scanner.scan(mst_root).unwrap().unwrap(); (repo.blocks, scan)}
fn record( rows: &mut Vec<(String, Stats)>,206 unmodified linesExpand all435 unmodified linesExpand all43643743843944044144244344444044144244344444544662 unmodified lines435 unmodified linesExpand all let mut filtered = filtered_car::FilteredCar::new(filter.clone(), false).unwrap(); for chunk in car_bytes.chunks(BODY_CHUNK) { filtered.push(chunk).unwrap(); } let repo = filtered.finish().unwrap(); let mut scanner = SparseScanner::new(repo.ranges, repo.blocks); scanner.rule_out(repo.ruled_out); let scan = scanner.scan(mst_root).unwrap().unwrap(); (scanner.take_blocks(), scan) let mut repo = filtered.finish().unwrap(); let scan = repo.scanner.scan(mst_root).unwrap().unwrap(); (repo.blocks, scan)}
/// streaming filtered backfill (`FilteredCar` + `SparseScanner`) across selective, dense, and/// reverse out-of-order cars.62 unmodified lines