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

fix: void function call issue

This commit is contained in:
dapan1121 2024-09-12 15:48:07 +08:00
parent a7269e4536
commit 007b64a3c1
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/libs/executor/src/groupcacheoperator.c
View File

@ -1061,7 +1061,7 @@ static int32_t getCacheBlkFromDownstreamOperator(struct SOperatorInfo* pOperator
pWaitCtx->newFetch = true; pWaitCtx->newFetch = true;
code = taosHashRemove(pCtx->pWaitSessions, pSessionId, sizeof(*pSessionId)); code = taosHashRemove(pCtx->pWaitSessions, pSessionId, sizeof(*pSessionId));
if (code) { if (code) {
qError("taosHashRemove session %" PRId64 " from waitSession failed, error: %s", pSessionId, tstrerror(code)); qError("taosHashRemove session %" PRId64 " from waitSession failed, error: %s", *pSessionId, tstrerror(code));
return code; return code;
} }
QRY_ERR_RET(tsem_post(&pWaitCtx->waitSem)); QRY_ERR_RET(tsem_post(&pWaitCtx->waitSem));

2
source/libs/scheduler/src/schJob.c
View File

@ -529,7 +529,7 @@ void schPostJobRes(SSchJob *pJob, SCH_OP_TYPE op) {
SCH_UNLOCK(SCH_WRITE, &pJob->opStatus.lock); SCH_UNLOCK(SCH_WRITE, &pJob->opStatus.lock);
code = tsem_post(&pJob->rspSem); code = tsem_post(&pJob->rspSem);
if (code) { if (code) {
ctgError("tsem_post failed for syncOp, error:%s", tstrerror(code)); SCH_JOB_ELOG("tsem_post failed for syncOp, error:%s", tstrerror(code));
} }
} else if (SCH_JOB_IN_ASYNC_EXEC_OP(pJob)) { } else if (SCH_JOB_IN_ASYNC_EXEC_OP(pJob)) {
SCH_UNLOCK(SCH_WRITE, &pJob->opStatus.lock); SCH_UNLOCK(SCH_WRITE, &pJob->opStatus.lock);

2
source/libs/scheduler/src/schTask.c
View File

@ -1355,7 +1355,7 @@ void schDropTaskInHashList(SSchJob *pJob, SHashObj *list) {
SCH_LOCK_TASK(pTask); SCH_LOCK_TASK(pTask);
if (pTask->delayTimer) { if (pTask->delayTimer) {
if (!taosTmrStopA(&pTask->delayTimer)) { if (!taosTmrStopA(&pTask->delayTimer)) {
SCH_TASK_WLOG("stop delayTimer failed, status:%d", pTask->delayTimer); SCH_TASK_WLOG("stop delayTimer failed, status:%d", pTask->status);
} }
} }
schDropTaskOnExecNode(pJob, pTask); schDropTaskOnExecNode(pJob, pTask);