diff --git a/perf/throughput/turso/src/main.rs b/perf/throughput/turso/src/main.rs index adf873da7..87d072252 100644 --- a/perf/throughput/turso/src/main.rs +++ b/perf/throughput/turso/src/main.rs @@ -2,6 +2,7 @@ use clap::{Parser, ValueEnum}; use std::sync::atomic::{AtomicU64, Ordering}; use std::sync::{Arc, Barrier}; use std::time::{Duration, Instant}; +use tracing_subscriber::EnvFilter; use turso::{Builder, Database, Result}; #[derive(Debug, Clone, Copy, ValueEnum)] @@ -9,6 +10,7 @@ enum TransactionMode { Legacy, Mvcc, Concurrent, + LogicalLog, } #[derive(Parser)] @@ -44,7 +46,11 @@ struct Args { #[tokio::main] async fn main() -> Result<()> { - let _ = tracing_subscriber::fmt::try_init(); + let _ = tracing_subscriber::fmt() + .with_env_filter(EnvFilter::from_default_env()) + .with_ansi(false) + .with_thread_ids(true) + .init(); let args = Args::parse(); println!( @@ -135,6 +141,12 @@ async fn setup_database(db_path: &str, mode: TransactionMode) -> Result { + builder + .with_mvcc(true, turso::MvccMode::LogicalLog) + .build() + .await? + } }; let conn = db.connect()?; @@ -180,7 +192,7 @@ async fn worker_thread( let begin_stmt = match mode { TransactionMode::Legacy | TransactionMode::Mvcc => "BEGIN", - TransactionMode::Concurrent => "BEGIN CONCURRENT", + TransactionMode::Concurrent | TransactionMode::LogicalLog => "BEGIN CONCURRENT", }; conn.execute(begin_stmt, ()).await?;