opti:tmq
This commit is contained in:
parent
0ccad9d5de
commit
4810053142
|
@ -386,7 +386,7 @@ static int32_t sendCheckInfoToVnode(STrans *pTrans, SMnode *pMnode, SMqTopicObj
|
||||||
SEncoder encoder;
|
SEncoder encoder;
|
||||||
tEncoderInit(&encoder, abuf, len);
|
tEncoderInit(&encoder, abuf, len);
|
||||||
code = tEncodeSTqCheckInfo(&encoder, &info);
|
code = tEncodeSTqCheckInfo(&encoder, &info);
|
||||||
if (code != 0) {
|
if (code < 0) {
|
||||||
terrno = TSDB_CODE_OUT_OF_MEMORY;
|
terrno = TSDB_CODE_OUT_OF_MEMORY;
|
||||||
goto END;
|
goto END;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue