This commit is contained in:
Shengliang Guan 2020-11-12 06:19:44 +00:00
parent 9d65e0e505
commit f6ee376fb6
1 changed files with 1 additions and 1 deletions

View File

@ -125,7 +125,7 @@ static void *tsdbLoopCommit(void *arg) {
while (true) { while (true) {
pNode = tdListPopHead(pQueue->queue); pNode = tdListPopHead(pQueue->queue);
if (pNode == NULL) { if (pNode == NULL) {
if (pQueue->stop && pQueue->refCount == 0) { if (pQueue->stop && pQueue->refCount <= 0) {
pthread_mutex_unlock(&(pQueue->lock)); pthread_mutex_unlock(&(pQueue->lock));
goto _exit; goto _exit;
} else { } else {