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

Fix compile error

Browse Source
This commit is contained in:
Pekka Enberg
2023-04-12 12:17:34 +03:00
parent a52bf9158b
commit 477da5b60a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/mvcc/database/src/database.rs
View File

@@ -209,7 +209,7 @@ impl<Clock: LogicalClock> Database<Clock> {
match rows.get_mut(&id) {
Some(row_versions) => match row_versions.last_mut() {
Some(v) => {
let tx = txs.get(&tx_id).ok_or(DatabaseError::NoSuchTransactionID(tx))?;
let tx = txs.get(&tx_id).ok_or(DatabaseError::NoSuchTransactionID(tx_id))?;
assert!(tx.state == TransactionState::Active);
if is_version_visible(&txs, tx, v) {
v.end = Some(TxTimestampOrID::TxID(tx.tx_id));
@@ -222,8 +222,8 @@ impl<Clock: LogicalClock> Database<Clock> {
None => return Ok(false),
}
let tx = txs
.get_mut(&tx)
.ok_or(DatabaseError::NoSuchTransactionID(tx))?;
.get_mut(&tx_id)
.ok_or(DatabaseError::NoSuchTransactionID(tx_id))?;
tx.insert_to_write_set(id);
Ok(true)
}