test

Author: Baoyi Chen

src/test/java/com/moilioncircle/redis/replicator/online/PsyncTest.java

@@ -83,19 +83,22 @@ public void psync() throws IOException {
             @Override
             public void onEvent(Replicator replicator, Event event) {
                 if (event instanceof PreRdbSyncEvent) {
+                    r.getLogger().info("id:{}, offset:{}", configuration.getReplId(), configuration.getReplOffset());
                     acc1.incrementAndGet();
                 }
 
                 if (event instanceof KeyValuePair) {
                     if (flag1.compareAndSet(false, true)) {
                         // will trigger full sync at this time
+                        r.getLogger().info("psync close 1");
                         close(replicator);
                     }
                 }
 
                 if (event instanceof PostRdbSyncEvent) {
                     if (flag.compareAndSet(false, true)) {
                         // will trigger full sync at this time
+                        r.getLogger().info("psync close 2");
                         close(replicator);
                         Thread thread = new Thread(new JRun());
                         thread.setDaemon(true);
@@ -108,13 +111,15 @@ public void onEvent(Replicator replicator, Event event) {
                     if (acc.get() == 500) {
                         //close current process port;
                         //that will auto trigger psync command
+                        r.getLogger().info("psync close 3");
                         r.getLogger().info("id:{}, offset:{}", configuration.getReplId(), configuration.getReplOffset());
                         close(replicator);
                     }
 
                     if (acc.get() == 1010) {
                         //close current process port;
                         //that will auto trigger psync command
+                        r.getLogger().info("psync close 4");
                         r.getLogger().info("id:{}, offset:{}", configuration.getReplId(), configuration.getReplOffset());
                         close(replicator);
                     }