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

fix: compile issues

This commit is contained in:
dapan1121 2024-07-15 17:32:36 +08:00
parent 50d7a458e5
commit b81493b7b4
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
source/libs/qworker/test/qworkerTests.cpp
View File

@ -137,23 +137,25 @@ int qwtBuildDropReqMsg(STaskDropReq *dropMsg, SRpcMsg *dropRpc) {
int32_t msgSize = tSerializeSTaskDropReq(NULL, 0, dropMsg); int32_t msgSize = tSerializeSTaskDropReq(NULL, 0, dropMsg);
if (msgSize < 0) { if (msgSize < 0) {
return; return terrno;
} }
char *msg = (char*)taosMemoryCalloc(1, msgSize); char *msg = (char*)taosMemoryCalloc(1, msgSize);
if (NULL == msg) { if (NULL == msg) {
return; return terrno;
} }
if (tSerializeSTaskDropReq(msg, msgSize, dropMsg) < 0) { if (tSerializeSTaskDropReq(msg, msgSize, dropMsg) < 0) {
taosMemoryFree(msg); taosMemoryFree(msg);
return; return terrno;
} }
dropRpc->msgType = TDMT_SCH_DROP_TASK; dropRpc->msgType = TDMT_SCH_DROP_TASK;
dropRpc->pCont = msg; dropRpc->pCont = msg;
dropRpc->contLen = msgSize; dropRpc->contLen = msgSize;
return TSDB_CODE_SUCCESS;
} }
int32_t qwtStringToPlan(const char *str, SSubplan **subplan) { int32_t qwtStringToPlan(const char *str, SSubplan **subplan) {
@ -256,7 +258,7 @@ int qwtRpcSendResponse(const SRpcMsg *pRsp) {
return code; return code;
} }
rpcFreeCont(rsp); rpcFreeCont(rsp);
return; return code;
} }
code = qwtBuildDropReqMsg(&qwtdropMsg, &qwtdropRpc); code = qwtBuildDropReqMsg(&qwtdropMsg, &qwtdropRpc);