fix: invalid read
This commit is contained in:
parent
015dd658e6
commit
5c6b5f0d0f
|
@ -891,11 +891,17 @@ static void cliHandleFastFail(SCliConn* pConn, int status) {
|
||||||
SCliThrd* pThrd = pConn->hostThrd;
|
SCliThrd* pThrd = pConn->hostThrd;
|
||||||
STrans* pTransInst = pThrd->pTransInst;
|
STrans* pTransInst = pThrd->pTransInst;
|
||||||
|
|
||||||
SCliMsg* pMsg = transQueueGet(&pConn->cliMsgs, 0);
|
SCliMsg* pMsg = transQueueGet(&pConn->cliMsgs, 0);
|
||||||
STraceId* trace = &pMsg->msg.info.traceId;
|
|
||||||
|
if (pMsg) {
|
||||||
|
STraceId* trace = &pMsg->msg.info.traceId;
|
||||||
|
tGError("%s msg %s failed to send, conn %p failed to connect to %s, reason: %s", CONN_GET_INST_LABEL(pConn),
|
||||||
|
pMsg ? TMSG_INFO(pMsg->msg.msgType) : 0, pConn, pConn->ip, uv_strerror(status));
|
||||||
|
} else {
|
||||||
|
tError("%s msg %s failed to send, conn %p failed to connect to %s, reason: %s", CONN_GET_INST_LABEL(pConn), 0,
|
||||||
|
pConn, pConn->ip, uv_strerror(status));
|
||||||
|
}
|
||||||
|
|
||||||
tGError("%s msg %s failed to send, conn %p failed to connect to %s, reason: %s", CONN_GET_INST_LABEL(pConn),
|
|
||||||
pMsg ? TMSG_INFO(pMsg->msg.msgType) : 0, pConn, pConn->ip, uv_strerror(status));
|
|
||||||
uv_timer_stop(pConn->timer);
|
uv_timer_stop(pConn->timer);
|
||||||
pConn->timer->data = NULL;
|
pConn->timer->data = NULL;
|
||||||
taosArrayPush(pThrd->timerList, &pConn->timer);
|
taosArrayPush(pThrd->timerList, &pConn->timer);
|
||||||
|
|
Loading…
Reference in New Issue