From 98fc272ac823b4fbc40e8679739e7295494f38a7 Mon Sep 17 00:00:00 2001
From: Hongze Cheng <hzcheng@taosdata.com>
Date: Sun, 24 Apr 2022 09:14:37 +0000
Subject: [PATCH] more refact

---
 source/dnode/vnode/src/vnd/vnodeCommit.c | 6 +++++-
 source/dnode/vnode/src/vnd/vnodeSvr.c    | 1 +
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/source/dnode/vnode/src/vnd/vnodeCommit.c b/source/dnode/vnode/src/vnd/vnodeCommit.c
index 9b2909aa09..2404bf5e8a 100644
--- a/source/dnode/vnode/src/vnd/vnodeCommit.c
+++ b/source/dnode/vnode/src/vnd/vnodeCommit.c
@@ -193,12 +193,14 @@ int vnodeCommit(SVnode *pVnode) {
   SVnodeInfo info;
   char       dir[TSDB_FILENAME_LEN];
 
+  vInfo("vgId:%d start to commit, version: %" PRId64, TD_VID(pVnode), pVnode->state.applied);
+
   pVnode->onCommit = pVnode->inUse;
   pVnode->inUse = NULL;
 
   // save info
   info.config = pVnode->config;
-  info.state.committed = pVnode->state.processed;
+  info.state.committed = pVnode->state.applied;
   snprintf(dir, TSDB_FILENAME_LEN, "%s%s%s", tfsGetPrimaryPath(pVnode->pTfs), TD_DIRSEP, pVnode->path);
   if (vnodeSaveInfo(dir, &info) < 0) {
     ASSERT(0);
@@ -232,6 +234,8 @@ int vnodeCommit(SVnode *pVnode) {
   pVnode->pPool = pVnode->onCommit;
   pVnode->onCommit = NULL;
 
+  vInfo("vgId:%d commit over", TD_VID(pVnode));
+
   return 0;
 }
 
diff --git a/source/dnode/vnode/src/vnd/vnodeSvr.c b/source/dnode/vnode/src/vnd/vnodeSvr.c
index 82775f9e70..b07a222a6d 100644
--- a/source/dnode/vnode/src/vnd/vnodeSvr.c
+++ b/source/dnode/vnode/src/vnd/vnodeSvr.c
@@ -138,6 +138,7 @@ int vnodeProcessWriteReq(SVnode *pVnode, SRpcMsg *pMsg, int64_t version, SRpcMsg
 
   // commit if need
   if (vnodeShouldCommit(pVnode)) {
+    vInfo("vgId:%d commit at version %" PRId64, TD_VID(pVnode), version);
     // commit current change
     vnodeCommit(pVnode);