Merge pull request #17346 from taosdata/feature/TD-14761
fix:sml core dump if insert quickly because of spin lock destroy
This commit is contained in:
commit
81e72ea84c
|
@ -2477,11 +2477,12 @@ static void smlInsertCallback(void *param, void *res, int32_t code) {
|
||||||
} else {
|
} else {
|
||||||
pParam->request->body.resInfo.numOfRows += info->affectedRows;
|
pParam->request->body.resInfo.numOfRows += info->affectedRows;
|
||||||
}
|
}
|
||||||
|
// unlock
|
||||||
|
taosThreadSpinUnlock(&pParam->lock);
|
||||||
|
|
||||||
if (pParam->cnt == pParam->total) {
|
if (pParam->cnt == pParam->total) {
|
||||||
tsem_post(&pParam->sem);
|
tsem_post(&pParam->sem);
|
||||||
}
|
}
|
||||||
taosThreadSpinUnlock(&pParam->lock);
|
|
||||||
// unlock
|
|
||||||
uDebug("SML:0x%" PRIx64 " insert finished, code: %d, rows: %d, total: %d", info->id, code, rows, info->affectedRows);
|
uDebug("SML:0x%" PRIx64 " insert finished, code: %d, rows: %d, total: %d", info->id, code, rows, info->affectedRows);
|
||||||
info->cost.endTime = taosGetTimestampUs();
|
info->cost.endTime = taosGetTimestampUs();
|
||||||
info->cost.code = code;
|
info->cost.code = code;
|
||||||
|
|
Loading…
Reference in New Issue