Lines Matching refs:mtcpq
425 struct event_queue *mtcpq; in FlushMonitorReadEvents() local
432 !(mtcpq = walk->eq)) in FlushMonitorReadEvents()
435 while (mtcpq->num_events > 0) { 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()
474 struct event_queue *mtcpq; in FlushBufferedReadEvents() local
482 mtcpq = mtcp->ep->mtcp_queue; in FlushBufferedReadEvents()
483 offset = mtcpq->start; in FlushBufferedReadEvents()
488 for (i = 0; i < mtcpq->num_events; i++) { in FlushBufferedReadEvents()
489 cur_stream = mtcp->smap[mtcpq->events[offset++].sockid].stream; in FlushBufferedReadEvents()
511 if (offset >= mtcpq->size) in FlushBufferedReadEvents()
521 struct event_queue *mtcpq = ep->mtcp_queue; in FlushEpollEvents() local
527 while (mtcpq->num_events > 0 && usrq->num_events < usrq->size) { in FlushEpollEvents()
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()
537 mtcpq->num_events--; in FlushEpollEvents()