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

fix recv return code .

This commit is contained in:
xiao-77 2024-12-06 18:17:16 +08:00
parent 3343f0d44e
commit d8c5c65f74
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/dnode/mnode/impl/src/mndConfig.c
View File

@ -225,7 +225,7 @@ static int32_t mndProcessConfigReq(SRpcMsg *pReq) {
SMnode *pMnode = pReq->info.node; SMnode *pMnode = pReq->info.node;
SConfigReq configReq = {0}; SConfigReq configReq = {0};
SDnodeObj *pDnode = NULL; SDnodeObj *pDnode = NULL;
int32_t code = -1; int32_t code = TSDB_CODE_SUCCESS;
SArray *array = NULL; SArray *array = NULL;
code = tDeserializeSConfigReq(pReq->pCont, pReq->contLen, &configReq); code = tDeserializeSConfigReq(pReq->pCont, pReq->contLen, &configReq);
@ -256,7 +256,11 @@ static int32_t mndProcessConfigReq(SRpcMsg *pReq) {
if (configReq.cver == vObj->i32) { if (configReq.cver == vObj->i32) {
configRsp.isVersionVerified = 1; configRsp.isVersionVerified = 1;
} else { } else {
initConfigArrayFromSdb(pMnode, array); code = initConfigArrayFromSdb(pMnode, array);
if (code != 0) {
mError("failed to init config array from sdb, since %s", terrstr());
goto _OVER;
}
configRsp.array = array; configRsp.array = array;
} }
} }