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

ci break

This commit is contained in:
dmchen 2023-09-18 18:38:54 +08:00
parent 8349513e6f
commit 2e42af1dd0
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
source/common/src/tmsg.c
View File

@ -6844,7 +6844,8 @@ int tEncodeSVCreateTbReq(SEncoder *pCoder, const SVCreateTbReq *pReq) {
} else { } else {
ASSERT(0); ASSERT(0);
} }
if(pReq->sqlLen > 0) { //ENCODESQL
if(pReq->sqlLen > 0 && pReq->sql != NULL) {
if (tEncodeI32(pCoder, pReq->sqlLen) < 0) return -1; if (tEncodeI32(pCoder, pReq->sqlLen) < 0) return -1;
if (tEncodeCStrWithLen(pCoder, pReq->sql, pReq->sqlLen) < 0) return -1; if (tEncodeCStrWithLen(pCoder, pReq->sql, pReq->sqlLen) < 0) return -1;
} }
@ -6891,12 +6892,13 @@ int tDecodeSVCreateTbReq(SDecoder *pCoder, SVCreateTbReq *pReq) {
ASSERT(0); ASSERT(0);
} }
//DECODESQL
if(!tDecodeIsEnd(pCoder)){ if(!tDecodeIsEnd(pCoder)){
if(tDecodeI32(pCoder, &pReq->sqlLen) < 0) return -1; if(tDecodeI32(pCoder, &pReq->sqlLen) < 0) return -1;
if(pReq->sqlLen > 0){ if(pReq->sqlLen > 0){
pReq->sql = taosMemoryCalloc(1, pReq->sqlLen + 1); pReq->sql = taosMemoryCalloc(1, pReq->sqlLen + 1);
if (pReq->sql == NULL) return -1; if (pReq->sql == NULL) return -1;
if (tDecodeCStrAndLen(pCoder, &pReq->sql, &pReq->sqlLen) < 0) return -1; if (tDecodeCStrTo(pCoder, pReq->sql) < 0) return -1;
} }
} }