提交 7e84d868 编写于 作者: H Haojun Liao

[TD-225] fix compiler error.

上级 e51f8e5f
...@@ -36,14 +36,14 @@ int32_t tWorkerInit(SWorkerPool *pPool) { ...@@ -36,14 +36,14 @@ int32_t tWorkerInit(SWorkerPool *pPool) {
void tWorkerCleanup(SWorkerPool *pPool) { void tWorkerCleanup(SWorkerPool *pPool) {
for (int i = 0; i < pPool->max; ++i) { for (int i = 0; i < pPool->max; ++i) {
SWorker *pWorker = pPool->worker + i; SWorker *pWorker = pPool->worker + i;
if (pWorker->thread) { if (pWorker->thread != 0) {
taosQsetThreadResume(pPool->qset); taosQsetThreadResume(pPool->qset);
} }
} }
for (int i = 0; i < pPool->max; ++i) { for (int i = 0; i < pPool->max; ++i) {
SWorker *pWorker = pPool->worker + i; SWorker *pWorker = pPool->worker + i;
if (pWorker->thread) { if (pWorker->thread != 0) {
pthread_join(pWorker->thread, NULL); pthread_join(pWorker->thread, NULL);
} }
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册