xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

enh/TD-29974-improve-trans-fix-case

This commit is contained in:
dmchen 2024-12-17 09:54:54 +08:00
parent ce86b1d687
commit 4b6eec21f4
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/dnode/mnode/impl/src/mndDb.c
View File

@ -1017,7 +1017,7 @@ static int32_t mndProcessCreateDbReq(SRpcMsg *pReq) {
TAOS_CHECK_GOTO(mndAcquireUser(pMnode, pReq->info.conn.user, &pUser), &lino, _OVER); TAOS_CHECK_GOTO(mndAcquireUser(pMnode, pReq->info.conn.user, &pUser), &lino, _OVER);
TAOS_CHECK_GOTO(mndCreateDb(pMnode, pReq, &createReq, pUser, dnodeList), &lino, _OVER); TAOS_CHECK_GOTO(mndCreateDb(pMnode, pReq, &createReq, pUser, dnodeList), &lino, _OVER);
//if (code == 0) code = TSDB_CODE_ACTION_IN_PROGRESS; if (code == 0) code = TSDB_CODE_ACTION_IN_PROGRESS;
SName name = {0}; SName name = {0};
if (tNameFromString(&name, createReq.db, T_NAME_ACCT | T_NAME_DB) < 0) if (tNameFromString(&name, createReq.db, T_NAME_ACCT | T_NAME_DB) < 0)

1
source/dnode/mnode/impl/src/mndTrans.c
View File

@ -1333,6 +1333,7 @@ int32_t mndTransProcessRsp(SRpcMsg *pRsp) {
pAction->msgReceived = 1; pAction->msgReceived = 1;
pAction->errCode = pRsp->code; pAction->errCode = pRsp->code;
pAction->endTime = taosGetTimestampMs(); pAction->endTime = taosGetTimestampMs();
// pTrans->lastErrorNo = pRsp->code; // pTrans->lastErrorNo = pRsp->code;
mndSetTransLastAction(pTrans, pAction); mndSetTransLastAction(pTrans, pAction);