enh: memory optimization
This commit is contained in:
parent
6e715e6964
commit
c89967d091
|
@ -4908,7 +4908,6 @@ int32_t tDecodeSRSmaParam(SDecoder *pCoder, SRSmaParam *pRSmaParam) {
|
||||||
if (tDecodeI64v(pCoder, &pRSmaParam->watermark[i]) < 0) return -1;
|
if (tDecodeI64v(pCoder, &pRSmaParam->watermark[i]) < 0) return -1;
|
||||||
if (tDecodeI32v(pCoder, &pRSmaParam->qmsgLen[i]) < 0) return -1;
|
if (tDecodeI32v(pCoder, &pRSmaParam->qmsgLen[i]) < 0) return -1;
|
||||||
if (pRSmaParam->qmsgLen[i] > 0) {
|
if (pRSmaParam->qmsgLen[i] > 0) {
|
||||||
tDecoderMalloc(pCoder, pRSmaParam->qmsgLen[i]);
|
|
||||||
if (tDecodeBinary(pCoder, (uint8_t **)&pRSmaParam->qmsg[i], NULL) < 0) return -1; // qmsgLen contains len of '\0'
|
if (tDecodeBinary(pCoder, (uint8_t **)&pRSmaParam->qmsg[i], NULL) < 0) return -1; // qmsgLen contains len of '\0'
|
||||||
} else {
|
} else {
|
||||||
pRSmaParam->qmsg[i] = NULL;
|
pRSmaParam->qmsg[i] = NULL;
|
||||||
|
|
|
@ -437,14 +437,10 @@ static int32_t vnodeProcessCreateStbReq(SVnode *pVnode, int64_t version, void *p
|
||||||
goto _err;
|
goto _err;
|
||||||
}
|
}
|
||||||
|
|
||||||
// taosMemoryFree(req.schemaRow.pSchema);
|
|
||||||
// taosMemoryFree(req.schemaTag.pSchema);
|
|
||||||
tDecoderClear(&coder);
|
tDecoderClear(&coder);
|
||||||
return 0;
|
return 0;
|
||||||
|
|
||||||
_err:
|
_err:
|
||||||
taosMemoryFree(req.schemaRow.pSchema);
|
|
||||||
taosMemoryFree(req.schemaTag.pSchema);
|
|
||||||
tDecoderClear(&coder);
|
tDecoderClear(&coder);
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue