68 	eq->start = 0;  in CreateEventQueue()
463 		event_socket = &mtcp->smap[eq->events[eq->start].sockid];  in mtcp_epoll_wait()
467 		if (!(event_socket->epoll & eq->events[eq->start].ev.events))  in mtcp_epoll_wait()
469 		if (!(event_socket->events & eq->events[eq->start].ev.events))  in mtcp_epoll_wait()
473 			events[cnt++] = eq->events[eq->start].ev;  in mtcp_epoll_wait()
474 			assert(eq->events[eq->start].sockid >= 0);  in mtcp_epoll_wait()
479 					EventToString(eq->events[eq->start].ev.events),   in mtcp_epoll_wait()
480 					eq->start, eq->end, eq->num_events);  in mtcp_epoll_wait()
484 					eq->events[eq->start].sockid,   in mtcp_epoll_wait()
485 					EventToString(eq->events[eq->start].ev.events));  in mtcp_epoll_wait()
488 		event_socket->events &= (~eq->events[eq->start].ev.events);  in mtcp_epoll_wait()
490 		eq->start++;  in mtcp_epoll_wait()
492 		if (eq->start >= eq->size) {  in mtcp_epoll_wait()
493 			eq->start = 0;  in mtcp_epoll_wait()
501 		event_socket = &mtcp->smap[eq->events[eq->start].sockid];  in mtcp_epoll_wait()
505 		if (!(event_socket->epoll & eq->events[eq->start].ev.events))  in mtcp_epoll_wait()
507 		if (!(event_socket->events & eq->events[eq->start].ev.events))  in mtcp_epoll_wait()
511 			events[cnt++] = eq->events[eq->start].ev;  in mtcp_epoll_wait()
512 			assert(eq->events[eq->start].sockid >= 0);  in mtcp_epoll_wait()
517 					EventToString(eq->events[eq->start].ev.events),   in mtcp_epoll_wait()
518 					eq->start, eq->end, eq->num_events);  in mtcp_epoll_wait()
522 					eq->events[eq->start].sockid,   in mtcp_epoll_wait()
523 					EventToString(eq->events[eq->start].ev.events));  in mtcp_epoll_wait()
526 		event_socket->events &= (~eq->events[eq->start].ev.events);  in mtcp_epoll_wait()
528 		eq->start++;  in mtcp_epoll_wait()
530 		if (eq->start >= eq->size) {  in mtcp_epoll_wait()
531 			eq->start = 0;  in mtcp_epoll_wait()
597 			eq->start, eq->end, eq->num_events);  in AddEpollEvent()