Lines Matching refs:ep
412 if (running[i] && g_mtcp[i]->ep) { in PrintNetworkStats()
413 PrintEventStat(i, &g_mtcp[i]->ep->stat); in PrintNetworkStats()
477 if (mtcp->ep == NULL) { in FlushBufferedReadEvents()
482 mtcpq = mtcp->ep->mtcp_queue; in FlushBufferedReadEvents()
519 struct mtcp_epoll *ep = mtcp->ep; in FlushEpollEvents() local
520 struct event_queue *usrq = ep->usr_queue; in FlushEpollEvents()
521 struct event_queue *mtcpq = ep->mtcp_queue; in FlushEpollEvents()
523 pthread_mutex_lock(&ep->epoll_lock); in FlushEpollEvents()
524 if (ep->mtcp_queue->num_events > 0) { 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()
548 ep->stat.wakes++; in FlushEpollEvents()
549 pthread_cond_signal(&ep->epoll_cond); in FlushEpollEvents()
551 pthread_mutex_unlock(&ep->epoll_lock); in FlushEpollEvents()
824 if (mtcp->ep) { in InterruptApplication()
825 pthread_mutex_lock(&mtcp->ep->epoll_lock); in InterruptApplication()
826 if (mtcp->ep->waiting) { in InterruptApplication()
827 pthread_cond_signal(&mtcp->ep->epoll_cond); in InterruptApplication()
829 pthread_mutex_unlock(&mtcp->ep->epoll_lock); in InterruptApplication()
978 if (mtcp->ep) { in RunMainLoop()
1207 mtcp->ep = NULL; in InitializeMTCPManager()