From b763ed1e49d30a4ccc982353115258387f301459 Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Tue, 21 Jan 2025 11:43:28 +0800 Subject: [PATCH] fix:[TD-33556] tmq close elegantly to avoid invalid read in TD-32585 --- source/client/src/clientTmq.c | 11 +---------- 1 file changed, 1 insertion(+), 10 deletions(-) diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c index 4662c31fb1..a2c8bfa351 100644 --- a/source/client/src/clientTmq.c +++ b/source/client/src/clientTmq.c @@ -1612,16 +1612,7 @@ static void tmqMgmtInit(void) { goto END; } - TdThreadMutexAttr attr = {0}; - if (taosThreadMutexAttrInit(&attr) != 0){ - goto END; - } - - if (taosThreadMutexInit(&tmqMgmt.lock, &attr) != 0){ - goto END; - } - - if (taosThreadMutexAttrDestroy(&attr) != 0){ + if (taosThreadMutexInit(&tmqMgmt.lock, NULL) != 0){ goto END; }