From 15dafd46c107af0bd56326dbc9ccc7b553b034f7 Mon Sep 17 00:00:00 2001 From: Nikita Sivukhin Date: Wed, 12 Nov 2025 16:40:38 +0400 Subject: [PATCH] replace turso_assert -> assert --- sync/engine/src/database_sync_lazy_storage.rs | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/sync/engine/src/database_sync_lazy_storage.rs b/sync/engine/src/database_sync_lazy_storage.rs index ecd3fc0ad..ad83b628c 100644 --- a/sync/engine/src/database_sync_lazy_storage.rs +++ b/sync/engine/src/database_sync_lazy_storage.rs @@ -1,8 +1,6 @@ use std::sync::Arc; -use turso_core::{ - turso_assert, Buffer, Completion, CompletionError, DatabaseStorage, File, LimboError, -}; +use turso_core::{Buffer, Completion, CompletionError, DatabaseStorage, File, LimboError}; use crate::{ database_sync_operations::{pull_pages_v1, ProtocolIoStats, PAGE_SIZE}, @@ -76,7 +74,7 @@ impl DatabaseStorage for LazyDatabaseStorage

{ let check_buffer = Arc::new(Buffer::new_temporary(size)); let check_c = dirty_file.pread(pos, Completion::new_read(check_buffer.clone(), |_| {}))?; - turso_assert!( + assert!( check_c.finished(), "LazyDatabaseStorage works only with sync IO" ); @@ -85,7 +83,7 @@ impl DatabaseStorage for LazyDatabaseStorage

{ let clean_c = self .clean_file .pread(pos, Completion::new_read(clean_buffer.clone(), |_| {}))?; - turso_assert!( + assert!( clean_c.finished(), "LazyDatabaseStorage works only with sync IO" ); @@ -121,7 +119,7 @@ impl DatabaseStorage for LazyDatabaseStorage

{ buf.clone(), Completion::new_write(|_| {}), )?; - turso_assert!( + assert!( dirty_c.finished(), "LazyDatabaseStorage works only with sync IO" ); @@ -129,7 +127,7 @@ impl DatabaseStorage for LazyDatabaseStorage

{ let clean_c = clean_file.pwrite(pos, buf.clone(), Completion::new_write(|_| {}))?; - turso_assert!( + assert!( clean_c.finished(), "LazyDatabaseStorage works only with sync IO" ); @@ -218,7 +216,7 @@ impl DatabaseStorage for LazyDatabaseStorage

{ fn sync(&self, c: turso_core::Completion) -> turso_core::Result { if let Some(dirty_file) = &self.dirty_file { let dirty_c = dirty_file.sync(Completion::new_sync(|_| {}))?; - turso_assert!( + assert!( dirty_c.finished(), "LazyDatabaseStorage works only with sync IO" ); @@ -238,7 +236,7 @@ impl DatabaseStorage for LazyDatabaseStorage

{ ) -> turso_core::Result { if let Some(dirty_file) = &self.dirty_file { let dirty_c = dirty_file.truncate(len as u64, Completion::new_trunc(|_| {}))?; - turso_assert!( + assert!( dirty_c.finished(), "LazyDatabaseStorage works only with sync IO" );