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

fix(stream): check null ptr.

This commit is contained in:
Haojun Liao 2025-01-21 11:21:53 +08:00
parent 08092aeb0c
commit df6ec3afc2
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/dnode/mnode/impl/src/mndStreamUtil.c
View File

@ -709,14 +709,14 @@ static int32_t allTasksSendChkptReport(SChkptReportInfo* pReportInfo, int32_t nu
} else { } else {
// do nothing // do nothing
} }
} } else {
if (pTransInfo->transId != transId) { if (pTransInfo->transId != transId) {
mError("stream:0x%" PRIx64 mError("stream:0x%" PRIx64
" checkpoint-report list info are expired, active transId:%d trans in list:%d, recheck next time", " checkpoint-report list info are expired, active transId:%d trans in list:%d, recheck next time",
id.streamId, pTransInfo->transId, transId); id.streamId, pTransInfo->transId, transId);
return -1; return -1;
} }
}
mDebug("stream:0x%" PRIx64 " %s all %d tasks send checkpoint-report, start to update checkpoint-info", id.streamId, mDebug("stream:0x%" PRIx64 " %s all %d tasks send checkpoint-report, start to update checkpoint-info", id.streamId,
pName, numOfTasks); pName, numOfTasks);