diff --git a/include/libs/sync/sync.h b/include/libs/sync/sync.h index ee3ea8db9bb4d827fafe669049a8400c03dbf279..dd2157655c2245acbe78a5723ebc7fa966992c09 100644 --- a/include/libs/sync/sync.h +++ b/include/libs/sync/sync.h @@ -13,8 +13,8 @@ * along with this program. If not, see . */ -#ifndef TDENGINE_RAFT_SYNC_H -#define TDENGINE_RAFT_SYNC_H +#ifndef _TD_LIBS_SYNC_H +#define _TD_LIBS_SYNC_H #ifdef __cplusplus extern "C" { @@ -25,41 +25,40 @@ extern "C" { #include "wal.h" typedef uint32_t SyncNodeId; -typedef int32_t SyncGroupId; -typedef int64_t SyncIndex; -typedef uint64_t SSyncTerm; +typedef int32_t SyncGroupId; +typedef int64_t SyncIndex; +typedef uint64_t SyncTerm; typedef enum { - TAOS_SYNC_ROLE_FOLLOWER = 0, + TAOS_SYNC_ROLE_FOLLOWER = 0, TAOS_SYNC_ROLE_CANDIDATE = 1, - TAOS_SYNC_ROLE_LEADER = 2, + TAOS_SYNC_ROLE_LEADER = 2, } ESyncRole; typedef struct { - void* data; + void* data; size_t len; } SSyncBuffer; typedef struct { - SyncNodeId nodeId; // node ID assigned by TDengine - uint16_t nodePort; // node sync Port - char nodeFqdn[TSDB_FQDN_LEN]; // node FQDN + SyncNodeId nodeId; // node ID assigned by TDengine + uint16_t nodePort; // node sync Port + char nodeFqdn[TSDB_FQDN_LEN]; // node FQDN } SNodeInfo; typedef struct { - int selfIndex; - int nNode; - SNodeInfo* nodeInfo; + int selfIndex; + int nNode; + SNodeInfo* nodeInfo; } SSyncCluster; typedef struct { - int32_t selfIndex; - int nNode; + int32_t selfIndex; + int nNode; SyncNodeId* nodeId; ESyncRole* role; } SNodesRole; -struct SSyncFSM; typedef struct SSyncFSM { void* pData; @@ -87,7 +86,7 @@ typedef struct SSyncFSM { typedef struct SSyncServerState { SyncNodeId voteFor; - SSyncTerm term; + SyncTerm term; } SSyncServerState; typedef struct SStateManager { @@ -103,12 +102,12 @@ typedef struct SStateManager { } SStateManager; typedef struct { - SyncGroupId vgId; + SyncGroupId vgId; twalh walHandle; - SyncIndex snapshotIndex; // initial version - SSyncCluster syncCfg; // configuration from mgmt + SyncIndex snapshotIndex; // initial version + SSyncCluster syncCfg; // configuration from mgmt SSyncFSM fsm; @@ -118,15 +117,15 @@ typedef struct { int32_t syncInit(); void syncCleanUp(); -SyncNodeId syncStart(const SSyncInfo *); -void syncStop(SyncNodeId); +SyncNodeId syncStart(const SSyncInfo*); +void syncStop(SyncNodeId); -int32_t syncPropose(SyncNodeId nodeId, SSyncBuffer buffer, void *pData, bool isWeak); +int32_t syncPropose(SyncNodeId nodeId, SSyncBuffer buffer, void* pData, bool isWeak); -extern int32_t raftDebugFlag; +extern int32_t syncDebugFlag; #ifdef __cplusplus } #endif -#endif // TDENGINE_RAFT_SYNC_H +#endif /*_TD_LIBS_SYNC_H*/