From d2ae4a6e2666be1a41b53cc25bc7255fa7aaa69d Mon Sep 17 00:00:00 2001
From: Minglei Jin <mljin@taosdata.com>
Date: Tue, 5 Mar 2024 09:52:26 +0800
Subject: [PATCH] enh(s3/writing): enable writing to s3 always

---
 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 4036200d73..8121c8fdd7 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
+int32_t vnodeNodeId(SVnode* pVnode);
 int32_t vnodeSyncOpen(SVnode* pVnode, char* path, int32_t vnodeVersion);
 int32_t vnodeSyncStart(SVnode* pVnode);
 void    vnodeSyncPreClose(SVnode* pVnode);
diff --git a/source/dnode/vnode/src/vnd/vnodeSync.c b/source/dnode/vnode/src/vnd/vnodeSync.c
index f9f2ae6b21..ef2dfcee85 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;
 }
 
+int32_t vnodeNodeId(SVnode *pVnode) {
+  SSyncCfg *syncCfg = &pVnode->config.syncCfg;
+  return syncCfg->nodeInfo[syncCfg->myIndex].nodeId;
+}
+
 int32_t vnodeGetSnapshot(SVnode *pVnode, SSnapshot *pSnap) {
   int code = 0;
   pSnap->lastApplyIndex = pVnode->state.committed;