diff --git a/source/libs/scheduler/src/schRemote.c b/source/libs/scheduler/src/schRemote.c index bb06a25ce0..a1410f2421 100644 --- a/source/libs/scheduler/src/schRemote.c +++ b/source/libs/scheduler/src/schRemote.c @@ -503,7 +503,7 @@ int32_t schHandleDropCallback(void *param, SDataBuf *pMsg, int32_t code) { (void)rpcReleaseHandle(pMsg->handle, TAOS_CONN_CLIENT); // ignore error if (pMsg->handle == NULL) { - ASSERT(0); + qError("sch handle is NULL, may be already released and mem lea"); } if (pMsg) { taosMemoryFree(pMsg->pData); diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index f866097e2a..802af1aad1 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -557,7 +557,6 @@ void cliHandleResp(SCliConn* conn) { taosMemoryFree(pHead); tDebug("%s conn %p recv invalid packet ", CONN_GET_INST_LABEL(conn), conn); // TODO: notify cb - // ASSERT(0); pThrd->notifyExceptCb(pThrd, NULL, NULL); return; } @@ -616,6 +615,7 @@ void cliHandleResp(SCliConn* conn) { if (cliMayRecycleConn(conn)) { return; } + cliConnCheckTimoutMsg(conn); cliConnMayUpdateTimer(conn, READ_TIMEOUT); diff --git a/source/libs/transport/src/transSvr.c b/source/libs/transport/src/transSvr.c index 12d243e3d1..612bbc8301 100644 --- a/source/libs/transport/src/transSvr.c +++ b/source/libs/transport/src/transSvr.c @@ -555,14 +555,14 @@ static bool uvHandleReq(SSvrConn* pConn) { } if (pHead->seqNum == 0) { - // ASSERT(0); + STraceId* trace = &pHead->traceId; + tGError("%s conn %p received invalid seqNum, msgType:%s", transLabel(pInst), pConn, TMSG_INFO(pHead->msgType)); + return false; } transMsg.info.handle = (void*)transAcquireExHandle(uvGetConnRefOfThrd(pThrd), pConn->refId); transMsg.info.refIdMgt = pThrd->connRefMgt; - // ASSERTS(transMsg.info.handle != NULL, "trans-svr failed to alloc handle to msg"); - // pHead->noResp = 1, // 1. server application should not send resp on handle // 2. once send out data, cli conn released to conn pool immediately @@ -729,7 +729,6 @@ static int uvPrepareSendData(SSvrRespMsg* smsg, uv_buf_t* wb) { // handle invalid drop_task resp, TD-20098 if (pConn->inType == TDMT_SCH_DROP_TASK && pMsg->code == TSDB_CODE_VND_INVALID_VGROUP_ID) { - // ASSERT(0); // (void)transQueuePop(&pConn->resps); // destroySmsg(smsg); // return TSDB_CODE_INVALID_MSG;