From 03de7ad5a65daad285d78138cd6905361fae3695 Mon Sep 17 00:00:00 2001 From: dmchen Date: Thu, 31 Aug 2023 16:44:36 +0800 Subject: [PATCH] stream name --- source/dnode/mnode/impl/src/mndStream.c | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index 46eb0d9957..9455aae8e3 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -888,7 +888,11 @@ static int32_t mndProcessCreateStreamReq(SRpcMsg *pReq) { createStreamReq.lastTs, createStreamReq.maxDelay, createStreamReq.numOfTags, createStreamReq.sourceDB, createStreamReq.targetStbFullName, createStreamReq.triggerType, createStreamReq.watermark); - auditRecord(pReq, pMnode->clusterId, "createStream", createStreamReq.name, "", detail); + SName name = {0}; + tNameFromString(&name, createStreamReq.name, T_NAME_ACCT | T_NAME_DB); + //reuse this function for stream + + auditRecord(pReq, pMnode->clusterId, "createStream", name.dbname, "", detail); _OVER: if (code != 0 && code != TSDB_CODE_ACTION_IN_PROGRESS) { @@ -1322,7 +1326,11 @@ static int32_t mndProcessDropStreamReq(SRpcMsg *pReq) { char detail[100] = {0}; sprintf(detail, "igNotExists:%d", dropReq.igNotExists); - auditRecord(pReq, pMnode->clusterId, "dropStream", dropReq.name, "", detail); + SName name = {0}; + tNameFromString(&name, dropReq.name, T_NAME_ACCT | T_NAME_DB); + //reuse this function for stream + + auditRecord(pReq, pMnode->clusterId, "dropStream", name.dbname, "", detail); sdbRelease(pMnode->pSdb, pStream); mndTransDrop(pTrans);