fix: memory leak while subscribe

c4045de4 · Shengliang Guan · 56ccb65c · c4045de4 · c4045de4
显示空白变更内容
内联并排

Showing with 4 addition and 0 deletion

source/dnode/mnode/impl/src/mndScheduler.c source/dnode/mnode/impl/src/mndScheduler.c +2 -0

source/dnode/mnode/impl/src/mndTopic.c source/dnode/mnode/impl/src/mndTopic.c +2 -0

未找到文件。
--- a/source/dnode/mnode/impl/src/mndScheduler.c
+++ b/source/dnode/mnode/impl/src/mndScheduler.c
@@ -585,6 +585,8 @@ int32_t mndSchedInitSubEp(SMnode* pMnode, const SMqTopicObj* pTopic, SMqSubscrib
    } else {
      pVgEp->qmsg = strdup("");
    }
+
+    sdbRelease(pSdb, pVgroup);
  }

  ASSERT(pSub->unassignedVgs->size > 0);

--- a/source/dnode/mnode/impl/src/mndTopic.c
+++ b/source/dnode/mnode/impl/src/mndTopic.c
@@ -512,6 +512,8 @@ static int32_t mndCreateTopic(SMnode *pMnode, SRpcMsg *pReq, SCMCreateTopicReq *
        mndTransDrop(pTrans);
        return -1;
      }
+
+      sdbRelease(pSdb, pVgroup);
    }
  }