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

fix invalid read

This commit is contained in:
Yihao Deng 2024-04-28 06:50:33 +00:00
parent af567ea2cb
commit fac8530580
1 changed files with 2 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
source/libs/stream/src/streamCheckpoint.c
View File

@ -24,7 +24,6 @@ typedef struct {
int64_t chkpId; int64_t chkpId;
SStreamTask* pTask; SStreamTask* pTask;
char* taskStr;
} SAsyncUploadArg; } SAsyncUploadArg;
int32_t tEncodeStreamCheckpointSourceReq(SEncoder* pEncoder, const SStreamCheckpointSourceReq* pReq) { int32_t tEncodeStreamCheckpointSourceReq(SEncoder* pEncoder, const SStreamCheckpointSourceReq* pReq) {
@ -422,7 +421,7 @@ int32_t uploadCheckpointData(void* param) {
char* path = NULL; char* path = NULL;
int32_t code = 0; int32_t code = 0;
SArray* toDelFiles = taosArrayInit(4, sizeof(void*)); SArray* toDelFiles = taosArrayInit(4, sizeof(void*));
char* taskStr = arg->taskStr != NULL ? arg->taskStr : "NULL"; char* taskStr = arg->taskId ? arg->taskId : "NULL";
if ((code = taskDbGenChkpUploadData(arg->pTask->pBackend, arg->pTask->pMeta->bkdChkptMgt, arg->chkpId, if ((code = taskDbGenChkpUploadData(arg->pTask->pBackend, arg->pTask->pMeta->bkdChkptMgt, arg->chkpId,
(int8_t)(arg->type), &path, toDelFiles)) != 0) { (int8_t)(arg->type), &path, toDelFiles)) != 0) {
@ -442,7 +441,7 @@ int32_t uploadCheckpointData(void* param) {
for (int i = 0; i < taosArrayGetSize(toDelFiles); i++) { for (int i = 0; i < taosArrayGetSize(toDelFiles); i++) {
char* p = taosArrayGetP(toDelFiles, i); char* p = taosArrayGetP(toDelFiles, i);
code = deleteCheckpointFile(arg->taskId, p); code = deleteCheckpointFile(arg->taskId, p);
stDebug("s-task:%s try to del file: %s", arg->taskStr != NULL ? arg->taskStr : "NULL", p); stDebug("s-task:%s try to del file: %s", taskStr, p);
if (code != 0) { if (code != 0) {
break; break;
} }
@ -475,12 +474,6 @@ int32_t streamTaskUploadChkp(SStreamTask* pTask, int64_t chkpId, char* taskId) {
arg->taskId = taosStrdup(taskId); arg->taskId = taosStrdup(taskId);
arg->chkpId = chkpId; arg->chkpId = chkpId;
arg->pTask = pTask; arg->pTask = pTask;
if (arg->pTask->id.idStr != NULL) {
arg->taskStr = taosStrdup(arg->pTask->id.idStr);
return 0;
} else {
arg->taskStr = NULL;
}
return streamMetaAsyncExec(pTask->pMeta, uploadCheckpointData, arg, NULL); return streamMetaAsyncExec(pTask->pMeta, uploadCheckpointData, arg, NULL);
} }