From d9e17c2284f7bce36007cae10394d3687e98b135 Mon Sep 17 00:00:00 2001 From: dmchen Date: Mon, 23 Sep 2024 06:25:25 +0000 Subject: [PATCH] fix/TD-32264-check-return-value --- source/util/src/tworker.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/source/util/src/tworker.c b/source/util/src/tworker.c index c2757dcabc..d3a18ddb16 100644 --- a/source/util/src/tworker.c +++ b/source/util/src/tworker.c @@ -414,7 +414,8 @@ STaosQueue *tWWorkerAllocQueue(SWWorkerPool *pool, void *ahandle, FItems fp) { TdThreadAttr thAttr; (void)taosThreadAttrInit(&thAttr); (void)taosThreadAttrSetDetachState(&thAttr, PTHREAD_CREATE_JOINABLE); - if (taosThreadCreate(&worker->thread, &thAttr, (ThreadFp)tWWorkerThreadFp, worker) != 0) goto _OVER; + code = taosThreadCreate(&worker->thread, &thAttr, (ThreadFp)tWWorkerThreadFp, worker); + if ((code)) goto _OVER; uInfo("worker:%s:%d is launched, max:%d", pool->name, worker->id, pool->max); pool->nextId = (pool->nextId + 1) % pool->max;