xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

[TD-10645][raft]<feature>replace SRpcEpSet to SEpSet

This commit is contained in:
lichuang 2021-11-04 09:53:52 +08:00
parent aba51499d0
commit 446b14f315
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/libs/sync/src/sync.c
View File

@ -23,8 +23,8 @@ SSyncManager* gSyncManager = NULL;
#define SYNC_ACTIVITY_TIMER 5
#define SYNC_SERVER_WORKER 2
static void syncProcessRsp(SRpcMsg *pMsg, SRpcEpSet *pEpSet);
static void syncProcessReqMsg(SRpcMsg *pMsg, SRpcEpSet *pEpSet);
static void syncProcessRsp(SRpcMsg *pMsg, SEpSet *pEpSet);
static void syncProcessReqMsg(SRpcMsg *pMsg, SEpSet *pEpSet);
static int syncInitRpcServer(SSyncManager* syncManager, const SSyncCluster* pSyncCfg);
static int syncInitRpcClient(SSyncManager* syncManager);
@ -168,12 +168,12 @@ int32_t syncPropose(SSyncNode* syncNode, const SSyncBuffer* pBuf, void* pData, b
void syncReconfig(const SSyncNode* pNode, const SSyncCluster* pCfg) {}
// process rpc rsp message from other sync server
static void syncProcessRsp(SRpcMsg *pMsg, SRpcEpSet *pEpSet) {
static void syncProcessRsp(SRpcMsg *pMsg, SEpSet *pEpSet) {
}
// process rpc message from other sync server
static void syncProcessReqMsg(SRpcMsg *pMsg, SRpcEpSet *pEpSet) {
static void syncProcessReqMsg(SRpcMsg *pMsg, SEpSet *pEpSet) {
}