handle quit error
This commit is contained in:
parent
8d4813590f
commit
70c9d9847f
|
@ -1499,7 +1499,6 @@ int32_t cliBatchSend(SCliConn* pConn, int8_t direct) {
|
||||||
tError("%s conn %p failed to send msg since %s", CONN_GET_INST_LABEL(pConn), pConn, tstrerror(terrno));
|
tError("%s conn %p failed to send msg since %s", CONN_GET_INST_LABEL(pConn), pConn, tstrerror(terrno));
|
||||||
while (!QUEUE_IS_EMPTY(&reqToSend)) {
|
while (!QUEUE_IS_EMPTY(&reqToSend)) {
|
||||||
queue* h = QUEUE_HEAD(&reqToSend);
|
queue* h = QUEUE_HEAD(&reqToSend);
|
||||||
|
|
||||||
SCliReq* pCliMsg = QUEUE_DATA(h, SCliReq, sendQ);
|
SCliReq* pCliMsg = QUEUE_DATA(h, SCliReq, sendQ);
|
||||||
removeReqFromSendQ(pCliMsg);
|
removeReqFromSendQ(pCliMsg);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue