fmt

Author: MarinPostma

sqld/src/connection/config.rs

@@ -43,7 +43,6 @@ impl Default for DatabaseConfig {
     }
 }
 
-
 impl DatabaseConfigStore {
     pub fn load(db_path: &Path) -> Result<Self> {
         let config_path = db_path.join("config.json");

sqld/src/connection/libsql.rs

@@ -208,7 +208,8 @@ where
                 current_frame_no_receiver,
                 state,
             )?;
-            conn.conn.pragma_update(None, "max_page_count", max_db_size)?;
+            conn.conn
+                .pragma_update(None, "max_page_count", max_db_size)?;
             Ok(conn)
         })
         .await

sqld/src/namespace/fork.rs

@@ -17,7 +17,6 @@ use crate::{BLOCKING_RT, LIBSQL_PAGE_SIZE};
 
 use super::{MakeNamespace, NamespaceName, ResetCb, RestoreOption};
 
-
 type Result<T> = crate::Result<T, ForkError>;
 
 #[derive(Debug, thiserror::Error)]

sqld/src/replication/primary/logger.rs

@@ -16,7 +16,6 @@ use tokio::sync::watch;
 use tokio::time::{Duration, Instant};
 use uuid::Uuid;
 
-use crate::LIBSQL_PAGE_SIZE;
 use crate::libsql_bindings::ffi::SQLITE_IOERR_WRITE;
 use crate::libsql_bindings::ffi::{
     sqlite3,
@@ -27,6 +26,7 @@ use crate::libsql_bindings::wal_hook::WalHook;
 use crate::replication::frame::{Frame, FrameHeader};
 use crate::replication::snapshot::{find_snapshot_file, LogCompactor, SnapshotFile};
 use crate::replication::{FrameNo, SnapshotCallback, CRC_64_GO_ISO, WAL_MAGIC};
+use crate::LIBSQL_PAGE_SIZE;
 
 init_static_wal_method!(REPLICATION_METHODS, ReplicationLoggerHook);
 

sqld/src/replication/replica/hook.rs

@@ -6,9 +6,9 @@ use sqld_libsql_bindings::ffi::Wal;
 use sqld_libsql_bindings::init_static_wal_method;
 use sqld_libsql_bindings::{ffi::types::XWalFrameFn, wal_hook::WalHook};
 
-use crate::LIBSQL_PAGE_SIZE;
 use crate::replication::frame::{Frame, FrameBorrowed};
 use crate::replication::FrameNo;
+use crate::LIBSQL_PAGE_SIZE;
 
 use super::snapshot::TempSnapshot;