enh(sync) snapshot sender, receiver

source/libs/sync/inc/syncSnapshot.h

@@ -26,8 +26,29 @@ extern "C" {
 #include "syncInt.h"
 #include "taosdef.h"
 
-int32_t takeSnapshot(SSyncFSM *pFsm, SSnapshot *pSnapshot);
-int32_t restoreSnapshot(SSyncFSM *pFsm, SSnapshot *pSnapshot);
+typedef struct SSyncSnapshotSender {
+  bool       isStart;
+  int32_t    progressIndex;
+  void *     pCurrentBlock;
+  int32_t    len;
+  SSnapshot *pSnapshot;
+} SSyncSnapshotSender;
+
+int32_t snapshotSenderStart(SSyncSnapshotSender *pSender);
+int32_t snapshotSenderStop(SSyncSnapshotSender *pSender);
+int32_t snapshotSend(SSyncSnapshotSender *pSender);
+
+typedef struct SSyncSnapshotReceiver {
+  bool       isStart;
+  int32_t    progressIndex;
+  void *     pCurrentBlock;
+  int32_t    len;
+  SSnapshot *pSnapshot;
+} SSyncSnapshotReceiver;
+
+int32_t snapshotReceiverStart(SSyncSnapshotReceiver *pReceiver);
+int32_t snapshotReceiverStop(SSyncSnapshotReceiver *pReceiver);
+int32_t snapshotReceive(SSyncSnapshotReceiver *pReceiver);
 
 #ifdef __cplusplus
 }

source/libs/sync/src/syncSnapshot.c

@@ -15,6 +15,14 @@
 
 #include "syncSnapshot.h"
 
-int32_t takeSnapshot(SSyncFSM *pFsm, SSnapshot *pSnapshot) { return 0; }
+int32_t snapshotSenderStart(SSyncSnapshotSender *pSender) { return 0; }
 
-int32_t restoreSnapshot(SSyncFSM *pFsm, SSnapshot *pSnapshot) { return 0; }
+int32_t snapshotSenderStop(SSyncSnapshotSender *pSender) { return 0; }
\ No newline at end of file
+
+int32_t snapshotSend(SSyncSnapshotSender *pSender) { return 0; }
+
+int32_t snapshotReceiverStart(SSyncSnapshotReceiver *pReceiver) { return 0; }
+
+int32_t snapshotReceiverStop(SSyncSnapshotReceiver *pReceiver) { return 0; }
+
+int32_t snapshotReceive(SSyncSnapshotReceiver *pReceiver) { return 0; }