From b8a5bcfbf9dfa7fd0b2af195d86f4bf5484b4057 Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Thu, 23 Jan 2025 14:55:24 +0800 Subject: [PATCH] fix:[TD-33600] windows error if taos exist without connection --- source/client/src/clientTmq.c | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c index e708eee70e..fcd88ed8d7 100644 --- a/source/client/src/clientTmq.c +++ b/source/client/src/clientTmq.c @@ -1601,6 +1601,11 @@ void tmqFreeImpl(void* handle) { static void tmqMgmtInit(void) { tmqInitRes = 0; + + if (taosThreadMutexInit(&tmqMgmt.lock, NULL) != 0){ + goto END; + } + tmqMgmt.timer = taosTmrInit(1000, 100, 360000, "TMQ"); if (tmqMgmt.timer == NULL) { @@ -1612,10 +1617,6 @@ static void tmqMgmtInit(void) { goto END; } - if (taosThreadMutexInit(&tmqMgmt.lock, NULL) != 0){ - goto END; - } - return; END: tmqInitRes = terrno;