Lines Matching full:events

87 	struct epoll_event *events;  member
113 short old, short events, void *p);
115 short old, short events, void *p);
169 epollop->events = mm_calloc(INITIAL_NEVENT, sizeof(struct epoll_event)); in epoll_init()
170 if (epollop->events == NULL) { in epoll_init()
199 epev.events = EPOLLIN; in epoll_init()
249 #define PRINT_CHANGES(op, events, ch, status) \ argument
251 "Old events were %d; " \
256 events, \
272 int op, events = 0; in epoll_apply_one_change() local
277 events = epoll_op_table[idx].events; in epoll_apply_one_change()
279 if (!events) { in epoll_apply_one_change()
285 events |= EPOLLET; in epoll_apply_one_change()
289 epev.events = events; in epoll_apply_one_change()
291 event_debug((PRINT_CHANGES(op, epev.events, ch, "okay"))); in epoll_apply_one_change()
304 (int)epev.events, ch->fd); in epoll_apply_one_change()
308 (int)epev.events, in epoll_apply_one_change()
325 (int)epev.events, ch->fd); in epoll_apply_one_change()
329 (int)epev.events, in epoll_apply_one_change()
341 (int)epev.events, in epoll_apply_one_change()
351 event_warn(PRINT_CHANGES(op, epev.events, ch, "failed")); in epoll_apply_one_change()
376 short old, short events, void *p) in epoll_nochangelist_add() argument
382 if (events & EV_WRITE) in epoll_nochangelist_add()
384 (events & EV_ET); in epoll_nochangelist_add()
385 if (events & EV_READ) in epoll_nochangelist_add()
387 (events & EV_ET); in epoll_nochangelist_add()
388 if (events & EV_CLOSED) in epoll_nochangelist_add()
390 (events & EV_ET); in epoll_nochangelist_add()
397 short old, short events, void *p) in epoll_nochangelist_del() argument
403 if (events & EV_WRITE) in epoll_nochangelist_del()
405 (events & EV_ET); in epoll_nochangelist_del()
406 if (events & EV_READ) in epoll_nochangelist_del()
408 (events & EV_ET); in epoll_nochangelist_del()
409 if (events & EV_CLOSED) in epoll_nochangelist_del()
411 (events & EV_ET); in epoll_nochangelist_del()
420 struct epoll_event *events = epollop->events; in epoll_dispatch() local
465 res = epoll_wait(epollop->epfd, events, epollop->nevents, timeout); in epoll_dispatch()
482 int what = events[i].events; in epoll_dispatch()
485 if (events[i].data.fd == epollop->timerfd) in epoll_dispatch()
505 evmap_io_active_(base, events[i].data.fd, ev | EV_ET); in epoll_dispatch()
510 be ready for more events next time. */ in epoll_dispatch()
514 new_events = mm_realloc(epollop->events, in epoll_dispatch()
517 epollop->events = new_events; in epoll_dispatch()
532 if (epollop->events) in epoll_dealloc()
533 mm_free(epollop->events); in epoll_dealloc()