fix(stream): fix dead lock.

2024-01-02 11:40:29 +08:00 · 2024-01-02 11:40:29 +08:00 · 4368bfb20a
parent b3d8f4e9d6
commit 4368bfb20a
1 changed files with 1 additions and 2 deletions
--- a/source/dnode/vnode/src/vnd/vnodeSync.c
+++ b/source/dnode/vnode/src/vnd/vnodeSync.c
@ -587,10 +587,9 @@ static void vnodeRestoreFinish(const SSyncFSM *pFsm, const SyncIndex commitIdx)
      }
    }
  } else {
+    streamMetaWUnLock(pMeta);
    vInfo("vgId:%d, sync restore finished, not launch stream tasks since not leader", vgId);
  }
-
-  streamMetaWUnLock(pMeta);
 }

 static void vnodeBecomeFollower(const SSyncFSM *pFsm) {