62 	struct event_queue *eq;  in CreateEventQueue()  local
64 	eq = (struct event_queue *)calloc(1, sizeof(struct event_queue));  in CreateEventQueue()
65 	if (!eq)  in CreateEventQueue()
68 	eq->start = 0;  in CreateEventQueue()
69 	eq->end = 0;  in CreateEventQueue()
70 	eq->size = size;  in CreateEventQueue()
71 	eq->events = (struct mtcp_epoll_event_int *)  in CreateEventQueue()
73 	if (!eq->events) {  in CreateEventQueue()
74 		free(eq);  in CreateEventQueue()
77 	eq->num_events = 0;  in CreateEventQueue()
79 	return eq;  in CreateEventQueue()
83 DestroyEventQueue(struct event_queue *eq)  in DestroyEventQueue()  argument
85 	if (eq->events)  in DestroyEventQueue()
86 		free(eq->events);  in DestroyEventQueue()
88 	free(eq);  in DestroyEventQueue()
343 	struct event_queue *eq;  in mtcp_epoll_wait()  local
393 	eq = ep->usr_queue;  in mtcp_epoll_wait()
397 	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()
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()
491 		eq->num_events--;  in mtcp_epoll_wait()
492 		if (eq->start >= eq->size) {  in mtcp_epoll_wait()
493 			eq->start = 0;  in mtcp_epoll_wait()
498 	eq = ep->usr_shadow_queue;  in mtcp_epoll_wait()
499 	num_events = eq->num_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()
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()
529 		eq->num_events--;  in mtcp_epoll_wait()
530 		if (eq->start >= eq->size) {  in mtcp_epoll_wait()
531 			eq->start = 0;  in mtcp_epoll_wait()
550 	struct event_queue *eq;  in AddEpollEvent()  local
563 		eq = ep->mtcp_queue;  in AddEpollEvent()
565 		eq = ep->usr_queue;  in AddEpollEvent()
568 		eq = ep->usr_shadow_queue;  in AddEpollEvent()
574 	if (eq->num_events >= eq->size) {  in AddEpollEvent()
576 				eq->num_events, eq->size);  in AddEpollEvent()
582 	index = eq->end++;  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()
589 	if (eq->end >= eq->size) {  in AddEpollEvent()
590 		eq->end = 0;  in AddEpollEvent()
592 	eq->num_events++;  in AddEpollEvent()
595 			eq->events[index].sockid,   in AddEpollEvent()
596 			EventToString(eq->events[index].ev.events),   in AddEpollEvent()
597 			eq->start, eq->end, eq->num_events);  in AddEpollEvent()