Searched refs:mtcpq (Results 1 – 1 of 1) sorted by relevance
425 struct event_queue *mtcpq; in FlushMonitorReadEvents() local432 !(mtcpq = walk->eq)) in FlushMonitorReadEvents()437 (struct tcp_stream *)mtcpq->events[mtcpq->start++].ev.data.ptr; in FlushMonitorReadEvents()462 if (mtcpq->start >= mtcpq->size) in FlushMonitorReadEvents()463 mtcpq->start = 0; in FlushMonitorReadEvents()464 mtcpq->num_events--; in FlushMonitorReadEvents()483 offset = mtcpq->start; in FlushBufferedReadEvents()529 usrq->events[usrq->end++] = mtcpq->events[mtcpq->start++]; in FlushEpollEvents()535 if (mtcpq->start >= mtcpq->size) in FlushEpollEvents()536 mtcpq->start = 0; in FlushEpollEvents()[all …]