add time out

This commit is contained in:
yihaoDeng 2024-09-30 18:17:04 +08:00
parent d24dc87c80
commit 60718d0e38
1 changed files with 2 additions and 2 deletions

View File

@ -1174,8 +1174,8 @@ static void notifyAndDestroyReq(SCliConn* pConn, SCliReq* pReq, int32_t code) {
}
static FORCE_INLINE void destroyReqInQueue(SCliConn* conn, queue* set) {
while (!QUEUE_IS_EMPTY(&set)) {
queue* el = QUEUE_HEAD(&set);
while (!QUEUE_IS_EMPTY(set)) {
queue* el = QUEUE_HEAD(set);
QUEUE_REMOVE(el);
SCliReq* pReq = QUEUE_DATA(el, SCliReq, q);