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

fix ci error

This commit is contained in:
xiao-77 2024-09-23 15:43:21 +08:00
parent ef56a07bea
commit 55d4d812e1
2 changed files with 5 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/dnode/mnode/impl/src/mndMain.c
View File

@ -911,11 +911,8 @@ _OVER:
int32_t contLen = tSerializeSEpSet(NULL, 0, &epSet); int32_t contLen = tSerializeSEpSet(NULL, 0, &epSet);
pMsg->info.rsp = rpcMallocCont(contLen); pMsg->info.rsp = rpcMallocCont(contLen);
if (pMsg->info.rsp != NULL) { if (pMsg->info.rsp != NULL) {
code = tSerializeSEpSet(pMsg->info.rsp, contLen, &epSet); if (tSerializeSEpSet(pMsg->info.rsp, contLen, &epSet) < 0) {
if (code < 0) { mError("failed to serialize ep set");
rpcFreeCont(pMsg->info.rsp);
pMsg->info.rsp = NULL;
TAOS_RETURN(code);
} }
pMsg->info.hasEpSet = 1; pMsg->info.hasEpSet = 1;
pMsg->info.rspLen = contLen; pMsg->info.rspLen = contLen;

9
source/dnode/mnode/impl/src/mndSnode.c
View File

@ -225,8 +225,7 @@ static int32_t mndSetCreateSnodeRedoActions(STrans *pTrans, SDnodeObj *pDnode, S
} }
code = tSerializeSCreateDropMQSNodeReq(pReq, contLen, &createReq); code = tSerializeSCreateDropMQSNodeReq(pReq, contLen, &createReq);
if (code < 0) { if (code < 0) {
taosMemoryFree(pReq); mError("snode:%d, failed to serialize create drop snode request since %s", createReq.dnodeId, terrstr());
TAOS_RETURN(code);
} }
STransAction action = {0}; STransAction action = {0};
@ -257,8 +256,7 @@ static int32_t mndSetCreateSnodeUndoActions(STrans *pTrans, SDnodeObj *pDnode, S
} }
code = tSerializeSCreateDropMQSNodeReq(pReq, contLen, &dropReq); code = tSerializeSCreateDropMQSNodeReq(pReq, contLen, &dropReq);
if (code < 0) { if (code < 0) {
taosMemoryFree(pReq); mError("snode:%d, failed to serialize create drop snode request since %s", dropReq.dnodeId, terrstr());
TAOS_RETURN(code);
} }
STransAction action = {0}; STransAction action = {0};
@ -393,8 +391,7 @@ static int32_t mndSetDropSnodeRedoActions(STrans *pTrans, SDnodeObj *pDnode, SSn
} }
code = tSerializeSCreateDropMQSNodeReq(pReq, contLen, &dropReq); code = tSerializeSCreateDropMQSNodeReq(pReq, contLen, &dropReq);
if (code < 0) { if (code < 0) {
taosMemoryFree(pReq); mError("snode:%d, failed to serialize create drop snode request since %s", dropReq.dnodeId, terrstr());
TAOS_RETURN(code);
} }
STransAction action = {0}; STransAction action = {0};