From cc4558ff9ac97fce5da95383b4b28badcb04c5e1 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 3 Feb 2023 23:09:21 +0800 Subject: [PATCH] opt index --- source/dnode/mnode/impl/src/mndIndex.c | 46 +++++++++++++------------- 1 file changed, 23 insertions(+), 23 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndIndex.c b/source/dnode/mnode/impl/src/mndIndex.c index 91a0419cd6..46ec092bee 100644 --- a/source/dnode/mnode/impl/src/mndIndex.c +++ b/source/dnode/mnode/impl/src/mndIndex.c @@ -353,33 +353,33 @@ static int32_t mndProcessCreateIdxReq(SRpcMsg *pReq) { //} } - pDb = mndAcquireDbByIdx(pMnode, createReq.idxName); - if (pDb == NULL) { - terrno = TSDB_CODE_MND_DB_NOT_SELECTED; - goto _OVER; - } + // pDb = mndAcquireDbByIdx(pMnode, createReq.idxName); + // if (pDb == NULL) { + // terrno = TSDB_CODE_MND_DB_NOT_SELECTED; + // goto _OVER; + / e +} - if (mndCheckDbPrivilege(pMnode, pReq->info.conn.user, MND_OPER_WRITE_DB, pDb) != 0) { - goto _OVER; - } +if (mndCheckDbPrivilege(pMnode, pReq->info.conn.user, MND_OPER_WRITE_DB, pDb) != 0) { + goto _OVER; +} - code = mndAddIndex(pMnode, pReq, &createReq, pDb, pStb); - if (terrno == TSDB_CODE_MND_TAG_INDEX_ALREADY_EXIST || terrno == TSDB_CODE_MND_TAG_NOT_EXIST) { - return terrno; - } else { - if (code == 0) code = TSDB_CODE_ACTION_IN_PROGRESS; - } +code = mndAddIndex(pMnode, pReq, &createReq, pDb, pStb); +if (terrno == TSDB_CODE_MND_TAG_INDEX_ALREADY_EXIST || terrno == TSDB_CODE_MND_TAG_NOT_EXIST) { + return terrno; +} else { + if (code == 0) code = TSDB_CODE_ACTION_IN_PROGRESS; +} -_OVER: - if (code != 0 && code != TSDB_CODE_ACTION_IN_PROGRESS) { - mError("stb:%s, failed to create since %s", createReq.idxName, terrstr()); - } +_OVER : if (code != 0 && code != TSDB_CODE_ACTION_IN_PROGRESS) { + mError("stb:%s, failed to create since %s", createReq.idxName, terrstr()); +} - mndReleaseStb(pMnode, pStb); - mndReleaseIdx(pMnode, pIdx); - mndReleaseDb(pMnode, pDb); +mndReleaseStb(pMnode, pStb); +mndReleaseIdx(pMnode, pIdx); +mndReleaseDb(pMnode, pDb); - return code; +return code; } static int32_t mndSetDropIdxRedoLogs(SMnode *pMnode, STrans *pTrans, SIdxObj *pIdx) { @@ -387,7 +387,7 @@ static int32_t mndSetDropIdxRedoLogs(SMnode *pMnode, STrans *pTrans, SIdxObj *pI if (pRedoRaw == NULL) return -1; if (mndTransAppendRedolog(pTrans, pRedoRaw) != 0) return -1; if (sdbSetRawStatus(pRedoRaw, SDB_STATUS_DROPPING) != 0) return -1; - + return 0; }