diff --git a/source/libs/sync/inc/syncSnapshot.h b/source/libs/sync/inc/syncSnapshot.h index fd2119ce659b553124aa9a310c3790b29363628c..104da4861646b8b8287b854eeab0f2264f36c2bb 100644 --- a/source/libs/sync/inc/syncSnapshot.h +++ b/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 } diff --git a/source/libs/sync/src/syncSnapshot.c b/source/libs/sync/src/syncSnapshot.c index 42b2bd993b515789934268f4400fece4f040f7c5..5419adee2cd33fabe02bf275ec6e5dd0248956b9 100644 --- a/source/libs/sync/src/syncSnapshot.c +++ b/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; } \ No newline at end of file +int32_t snapshotSenderStop(SSyncSnapshotSender *pSender) { return 0; } + +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; }