94 	mtcp_manager_t mtcp = g_mtcp[mctx->cpu];  in mtcp_epoll_create()  local
142 	mtcp->ep = ep;  in mtcp_epoll_create()
168 	mtcp_manager_t mtcp;  in CloseEpollSocket()  local
171 	mtcp = GetMTCPManager(mctx);  in CloseEpollSocket()
172 	if (!mtcp) {  in CloseEpollSocket()
176 	ep = mtcp->smap[epid].ep;  in CloseEpollSocket()
187 	mtcp->ep = NULL;  in CloseEpollSocket()
188 	mtcp->smap[epid].ep = NULL;  in CloseEpollSocket()
200 RaisePendingStreamEvents(mtcp_manager_t mtcp,   in RaisePendingStreamEvents()  argument
244 	mtcp_manager_t mtcp;  in mtcp_epoll_ctl()  local
249 	mtcp = GetMTCPManager(mctx);  in mtcp_epoll_ctl()
250 	if (!mtcp) {  in mtcp_epoll_ctl()
266 	if (mtcp->smap[epid].socktype == MOS_SOCK_UNUSED) {  in mtcp_epoll_ctl()
271 	if (mtcp->smap[epid].socktype != MOS_SOCK_EPOLL) {  in mtcp_epoll_ctl()
276 	ep = mtcp->smap[epid].ep;  in mtcp_epoll_ctl()
281 	socket = &mtcp->smap[sockid];  in mtcp_epoll_ctl()
302 			RaisePendingStreamEvents(mtcp, ep, socket);  in mtcp_epoll_ctl()
320 			RaisePendingStreamEvents(mtcp, ep, socket);  in mtcp_epoll_ctl()
341 	mtcp_manager_t mtcp;  in mtcp_epoll_wait()  local
350 	mtcp = GetMTCPManager(mctx);  in mtcp_epoll_wait()
351 	if (!mtcp) {  in mtcp_epoll_wait()
361 	if (mtcp->smap[epid].socktype == MOS_SOCK_UNUSED) {  in mtcp_epoll_wait()
366 	if (mtcp->smap[epid].socktype != MOS_SOCK_EPOLL) {  in mtcp_epoll_wait()
371 	ep = mtcp->smap[epid].ep;  in mtcp_epoll_wait()
401 		if (mtcp->wakeup_flag && mtcp->is_sleeping) {  in mtcp_epoll_wait()
402 			pthread_kill(mtcp->ctx->thread, SIGUSR1);  in mtcp_epoll_wait()
449 		if (mtcp->ctx->done || mtcp->ctx->exit || mtcp->ctx->interrupt) {  in mtcp_epoll_wait()
450 			mtcp->ctx->interrupt = FALSE;  in mtcp_epoll_wait()
463 		event_socket = &mtcp->smap[eq->events[eq->start].sockid];  in mtcp_epoll_wait()
501 		event_socket = &mtcp->smap[eq->events[eq->start].sockid];  in mtcp_epoll_wait()