aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2025-12-29 05:54:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge 'core/storage: Switch Pager::max_page_count to AtomicU32' from Pekka Enberg

Browse Source 
Closes #3197
This commit is contained in:
Pekka Enberg
2025-09-18 15:45:39 +03:00
committed by GitHub
parent 6e9684c763 19513fd9a7
commit d69cdd92d2
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
core/storage/pager.rs
View File

@@ -524,7 +524,7 @@ pub struct Pager {
reserved_space: AtomicU16,
free_page_state: RefCell<FreePageState>,
/// Maximum number of pages allowed in the database. Default is 1073741823 (SQLite default).
max_page_count: Cell<u32>,
max_page_count: AtomicU32,
#[cfg(not(feature = "omit_autovacuum"))]
/// State machine for [Pager::ptrmap_get]
ptrmap_get_state: RefCell<PtrMapGetState>,
@@ -627,7 +627,7 @@ impl Pager {
reserved_space: AtomicU16::new(RESERVED_SPACE_NOT_SET),
free_page_state: RefCell::new(FreePageState::Start),
allocate_page_state: RwLock::new(AllocatePageState::Start),
max_page_count: Cell::new(DEFAULT_MAX_PAGE_COUNT),
max_page_count: AtomicU32::new(DEFAULT_MAX_PAGE_COUNT),
#[cfg(not(feature = "omit_autovacuum"))]
ptrmap_get_state: RefCell::new(PtrMapGetState::Start),
#[cfg(not(feature = "omit_autovacuum"))]
@@ -641,7 +641,7 @@ impl Pager {
/// Get the maximum page count for this database
pub fn get_max_page_count(&self) -> u32 {
self.max_page_count.get()
self.max_page_count.load(Ordering::SeqCst)
}
/// Set the maximum page count for this database
@@ -653,7 +653,7 @@ impl Pager {
// Clamp new_max to be at least the current database size
let clamped_max = std::cmp::max(new_max, current_page_count);
self.max_page_count.set(clamped_max);
self.max_page_count.store(clamped_max, Ordering::SeqCst);
Ok(IOResult::Done(clamped_max))
}