From 905b34c9a81ceef0835cddaff3912792ba2dbe86 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=EA=B9=80=EC=84=A0=EC=9A=B0?= Date: Mon, 16 Sep 2024 22:03:53 +0900 Subject: [PATCH] Nit --- test/src/lib.rs | 65 ++----------------------------------------------- 1 file changed, 2 insertions(+), 63 deletions(-) diff --git a/test/src/lib.rs b/test/src/lib.rs index 71f813ca0..cbe840830 100644 --- a/test/src/lib.rs +++ b/test/src/lib.rs @@ -1,9 +1,6 @@ use limbo_core::Database; -use log::{LevelFilter, Record}; -use std::io::Write; use std::path::PathBuf; -use std::sync::Once; -use std::sync::{Arc, Mutex}; +use std::sync::Arc; use tempfile::TempDir; #[allow(dead_code)] @@ -47,7 +44,7 @@ mod tests { let conn = tmp_db.connect_limbo(); let list_query = "SELECT * FROM test"; - let max_iterations = 1000; + let max_iterations = 10000; for i in 0..max_iterations { if (i % 100) == 0 { let progress = (i as f64 / max_iterations as f64) * 100.0; @@ -100,64 +97,6 @@ mod tests { Ok(()) } - #[ignore] - #[test] - fn test_btree_splitting() -> anyhow::Result<()> { - static INIT: Once = Once::new(); - let log_buffer = Arc::new(Mutex::new(Vec::new())); - let log_buffer_clone = Arc::clone(&log_buffer); - - INIT.call_once(|| { - env_logger::builder() - .format(move |buf, record: &Record| { - let mut log_buffer = log_buffer_clone.lock().unwrap(); - writeln!(log_buffer, "{}", record.args()).unwrap(); - writeln!(buf, "{}", record.args())?; - Ok(()) - }) - .filter_level(LevelFilter::Trace) - .init(); - }); - - let tmp_db = TempDatabase::new("CREATE TABLE test (x INTEGER PRIMARY KEY);"); - let conn = tmp_db.connect_limbo(); - - let max_iterations = 10000; - let mut page_split_log_found = false; - for i in 0..max_iterations { - let insert_query = format!("INSERT INTO test VALUES ({})", i); - match conn.query(insert_query) { - Ok(Some(ref mut rows)) => loop { - match rows.next_row()? { - RowResult::IO => { - tmp_db.io.run_once()?; - } - RowResult::Done => break, - _ => unreachable!(), - } - }, - Ok(None) => {} - Err(err) => { - eprintln!("{}", err); - } - }; - conn.cacheflush()?; - - let logs = log_buffer.lock().unwrap(); - let logs_str = String::from_utf8_lossy(&logs); - if logs_str.contains("Balancing root") && logs_str.contains("Balancing leaf") { - page_split_log_found = true; - break; - } - } - - assert!( - page_split_log_found, - "Expected root page split but not executed" - ); - Ok(()) - } - #[test] fn test_simple_overflow_page() -> anyhow::Result<()> { let _ = env_logger::try_init();