From bd00a4f217be0549f441f84d1204f25112305e5b Mon Sep 17 00:00:00 2001 From: kailixu Date: Thu, 11 May 2023 11:32:39 +0800 Subject: [PATCH] chore:more code --- include/common/tmsg.h | 1 + source/dnode/mnode/impl/src/mndDnode.c | 5 +++++ 2 files changed, 6 insertions(+) diff --git a/include/common/tmsg.h b/include/common/tmsg.h index 82f43a6179..4b428334fd 100644 --- a/include/common/tmsg.h +++ b/include/common/tmsg.h @@ -1234,6 +1234,7 @@ typedef struct { typedef struct { int32_t id; + int8_t isMnode; SEp ep; char active[TSDB_ACTIVE_KEY_LEN]; char connActive[TSDB_CONN_ACTIVE_KEY_LEN]; diff --git a/source/dnode/mnode/impl/src/mndDnode.c b/source/dnode/mnode/impl/src/mndDnode.c index 748eeb5a06..a02f107736 100644 --- a/source/dnode/mnode/impl/src/mndDnode.c +++ b/source/dnode/mnode/impl/src/mndDnode.c @@ -356,6 +356,11 @@ void mndGetDnodeData(SMnode *pMnode, SArray *pDnodeInfo) { tstrncpy(dInfo.active, pDnode->active, TSDB_ACTIVE_KEY_LEN); tstrncpy(dInfo.connActive, pDnode->connActive, TSDB_CONN_ACTIVE_KEY_LEN); sdbRelease(pSdb, pDnode); + if (mndIsMnode(pMnode, pDnode->id)) { + dInfo.isMnode = 1; + } else { + dInfo.isMnode = 0; + } taosArrayPush(pDnodeInfo, &dInfo); }