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

fix invalid vgroup id

This commit is contained in:
yihaoDeng 2023-01-04 10:48:38 +08:00
parent 17b5df0018
commit 5b7b8a97b4
1 changed files with 2 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
source/libs/catalog/src/ctgAsync.c
View File

@ -908,26 +908,9 @@ int32_t ctgCallUserCb(void* param) {
void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) { void ctgUpdateJobErrCode(SCtgJob* pJob, int32_t errCode) {
if (!NEED_CLIENT_REFRESH_VG_ERROR(errCode) || errCode == TSDB_CODE_SUCCESS) return; if (!NEED_CLIENT_REFRESH_VG_ERROR(errCode) || errCode == TSDB_CODE_SUCCESS) return;
int32_t origCode = atomic_load_32(&pJob->jobResCode); atomic_store_32(&pJob->jobResCode, errCode);
if (TSDB_CODE_SUCCESS == origCode) {
if (origCode == atomic_val_compare_exchange_32(&pJob->jobResCode, origCode, errCode)) {
goto _return;
}
origCode = atomic_load_32(&pJob->jobResCode);
}
if (NEED_CLIENT_REFRESH_VG_ERROR(origCode)) {
return;
}
if (NEED_CLIENT_REFRESH_VG_ERROR(errCode)) {
atomic_store_32(&pJob->jobResCode, errCode);
goto _return;
}
return;
_return:
qDebug("QID:0x%" PRIx64 " ctg job errCode updated to %s", pJob->queryId, tstrerror(errCode)); qDebug("QID:0x%" PRIx64 " ctg job errCode updated to %s", pJob->queryId, tstrerror(errCode));
return;
} }
int32_t ctgHandleTaskEnd(SCtgTask* pTask, int32_t rspCode) { int32_t ctgHandleTaskEnd(SCtgTask* pTask, int32_t rspCode) {