From 2a03c1a6173c364984f943d8a4f676e98c4dae13 Mon Sep 17 00:00:00 2001 From: Jussi Saurio Date: Tue, 21 Oct 2025 11:18:26 +0300 Subject: [PATCH] Add subjournal and savepoints to Pager struct --- core/storage/pager.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/core/storage/pager.rs b/core/storage/pager.rs index 820781508..e5f5757dd 100644 --- a/core/storage/pager.rs +++ b/core/storage/pager.rs @@ -1,4 +1,5 @@ use crate::storage::database::DatabaseFile; +use crate::storage::subjournal::Subjournal; use crate::storage::wal::IOV_MAX; use crate::storage::{ buffer_pool::BufferPool, @@ -508,7 +509,8 @@ pub struct Pager { /// I/O interface for input/output operations. pub io: Arc, dirty_pages: Arc>>>, - + subjournal: RwLock>, + savepoints: Arc>>, commit_info: RwLock, checkpoint_state: RwLock, syncing: Arc, @@ -626,6 +628,8 @@ impl Pager { dirty_pages: Arc::new(RwLock::new(HashSet::with_hasher( hash::BuildHasherDefault::new(), ))), + subjournal: RwLock::new(None), + savepoints: Arc::new(RwLock::new(Vec::new())), commit_info: RwLock::new(CommitInfo { result: None, completions: Vec::new(),