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

Fix concurrency test

Browse Source 
It was accidentally using row ID as transaction ID...
This commit is contained in:
Pekka Enberg
2023-04-12 11:56:22 +03:00
parent 3cecf777cf
commit 77d639fc20
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
core/mvcc/database/tests/concurrency_test.rs
View File

@@ -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();