fmt

Author: MarinPostma

libsql-wal/src/lib.rs

@@ -6,11 +6,11 @@ pub mod io;
 pub mod registry;
 pub mod replication;
 pub mod segment;
+mod segment_swap_strategy;
 pub mod shared_wal;
 pub mod storage;
 pub mod transaction;
 pub mod wal;
-mod segment_swap_strategy;
 
 const LIBSQL_MAGIC: u64 = u64::from_be_bytes(*b"LIBSQL\0\0");
 const LIBSQL_PAGE_SIZE: u16 = 4096;

libsql-wal/src/registry.rs

@@ -25,12 +25,12 @@ use crate::replication::storage::{ReplicateFromStorage as _, StorageReplicator};
 use crate::segment::list::SegmentList;
 use crate::segment::Segment;
 use crate::segment::{current::CurrentSegment, sealed::SealedSegment};
-use crate::shared_wal::{SharedWal, SwapLog};
-use crate::storage::{OnStoreCallback, Storage};
-use crate::transaction::TxGuard;
 use crate::segment_swap_strategy::duration::DurationSwapStrategy;
 use crate::segment_swap_strategy::frame_count::FrameCountSwapStrategy;
 use crate::segment_swap_strategy::SegmentSwapStrategy;
+use crate::shared_wal::{SharedWal, SwapLog};
+use crate::storage::{OnStoreCallback, Storage};
+use crate::transaction::TxGuard;
 use crate::{LibsqlFooter, LIBSQL_PAGE_SIZE};
 use libsql_sys::name::NamespaceName;
 

libsql-wal/src/segment_swap_strategy/duration.rs

@@ -12,7 +12,10 @@ pub struct DurationSwapStrategy {
 
 impl DurationSwapStrategy {
     pub fn new(swap_after: Duration) -> Self {
-        Self { swap_after, last_swapped_at: Mutex::new(Instant::now()) }
+        Self {
+            swap_after,
+            last_swapped_at: Mutex::new(Instant::now()),
+        }
     }
 }
 

libsql-wal/src/segment_swap_strategy/frame_count.rs

@@ -18,5 +18,5 @@ impl SegmentSwapStrategy for FrameCountSwapStrategy {
     }
 
     #[inline(always)]
-    fn swapped(&self) { }
+    fn swapped(&self) {}
 }

libsql-wal/src/shared_wal.rs

@@ -16,8 +16,8 @@ use crate::io::file::FileExt;
 use crate::io::Io;
 use crate::replication::storage::ReplicateFromStorage;
 use crate::segment::current::CurrentSegment;
-use crate::transaction::{ReadTransaction, Savepoint, Transaction, TxGuard, WriteTransaction};
 use crate::segment_swap_strategy::SegmentSwapStrategy;
+use crate::transaction::{ReadTransaction, Savepoint, Transaction, TxGuard, WriteTransaction};
 use libsql_sys::name::NamespaceName;
 
 #[derive(Default)]
@@ -274,9 +274,7 @@ impl<IO: Io> SharedWal<IO> {
             self.new_frame_notifier.send_replace(last_committed);
         }
 
-        if tx.is_commited()
-            && self.swap_strategy.should_swap(current.count_committed())
-        {
+        if tx.is_commited() && self.swap_strategy.should_swap(current.count_committed()) {
             self.swap_current(&tx)?;
             self.swap_strategy.swapped();
         }