aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-14 21:54:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #11 from penberg/throughput-bench

Browse Source 
Use Criterion's throughput estimation
This commit is contained in:
Pekka Enberg
2023-04-14 13:33:46 +03:00
committed by GitHub
parent e99f5d89fc 0f956fa179
commit c87d6ee44e
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
core/mvcc/database/benches/my_benchmark.rs
View File

@@ -1,12 +1,15 @@
use criterion::{criterion_group, criterion_main, Criterion};
use criterion::{criterion_group, criterion_main, Criterion, Throughput};
use mvcc_rs::clock::LocalClock;
use mvcc_rs::database::{Database, Row};
use pprof::criterion::{Output, PProfProfiler};
fn bench(c: &mut Criterion) {
let mut group = c.benchmark_group("mvcc-ops-throughput");
group.throughput(Throughput::Elements(1));
let clock = LocalClock::default();
let db = Database::new(clock);
c.bench_function("begin_tx", |b| {
group.bench_function("begin_tx", |b| {
b.iter(|| {
db.begin_tx();
})
@@ -14,7 +17,7 @@ fn bench(c: &mut Criterion) {
let clock = LocalClock::default();
let db = Database::new(clock);
c.bench_function("begin_tx + rollback_tx", |b| {
group.bench_function("begin_tx + rollback_tx", |b| {
b.iter(|| {
let tx_id = db.begin_tx();
db.rollback_tx(tx_id)
@@ -23,7 +26,7 @@ fn bench(c: &mut Criterion) {
let clock = LocalClock::default();
let db = Database::new(clock);
c.bench_function("begin_tx + commit_tx", |b| {
group.bench_function("begin_tx + commit_tx", |b| {
b.iter(|| {
let tx_id = db.begin_tx();
db.commit_tx(tx_id)
@@ -41,7 +44,7 @@ fn bench(c: &mut Criterion) {
},
)
.unwrap();
c.bench_function("read", |b| {
group.bench_function("read", |b| {
b.iter(|| {
db.read(tx, 1).unwrap();
})