From 434aefb8803811142eb8779be597a25dda2a5386 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 10 Dec 2020 10:44:04 +0800 Subject: [PATCH] [TD-225] fix compiler error. --- src/util/src/tworker.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/util/src/tworker.c b/src/util/src/tworker.c index a45e73d4c6..8b4053bccd 100644 --- a/src/util/src/tworker.c +++ b/src/util/src/tworker.c @@ -36,14 +36,14 @@ int32_t tWorkerInit(SWorkerPool *pPool) { void tWorkerCleanup(SWorkerPool *pPool) { for (int i = 0; i < pPool->max; ++i) { SWorker *pWorker = pPool->worker + i; - if (pWorker->thread != 0) { + if(taosCheckPthreadValid(pWorker->thread)) { taosQsetThreadResume(pPool->qset); } } for (int i = 0; i < pPool->max; ++i) { SWorker *pWorker = pPool->worker + i; - if (pWorker->thread != 0) { + if (taosCheckPthreadValid(pWorker->thread)) { pthread_join(pWorker->thread, NULL); } } -- GitLab