This commit is contained in:
Haojun Liao 2020-10-17 23:47:40 +08:00
parent d069a35683
commit 95adf3ea61
1 changed files with 3 additions and 3 deletions

View File

@ -6692,12 +6692,12 @@ static bool doBuildResCheck(SQInfo* pQInfo) {
pQInfo->dataReady = QUERY_RESULT_READY; pQInfo->dataReady = QUERY_RESULT_READY;
buildRes = (pQInfo->rspContext != NULL); buildRes = (pQInfo->rspContext != NULL);
pthread_mutex_unlock(&pQInfo->lock); // clear qhandle owner, it must be in the secure area. other thread may run ahead before current, after it is
// put into task to be executed.
// clear qhandle owner
assert(pQInfo->owner == taosGetPthreadId()); assert(pQInfo->owner == taosGetPthreadId());
pQInfo->owner = 0; pQInfo->owner = 0;
pthread_mutex_unlock(&pQInfo->lock);
return buildRes; return buildRes;
} }