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

change check out seq

This commit is contained in:
yihaoDeng 2023-11-08 20:29:37 +08:00
parent 08e3448498
commit 0f98f4daa5
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/dnode/mnode/impl/src/mndStream.c
View File

@ -1219,14 +1219,11 @@ static int32_t mndProcessStreamDoCheckpoint(SRpcMsg *pReq) {
if ((code = mndCheckNodeStatus(pMnode)) != 0) { if ((code = mndCheckNodeStatus(pMnode)) != 0) {
return code; return code;
} }
SMStreamDoCheckpointMsg *pMsg = (SMStreamDoCheckpointMsg *)pReq->pCont; SMStreamDoCheckpointMsg *pMsg = (SMStreamDoCheckpointMsg *)pReq->pCont;
int64_t checkpointId = pMsg->checkpointId;
while (1) { while (1) {
pIter = sdbFetch(pSdb, SDB_STREAM, pIter, (void **)&pStream); pIter = sdbFetch(pSdb, SDB_STREAM, pIter, (void **)&pStream);
if (pIter == NULL) break; if (pIter == NULL) break;
code = mndProcessStreamCheckpointTrans(pMnode, pStream, pStream->checkpointId + 1);
code = mndProcessStreamCheckpointTrans(pMnode, pStream, checkpointId);
sdbRelease(pSdb, pStream); sdbRelease(pSdb, pStream);
if (code == -1) { if (code == -1) {
break; break;