fix frames_synced

Author: LucioFranco

libsql-server/tests/embedded_replica/mod.rs

@@ -759,7 +759,7 @@ fn replicate_with_snapshots() {
         assert_eq!(stat, 427);
 
         let rep = db.sync().await.unwrap();
-        assert_eq!(rep.frames_synced(), 427);
+        assert_eq!(rep.frames_synced(), 0);
 
         let conn = db.connect().unwrap();
 
@@ -1336,7 +1336,7 @@ fn replicated_return() {
 
         let rep = db.sync().await.unwrap();
         assert_eq!(rep.frame_no(), Some(10));
-        assert_eq!(rep.frames_synced(), 11);
+        assert_eq!(rep.frames_synced(), 9);
 
         // Regenerate log
         notify.notify_waiters();
@@ -1346,7 +1346,7 @@ fn replicated_return() {
 
         let rep = db.sync().await.unwrap();
         assert_eq!(rep.frame_no(), Some(4));
-        assert_eq!(rep.frames_synced(), 16);
+        assert_eq!(rep.frames_synced(), 3);
 
         let mut row = conn.query("select count(*) from user", ()).await.unwrap();
         let count = row.next().await.unwrap().unwrap().get::<u64>(0).unwrap();

libsql/src/replication/mod.rs

@@ -255,13 +255,17 @@ impl EmbeddedReplicator {
             }
         }
 
-        let last_frames_synced = self
-            .last_frames_synced
-            .fetch_add(1, std::sync::atomic::Ordering::Relaxed);
+        let last_frames_synced = self.last_frames_synced.fetch_add(
+            replicator.frames_synced(),
+            std::sync::atomic::Ordering::Relaxed,
+        );
+
+        let frames_synced =
+            ((replicator.frames_synced() as i64 - last_frames_synced as i64).abs()) as usize;
 
         let replicated = Replicated {
             frame_no: replicator.client_mut().committed_frame_no(),
-            frames_synced: replicator.frames_synced() - last_frames_synced,
+            frames_synced,
         };
 
         Ok(replicated)