Function wal_group_commit

nodedb-wal/benches/wal_throughput.rs:63–105

(b: &mut Bencher)

    tags = "core"
)]
fn wal_group_commit(b: &mut Bencher) {
    let dir = tempfile::tempdir().unwrap();
    let path = dir.path().join("bench_gc.wal");
    let payload = vec![0xCDu8; 128];

    b.iter(|| {
        let _ = std::fs::remove_file(&path);
        let writer = Arc::new(Mutex::new(
            WalWriter::open_without_direct_io(&path).unwrap(),
        ));
        let committer = Arc::new(GroupCommitter::new());

        let handles: Vec<_> = (0..10)
            .map(|t| {
                let c = Arc::clone(&committer);
                let w = Arc::clone(&writer);
                let p = payload.clone();
                std::thread::spawn(move || {
                    for _ in 0..1000 {
                        c.submit(
                            &w,
                            PendingWrite {
                                record_type: RecordType::Put as u32,
                                tenant_id: t,
                                vshard_id: 0,
                                database_id: 0,
                                payload: p.clone(),
                            },
                        )
                        .unwrap();
                    }
                })
            })
            .collect();

        for h in handles {
            h.join().unwrap();
        }

        let w = writer.lock().unwrap();
        black_box(w.next_lsn())
    });
}

// 1000 records per iteration of wal_append_fsync_1k_128b.
#[synthetic(