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

refactor File and Database Storage to remove Arc<Connection> and return Arc<Connection> for caller to wait for completion

Browse Source
This commit is contained in:
pedrocarlo
2025-06-24 22:29:14 -03:00
parent 64d9193e7b
commit bac5e4b563
13 changed files with 117 additions and 92 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
bindings/javascript/src/lib.rs
View File

@@ -583,7 +583,7 @@ impl DatabaseFile {
}
impl limbo_core::DatabaseStorage for DatabaseFile {
fn read_page(&self, page_idx: usize, c: Arc<limbo_core::Completion>) -> limbo_core::Result<()> {
fn read_page(&self, page_idx: usize, c: limbo_core::Completion) -> limbo_core::Result<()> {
let r = match c.completion_type {
limbo_core::CompletionType::Read(ref r) => r,
_ => unreachable!(),
@@ -602,7 +602,7 @@ impl limbo_core::DatabaseStorage for DatabaseFile {
&self,
page_idx: usize,
buffer: Arc<std::cell::RefCell<limbo_core::Buffer>>,
c: Arc<limbo_core::Completion>,
c: limbo_core::Completion,
) -> limbo_core::Result<()> {
let size = buffer.borrow().len();
let pos = (page_idx - 1) * size;
@@ -610,8 +610,9 @@ impl limbo_core::DatabaseStorage for DatabaseFile {
Ok(())
}
fn sync(&self, c: Arc<limbo_core::Completion>) -> limbo_core::Result<()> {
self.file.sync(c)
fn sync(&self, c: limbo_core::Completion) -> limbo_core::Result<()> {
let _ = self.file.sync(c)?;
Ok(())
}
fn size(&self) -> limbo_core::Result<u64> {