Merge pull request #19763 from taosdata/fix/TD-22074
fix: fix not msg to send
This commit is contained in:
commit
eae7fc509f
|
@ -800,9 +800,12 @@ static void cliSendCb(uv_write_t* req, int status) {
|
||||||
}
|
}
|
||||||
|
|
||||||
void cliSend(SCliConn* pConn) {
|
void cliSend(SCliConn* pConn) {
|
||||||
bool empty = transQueueEmpty(&pConn->cliMsgs);
|
SCliThrd* pThrd = pConn->hostThrd;
|
||||||
ASSERTS(empty == false, "trans-cli get invalid msg");
|
STrans* pTransInst = pThrd->pTransInst;
|
||||||
if (empty == true) {
|
|
||||||
|
if (transQueueEmpty(&pConn->cliMsgs)) {
|
||||||
|
tError("%s conn %p not msg to send", pTransInst->label, pConn);
|
||||||
|
cliHandleExcept(pConn);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -812,9 +815,6 @@ void cliSend(SCliConn* pConn) {
|
||||||
|
|
||||||
STransConnCtx* pCtx = pCliMsg->ctx;
|
STransConnCtx* pCtx = pCliMsg->ctx;
|
||||||
|
|
||||||
SCliThrd* pThrd = pConn->hostThrd;
|
|
||||||
STrans* pTransInst = pThrd->pTransInst;
|
|
||||||
|
|
||||||
STransMsg* pMsg = (STransMsg*)(&pCliMsg->msg);
|
STransMsg* pMsg = (STransMsg*)(&pCliMsg->msg);
|
||||||
if (pMsg->pCont == 0) {
|
if (pMsg->pCont == 0) {
|
||||||
pMsg->pCont = (void*)rpcMallocCont(0);
|
pMsg->pCont = (void*)rpcMallocCont(0);
|
||||||
|
|
Loading…
Reference in New Issue