Function bench_append

crates/commitlog/benches/write.rs:40–81

(c: &mut Criterion, label: &str, params: Params)

}

fn bench_append(c: &mut Criterion, label: &str, params: Params) {
    let id = BenchmarkId::from_parameter(&params);
    c.benchmark_group(label)
        .sample_size(10)
        .sampling_mode(SamplingMode::Flat)
        .throughput(Throughput::Elements(params.total_appends))
        .bench_with_input(
            id,
            &params,
            |b,
             Params {
                 payloads,
                 txs_per_commit,
                 total_appends,
                 fsync_every,
             }| {
                let tmp = tempdir_in(".").unwrap();
                let dir = CommitLogDir::from_path_unchecked(tmp.path());
                let clog = Commitlog::open(dir, Options::default(), None).unwrap();
                let mut offset = clog.max_committed_offset().unwrap_or_default();

                b.iter(|| {
                    let mut payloads = payloads.iter().cycle();
                    for i in 0..*total_appends {
                        clog.commit(payloads.by_ref().take(txs_per_commit.get() as usize).map(|payload| {
                            let tx = Transaction {
                                offset,
                                txdata: payload,
                            };
                            offset += 1;
                            tx
                        }))
                        .unwrap();
                        if i % fsync_every == 0 {
                            clog.flush_and_sync().unwrap();
                        }
                    }
                    clog.flush_and_sync().unwrap();
                })
            },
        );
}

fn baseline(c: &mut Criterion) {
    let params = Params::with_payloads([Payload::new([b'z'; 64])]);