From 60d3a837b734d1eddda683ca236286f0f10f7f5b Mon Sep 17 00:00:00 2001
From: Pekka Enberg <penberg@iki.fi>
Date: Mon, 22 Sep 2025 17:52:05 +0300
Subject: [PATCH] core: Wrap Connection::cache_size with AtomicI32

---
 core/lib.rs | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/core/lib.rs b/core/lib.rs
index c413101c5..e43f95ec2 100644
--- a/core/lib.rs
+++ b/core/lib.rs
@@ -70,7 +70,7 @@ use std::{
     ops::Deref,
     rc::Rc,
     sync::{
-        atomic::{AtomicBool, AtomicI64, AtomicUsize, Ordering},
+        atomic::{AtomicBool, AtomicI32, AtomicI64, AtomicUsize, Ordering},
         Arc, LazyLock, Mutex, Weak,
     },
     time::Duration,
@@ -507,7 +507,7 @@ impl Database {
             total_changes: AtomicI64::new(0),
             syms: RwLock::new(SymbolTable::new()),
             _shared_cache: false,
-            cache_size: Cell::new(default_cache_size),
+            cache_size: AtomicI32::new(default_cache_size),
             page_size: Cell::new(page_size),
             wal_auto_checkpoint_disabled: Cell::new(false),
             capture_data_changes: RefCell::new(CaptureDataChangesMode::Off),
@@ -992,7 +992,7 @@ pub struct Connection {
     total_changes: AtomicI64,
     syms: RwLock<SymbolTable>,
     _shared_cache: bool,
-    cache_size: Cell<i32>,
+    cache_size: AtomicI32,
     /// page size used for an uninitialized database or the next vacuum command.
     /// it's not always equal to the current page size of the database
     page_size: Cell<PageSize>,
@@ -1683,10 +1683,10 @@ impl Connection {
     }
 
     pub fn get_cache_size(&self) -> i32 {
-        self.cache_size.get()
+        self.cache_size.load(Ordering::SeqCst)
     }
     pub fn set_cache_size(&self, size: i32) {
-        self.cache_size.set(size);
+        self.cache_size.store(size, Ordering::SeqCst);
     }
 
     pub fn get_capture_data_changes(&self) -> std::cell::Ref<'_, CaptureDataChangesMode> {