From b81493b7b426a1328b9971d781c5eacd115a4364 Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Mon, 15 Jul 2024 17:32:36 +0800 Subject: [PATCH] fix: compile issues --- source/libs/qworker/test/qworkerTests.cpp | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/source/libs/qworker/test/qworkerTests.cpp b/source/libs/qworker/test/qworkerTests.cpp index b60e285cb4..d292b271c5 100644 --- a/source/libs/qworker/test/qworkerTests.cpp +++ b/source/libs/qworker/test/qworkerTests.cpp @@ -137,23 +137,25 @@ int qwtBuildDropReqMsg(STaskDropReq *dropMsg, SRpcMsg *dropRpc) { int32_t msgSize = tSerializeSTaskDropReq(NULL, 0, dropMsg); if (msgSize < 0) { - return; + return terrno; } char *msg = (char*)taosMemoryCalloc(1, msgSize); if (NULL == msg) { - return; + return terrno; } if (tSerializeSTaskDropReq(msg, msgSize, dropMsg) < 0) { taosMemoryFree(msg); - return; + return terrno; } dropRpc->msgType = TDMT_SCH_DROP_TASK; dropRpc->pCont = msg; dropRpc->contLen = msgSize; + + return TSDB_CODE_SUCCESS; } int32_t qwtStringToPlan(const char *str, SSubplan **subplan) { @@ -256,7 +258,7 @@ int qwtRpcSendResponse(const SRpcMsg *pRsp) { return code; } rpcFreeCont(rsp); - return; + return code; } code = qwtBuildDropReqMsg(&qwtdropMsg, &qwtdropRpc);