enh: check trans conflict in mndCreateTopic ahead of time

69d451db · Benguang Zhao · 9e2062f5 · 69d451db
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

source/dnode/mnode/impl/src/mndTopic.c source/dnode/mnode/impl/src/mndTopic.c +3 -1

未找到文件。
--- a/source/dnode/mnode/impl/src/mndTopic.c
+++ b/source/dnode/mnode/impl/src/mndTopic.c
@@ -476,7 +476,9 @@ static int32_t mndCreateTopic(SMnode *pMnode, SRpcMsg *pReq, SCMCreateTopicReq *
  }

  mndTransSetDbName(pTrans, pDb->name, NULL);
-
+  if (mndTransCheckConflict(pMnode, pTrans) != 0) {
+      goto _OUT;
+  }
  mInfo("trans:%d to create topic:%s", pTrans->id, pCreate->name);

  SSdbRaw *pCommitRaw = mndTopicActionEncode(&topicObj);