test

leonchen83 · Dec 9, 2023 · 3b9e9a8 · 3b9e9a8
1 parent 0878076
commit 3b9e9a8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/test/java/com/moilioncircle/redis/replicator/online/PsyncTest.java b/src/test/java/com/moilioncircle/redis/replicator/online/PsyncTest.java
@@ -95,6 +95,8 @@ public void onEvent(Replicator replicator, Event event) {
 
                 if (event instanceof PostRdbSyncEvent) {
                     if (flag.compareAndSet(false, true)) {
+                        // will trigger full sync at this time
+                        close(replicator);
                         Thread thread = new Thread(new JRun());
                         thread.setDaemon(true);
                         thread.start();
@@ -129,7 +131,7 @@ public void onEvent(Replicator replicator, Event event) {
             }
         });
         r.open();
-        assertEquals(2, acc1.get());
+        assertEquals(3, acc1.get());
         assertEquals(1500, acc.get());
     }