enh: rename syncLogBuffer.h|c to syncPipeline.h|c

source/libs/sync/inc/syncLogBuffer.h → source/libs/sync/inc/syncPipeline.h

@@ -13,8 +13,8 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 
-#ifndef _TD_LIBS_SYNC_LOG_BUFFER_H
-#define _TD_LIBS_SYNC_LOG_BUFFER_H
+#ifndef _TD_LIBS_SYNC_PIPELINE_H
+#define _TD_LIBS_SYNC_PIPELINE_H
 
 #ifdef __cplusplus
 extern "C" {
@@ -58,7 +58,6 @@ typedef struct SSyncLogBuffer {
 } SSyncLogBuffer;
 
 // SSyncLogRepMgr
-
 SSyncLogReplMgr* syncLogReplMgrCreate();
 void             syncLogReplMgrDestroy(SSyncLogReplMgr* pMgr);
 int32_t          syncLogReplMgrReset(SSyncLogReplMgr* pMgr);
@@ -113,12 +112,8 @@ int32_t         syncLogBufferValidate(SSyncLogBuffer* pBuf);
 int32_t         syncLogBufferRollback(SSyncLogBuffer* pBuf, SyncIndex toIndex);
 int32_t syncLogBufferReplicate(SSyncLogBuffer* pBuf, SSyncNode* pNode, SSyncRaftEntry* pEntry, SyncTerm prevLogTerm);
 
-// others
-int64_t syncNodeUpdateCommitIndex(SSyncNode* ths, SyncIndex commtIndex);
-int32_t syncLogToAppendEntries(SSyncNode* pNode, SSyncRaftEntry* pEntry, SyncTerm prevLogTerm, SRpcMsg* pRpcMsg);
-
 #ifdef __cplusplus
 }
 #endif
 
-#endif /*_TD_LIBS_SYNC_LOG_BUFFER_H*/
+#endif /*_TD_LIBS_SYNC_PIPELINE_H*/

source/libs/sync/src/syncAppendEntries.c

@@ -15,12 +15,13 @@
 
 #define _DEFAULT_SOURCE
 #include "syncAppendEntries.h"
-#include "syncLogBuffer.h"
+#include "syncPipeline.h"
 #include "syncMessage.h"
 #include "syncRaftLog.h"
 #include "syncRaftStore.h"
 #include "syncReplication.h"
 #include "syncUtil.h"
+#include "syncCommit.h"
 
 // TLA+ Spec
 // HandleAppendEntriesRequest(i, j, m) ==

source/libs/sync/src/syncAppendEntriesReply.c

@@ -17,7 +17,7 @@
 #include "syncAppendEntriesReply.h"
 #include "syncCommit.h"
 #include "syncIndexMgr.h"
-#include "syncLogBuffer.h"
+#include "syncPipeline.h"
 #include "syncMessage.h"
 #include "syncRaftEntry.h"
 #include "syncRaftStore.h"

source/libs/sync/src/syncMain.c

@@ -22,7 +22,7 @@
 #include "syncEnv.h"
 #include "syncIndexMgr.h"
 #include "syncInt.h"
-#include "syncLogBuffer.h"
+#include "syncPipeline.h"
 #include "syncMessage.h"
 #include "syncRaftCfg.h"
 #include "syncRaftLog.h"

source/libs/sync/src/syncLogBuffer.c → source/libs/sync/src/syncPipeline.c

@@ -15,7 +15,7 @@
 
 #define _DEFAULT_SOURCE
 
-#include "syncLogBuffer.h"
+#include "syncPipeline.h"
 #include "syncIndexMgr.h"
 #include "syncInt.h"
 #include "syncRaftEntry.h"

source/libs/sync/src/syncReplication.c

@@ -16,7 +16,7 @@
 #define _DEFAULT_SOURCE
 #include "syncReplication.h"
 #include "syncIndexMgr.h"
-#include "syncLogBuffer.h"
+#include "syncPipeline.h"
 #include "syncRaftEntry.h"
 #include "syncRaftStore.h"
 #include "syncUtil.h"