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

ehn/add-sync-heartbeat-sent-time-to-log

This commit is contained in:
dmchen 2024-11-20 08:57:27 +08:00
parent fde7a7aeaf
commit 828f01f5ae
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/libs/sync/src/syncReplication.c
View File

@ -92,10 +92,11 @@ int32_t syncNodeSendAppendEntries(SSyncNode* pSyncNode, const SRaftId* destRaftI
} }
int32_t syncNodeSendHeartbeat(SSyncNode* pSyncNode, const SRaftId* destId, SRpcMsg* pMsg) { int32_t syncNodeSendHeartbeat(SSyncNode* pSyncNode, const SRaftId* destId, SRpcMsg* pMsg) {
SRaftId destIdTmp = *destId;
TAOS_CHECK_RETURN(syncNodeSendMsgById(destId, pSyncNode, pMsg)); TAOS_CHECK_RETURN(syncNodeSendMsgById(destId, pSyncNode, pMsg));
int64_t tsMs = taosGetTimestampMs(); int64_t tsMs = taosGetTimestampMs();
syncIndexMgrSetSentTime(pSyncNode->pMatchIndex, destId, tsMs); syncIndexMgrSetSentTime(pSyncNode->pMatchIndex, &destIdTmp, tsMs);
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }