Searched refs:num_events (Results 1 – 4 of 4) sorted by relevance
77 eq->num_events = 0; in CreateEventQueue()348 int num_events; in mtcp_epoll_wait() local397 while (eq->num_events == 0 && eq_shadow->num_events == 0 && timeout != 0) { in mtcp_epoll_wait()461 num_events = eq->num_events; in mtcp_epoll_wait()491 eq->num_events--; in mtcp_epoll_wait()499 num_events = eq->num_events; in mtcp_epoll_wait()529 eq->num_events--; in mtcp_epoll_wait()574 if (eq->num_events >= eq->size) { in AddEpollEvent()576 eq->num_events, eq->size); in AddEpollEvent()592 eq->num_events++; in AddEpollEvent()[all …]
435 while (mtcpq->num_events > 0) { in FlushMonitorReadEvents()464 mtcpq->num_events--; in FlushMonitorReadEvents()488 for (i = 0; i < mtcpq->num_events; i++) { in FlushBufferedReadEvents()524 if (ep->mtcp_queue->num_events > 0) { in FlushEpollEvents()527 while (mtcpq->num_events > 0 && usrq->num_events < usrq->size) { in FlushEpollEvents()533 usrq->num_events++; in FlushEpollEvents()537 mtcpq->num_events--; in FlushEpollEvents()542 if (ep->waiting && (ep->usr_queue->num_events > 0 || in FlushEpollEvents()543 ep->usr_shadow_queue->num_events > 0)) { in FlushEpollEvents()546 ep->usr_queue->num_events, cur_ts, mtcp->ts_last_event); in FlushEpollEvents()
263 if (eq->num_events >= eq->size) { in RaiseReadEvent()265 "size: %d\n", eq->num_events, eq->size); in RaiseReadEvent()276 eq->num_events++; in RaiseReadEvent()
40 int num_events; // number of events member