microcosm.blue
Fast and robust atproto CAR file processing in rust
fmt
bad-example.com
+10
-4
benches/cid-check.rs
+10
-4
benches/cid-check.rs
···
1
use criterion::{Criterion, criterion_group, criterion_main};
2
use multihash_codetable::{Code, MultihashDigest};
3
-
use cid::Cid;
4
use sha2::{Digest, Sha256};
5
6
fn multihash_verify(given: Cid, block: &[u8]) -> bool {
···
30
let cid = Cid::new_v1(0x71, Code::Sha2_256.digest(&some_bytes));
31
32
let mut g = c.benchmark_group("CID check");
33
-
g.bench_function("multihash", |b| b.iter(|| multihash_verify(cid, &some_bytes)));
34
-
g.bench_function("effortful", |b| b.iter(|| effortful_verify(cid, &some_bytes)));
35
-
g.bench_function("fastloose", |b| b.iter(|| fastloose_verify(cid, &some_bytes)));
36
}
37
38
criterion_group!(benches, criterion_benchmark);
···
1
+
use cid::Cid;
2
use criterion::{Criterion, criterion_group, criterion_main};
3
use multihash_codetable::{Code, MultihashDigest};
4
use sha2::{Digest, Sha256};
5
6
fn multihash_verify(given: Cid, block: &[u8]) -> bool {
···
30
let cid = Cid::new_v1(0x71, Code::Sha2_256.digest(&some_bytes));
31
32
let mut g = c.benchmark_group("CID check");
33
+
g.bench_function("multihash", |b| {
34
+
b.iter(|| multihash_verify(cid, &some_bytes))
35
+
});
36
+
g.bench_function("effortful", |b| {
37
+
b.iter(|| effortful_verify(cid, &some_bytes))
38
+
});
39
+
g.bench_function("fastloose", |b| {
40
+
b.iter(|| fastloose_verify(cid, &some_bytes))
41
+
});
42
}
43
44
criterion_group!(benches, criterion_benchmark);
+1
-2
src/drive.rs
+1
-2
src/drive.rs
···
1
//! Consume a CAR from an AsyncRead, producing an ordered stream of records
2
3
-
use multihash_codetable::{MultihashDigest, Code};
4
use crate::{
5
Bytes, HashMap,
6
disk::{DiskError, DiskStore},
···
9
};
10
use cid::Cid;
11
use iroh_car::CarReader;
12
use std::convert::Infallible;
13
use tokio::{io::AsyncRead, sync::mpsc};
14
···
205
// try to load all the blocks into memory
206
let mut mem_size = 0;
207
while let Some((cid, data)) = car.next_block().await? {
208
-
209
// lkasdjflkajdsflkajsfdlkjasdf
210
if !verify_block(cid, &data) {
211
return Err(DriveError::BadCID);
···
1
//! Consume a CAR from an AsyncRead, producing an ordered stream of records
2
3
use crate::{
4
Bytes, HashMap,
5
disk::{DiskError, DiskStore},
···
8
};
9
use cid::Cid;
10
use iroh_car::CarReader;
11
+
use multihash_codetable::{Code, MultihashDigest};
12
use std::convert::Infallible;
13
use tokio::{io::AsyncRead, sync::mpsc};
14
···
205
// try to load all the blocks into memory
206
let mut mem_size = 0;
207
while let Some((cid, data)) = car.next_block().await? {
208
// lkasdjflkajdsflkajsfdlkjasdf
209
if !verify_block(cid, &data) {
210
return Err(DriveError::BadCID);