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

revert pager changes

Browse Source
This commit is contained in:
Pavan-Nambi
2025-09-20 10:59:16 +05:30
parent 0de92cd7fb
commit 6de280789e
1 changed files with 3 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
core/lib.rs
View File

@@ -1412,24 +1412,10 @@ impl Connection {
#[cfg(all(feature = "fs", feature = "conn_raw_api"))]
pub fn read_schema_version(&self) -> Result<u32> {
let pager = self.pager.borrow();
let was_in_tx = self.transaction_state.get() != TransactionState::None;
if !was_in_tx {
pager.begin_read_tx()?;
}
let result = pager
pager
.io
.block(|| pager.with_header(|header| header.schema_cookie));
if !was_in_tx {
pager.end_read_tx()?;
}
match result {
Ok(version) => Ok(version.get()),
Err(LimboError::Page1NotAlloc) => Ok(0),
Err(e) => Err(e),
}
.block(|| pager.with_header(|header| header.schema_cookie))
.map(|version| version.get())
}
/// Update schema version to the new value within opened write transaction