From 77d639fc208e9eea204b429efe906f1e9504d949 Mon Sep 17 00:00:00 2001 From: Pekka Enberg Date: Wed, 12 Apr 2023 11:56:22 +0300 Subject: [PATCH] Fix concurrency test It was accidentally using row ID as transaction ID... --- core/mvcc/database/tests/concurrency_test.rs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/core/mvcc/database/tests/concurrency_test.rs b/core/mvcc/database/tests/concurrency_test.rs index c45baddca..a39a87dec 100644 --- a/core/mvcc/database/tests/concurrency_test.rs +++ b/core/mvcc/database/tests/concurrency_test.rs @@ -4,7 +4,6 @@ use shuttle::sync::Arc; use shuttle::thread; use std::sync::atomic::Ordering; -#[ignore] #[test] fn test_non_overlapping_concurrent_inserts() { // Two threads insert to the database concurrently using non-overlapping @@ -24,7 +23,7 @@ fn test_non_overlapping_concurrent_inserts() { id, data: "Hello".to_string(), }; - db.insert(id, row.clone()).unwrap(); + db.insert(tx, row.clone()).unwrap(); db.commit_tx(tx); let tx = db.begin_tx(); let committed_row = db.read(tx, id).unwrap(); @@ -42,7 +41,7 @@ fn test_non_overlapping_concurrent_inserts() { id, data: "World".to_string(), }; - db.insert(id, row.clone()).unwrap(); + db.insert(tx, row.clone()).unwrap(); db.commit_tx(tx); let tx = db.begin_tx(); let committed_row = db.read(tx, id).unwrap();