From 60ef86da6d61d411d9cdb182dc7561308cc834c5 Mon Sep 17 00:00:00 2001
From: Minglei Jin <mljin@taosdata.com>
Date: Wed, 6 Mar 2024 14:35:44 +0800
Subject: [PATCH] vnd/clusterId: new interface to get cluster id for vnode

---
 source/dnode/vnode/src/inc/vnd.h       | 1 +
 source/dnode/vnode/src/vnd/vnodeSync.c | 5 +++++
 2 files changed, 6 insertions(+)

diff --git a/source/dnode/vnode/src/inc/vnd.h b/source/dnode/vnode/src/inc/vnd.h
index 8121c8fdd7..f9f4b603fd 100644
--- a/source/dnode/vnode/src/inc/vnd.h
+++ b/source/dnode/vnode/src/inc/vnd.h
@@ -133,6 +133,7 @@ int32_t vnodeAsyncCommit(SVnode* pVnode);
 bool    vnodeShouldRollback(SVnode* pVnode);
 
 // vnodeSync.c
+int64_t vnodeClusterId(SVnode* pVnode);
 int32_t vnodeNodeId(SVnode* pVnode);
 int32_t vnodeSyncOpen(SVnode* pVnode, char* path, int32_t vnodeVersion);
 int32_t vnodeSyncStart(SVnode* pVnode);
diff --git a/source/dnode/vnode/src/vnd/vnodeSync.c b/source/dnode/vnode/src/vnd/vnodeSync.c
index ef2dfcee85..35b63c5792 100644
--- a/source/dnode/vnode/src/vnd/vnodeSync.c
+++ b/source/dnode/vnode/src/vnd/vnodeSync.c
@@ -811,6 +811,11 @@ bool vnodeIsLeader(SVnode *pVnode) {
   return true;
 }
 
+int64_t vnodeClusterId(SVnode *pVnode) {
+  SSyncCfg *syncCfg = &pVnode->config.syncCfg;
+  return syncCfg->nodeInfo[syncCfg->myIndex].clusterId;
+}
+
 int32_t vnodeNodeId(SVnode *pVnode) {
   SSyncCfg *syncCfg = &pVnode->config.syncCfg;
   return syncCfg->nodeInfo[syncCfg->myIndex].nodeId;