71 	eq->events = (struct mtcp_epoll_event_int *)  in CreateEventQueue()
73 	if (!eq->events) {  in CreateEventQueue()
85 	if (eq->events)  in DestroyEventQueue()
86 		free(eq->events);  in DestroyEventQueue()
230 			if (!(socket->events & MOS_EPOLLOUT)) {  in RaisePendingStreamEvents()
247 	uint32_t events;  in mtcp_epoll_ctl()  local
290 		events = event->events;  in mtcp_epoll_ctl()
291 		events |= (MOS_EPOLLERR | MOS_EPOLLHUP);  in mtcp_epoll_ctl()
293 		socket->epoll = events;  in mtcp_epoll_ctl()
314 		events = event->events;  in mtcp_epoll_ctl()
315 		events |= (MOS_EPOLLERR | MOS_EPOLLHUP);  in mtcp_epoll_ctl()
317 		socket->epoll = events;  in mtcp_epoll_ctl()
339 		struct mtcp_epoll_event *events, int maxevents, int timeout)  in mtcp_epoll_wait()  argument
372 	if (!ep || !events || maxevents <= 0) {  in mtcp_epoll_wait()
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()
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()
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()
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()
558 	if (socket->events & event) {  in AddEpollEvent()
584 	socket->events |= event;  in AddEpollEvent()
585 	eq->events[index].sockid = socket->id;  in AddEpollEvent()
586 	eq->events[index].ev.events = event;  in AddEpollEvent()
587 	eq->events[index].ev.data = socket->ep_data;  in AddEpollEvent()
595 			eq->events[index].sockid,   in AddEpollEvent()
596 			EventToString(eq->events[index].ev.events),   in AddEpollEvent()