From 9ef4e451712874ebba15bc96e8ee6cd2b0603365 Mon Sep 17 00:00:00 2001
From: dmchen <cademfly@hotmail.com>
Date: Fri, 18 Oct 2024 07:51:52 +0000
Subject: [PATCH] fix/TS-5532-set-seperate-thrad-update-status-fix-case

---
 source/dnode/mgmt/mgmt_dnode/src/dmHandle.c | 8 ++++----
 source/dnode/mgmt/node_mgmt/src/dmMgmt.c    | 2 +-
 source/dnode/mgmt/node_util/inc/dmUtil.h    | 2 +-
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/source/dnode/mgmt/mgmt_dnode/src/dmHandle.c b/source/dnode/mgmt/mgmt_dnode/src/dmHandle.c
index 1f4a46e887..08fd632831 100644
--- a/source/dnode/mgmt/mgmt_dnode/src/dmHandle.c
+++ b/source/dnode/mgmt/mgmt_dnode/src/dmHandle.c
@@ -165,11 +165,11 @@ void dmSendStatusReq(SDnodeMgmt *pMgmt) {
   (void)taosThreadRwlockUnlock(&pMgmt->pData->lock);
 
   dDebug("send status req to mnode, statusSeq:%d, begin to get vnode loads", pMgmt->statusSeq);
-  (void)taosThreadRwlockRdlock(&pMgmt->pData->statusInfolock);
+  (void)taosThreadMutexLock(&pMgmt->pData->statusInfolock);
   req.pVloads = taosArrayDup(tsVinfo.pVloads, NULL);
   taosArrayDestroy(tsVinfo.pVloads);
   tsVinfo.pVloads = NULL;
-  (void)taosThreadRwlockUnlock(&pMgmt->pData->statusInfolock);
+  (void)taosThreadMutexUnlock(&pMgmt->pData->statusInfolock);
 
   dDebug("send status req to mnode, statusSeq:%d, begin to get mnode loads", pMgmt->statusSeq);
   SMonMloadInfo minfo = {0};
@@ -239,10 +239,10 @@ void dmUpdateStatusInfo(SDnodeMgmt *pMgmt) {
   SMonVloadInfo vinfo = {0};
   dDebug("begin to get vnode loads");
   (*pMgmt->getVnodeLoadsFp)(&vinfo);
-  (void)taosThreadRwlockWrlock(&pMgmt->pData->statusInfolock);
+  (void)taosThreadMutexLock(&pMgmt->pData->statusInfolock);
   if (tsVinfo.pVloads == NULL) tsVinfo.pVloads = taosArrayDup(vinfo.pVloads, NULL);
   taosArrayDestroy(vinfo.pVloads);
-  (void)taosThreadRwlockWrlock(&pMgmt->pData->statusInfolock);
+  (void)taosThreadMutexUnlock(&pMgmt->pData->statusInfolock);
 }
 
 void dmSendNotifyReq(SDnodeMgmt *pMgmt, SNotifyReq *pReq) {
diff --git a/source/dnode/mgmt/node_mgmt/src/dmMgmt.c b/source/dnode/mgmt/node_mgmt/src/dmMgmt.c
index 4fc618379c..5e4f7163e7 100644
--- a/source/dnode/mgmt/node_mgmt/src/dmMgmt.c
+++ b/source/dnode/mgmt/node_mgmt/src/dmMgmt.c
@@ -214,7 +214,7 @@ int32_t dmInitVars(SDnode *pDnode) {
   }
 
   (void)taosThreadRwlockInit(&pData->lock, NULL);
-  (void)taosThreadRwlockInit(&pData->statusInfolock, NULL);
+  (void)taosThreadMutexInit(&pData->statusInfolock, NULL);
   (void)taosThreadMutexInit(&pDnode->mutex, NULL);
   return 0;
 }
diff --git a/source/dnode/mgmt/node_util/inc/dmUtil.h b/source/dnode/mgmt/node_util/inc/dmUtil.h
index 2374c45c2d..de20f807e9 100644
--- a/source/dnode/mgmt/node_util/inc/dmUtil.h
+++ b/source/dnode/mgmt/node_util/inc/dmUtil.h
@@ -144,7 +144,7 @@ typedef struct {
   char           machineId[TSDB_MACHINE_ID_LEN + 1];
   EEncryptAlgor  encryptAlgorigthm;
   EEncryptScope  encryptScope;
-  TdThreadRwlock statusInfolock;
+  TdThreadMutex  statusInfolock;
 } SDnodeData;
 
 typedef struct {