Lines Matching defs:events
197 * during intermittent events or the kernel bug is triggered. If the next
225 * Maximum number of events communicated with the kernel. There should normally
263 * DLVL(70) -- Socket "correctness" -- including returning of events, etc.
265 * DLVL(50) -- Event tracing, including receiving/sending completion events.
352 * Internal events. Posted when a descriptor is readable or
401 struct kevent *events;
406 struct epoll_event *events;
413 struct pollfd *events;
930 event.events = manager->epoll_events[fd];
951 pfd.events = POLLIN;
953 pfd.events = POLLOUT;
1008 event.events = manager->epoll_events[fd];
1012 op = (event.events == 0U) ? EPOLL_CTL_DEL : EPOLL_CTL_MOD;
1028 pfds[0].events = POLLREMOVE;
1039 pfds[1].events = POLLOUT;
1045 pfds[1].events = POLLIN;
2382 * Initialize readable and writable events.
3403 * Are there any done events left, or were they all canceled
3826 * the events with an EOF result code.
4062 process_fds(isc__socketmgr_t *manager, struct kevent *events, int nevents) {
4078 "maximum number of FD events (%d) received",
4083 REQUIRE(events[i].ident < manager->maxsocks);
4085 if (events[i].ident == (uintptr_t)manager->pipe_fds[0]) {
4090 readable = ISC_TF(events[i].filter == EVFILT_READ);
4091 writable = ISC_TF(events[i].filter == EVFILT_WRITE);
4092 process_fd(manager, events[i].ident, readable, writable);
4104 process_fds(isc__socketmgr_t *manager, struct epoll_event *events, int nevents)
4115 "maximum number of FD events (%d) received",
4120 REQUIRE(events[i].data.fd < (int)manager->maxsocks);
4122 if (events[i].data.fd == manager->pipe_fds[0]) {
4127 if ((events[i].events & EPOLLERR) != 0 ||
4128 (events[i].events & EPOLLHUP) != 0) {
4133 * events. Note also that the read or write attempt
4136 int fd = events[i].data.fd;
4137 events[i].events |= manager->epoll_events[fd];
4139 process_fd(manager, events[i].data.fd,
4140 (events[i].events & EPOLLIN) != 0,
4141 (events[i].events & EPOLLOUT) != 0);
4153 process_fds(isc__socketmgr_t *manager, struct pollfd *events, int nevents) {
4163 "maximum number of FD events (%d) received",
4168 REQUIRE(events[i].fd < (int)manager->maxsocks);
4170 if (events[i].fd == manager->pipe_fds[0]) {
4175 process_fd(manager, events[i].fd,
4176 (events[i].events & POLLIN) != 0,
4177 (events[i].events & POLLOUT) != 0);
4290 manager->events, manager->nevents, NULL);
4292 cc = epoll_wait(manager->epoll_fd, manager->events,
4307 dvp.dp_fds = manager->events;
4385 done = process_fds(manager, manager->events, cc);
4437 manager->events = isc_mem_get(mctx, sizeof(struct kevent) *
4439 if (manager->events == NULL)
4450 isc_mem_put(mctx, manager->events,
4459 isc_mem_put(mctx, manager->events,
4466 manager->events = isc_mem_get(mctx, sizeof(struct epoll_event) *
4468 if (manager->events == NULL)
4479 isc_mem_put(mctx, manager->events,
4487 isc_mem_put(mctx, manager->events,
4499 manager->events = isc_mem_get(mctx, sizeof(struct pollfd) *
4501 if (manager->events == NULL)
4510 isc_mem_put(mctx, manager->events,
4524 isc_mem_put(mctx, manager->events,
4534 isc_mem_put(mctx, manager->events,
4615 isc_mem_put(mctx, manager->events,
4619 isc_mem_put(mctx, manager->events,
4623 isc_mem_put(mctx, manager->events,
6182 * Run through the list of events on this socket, and cancel the ones
6482 manager->events, manager->nevents,
6491 manager->events,
6506 dvp.dp_fds = manager->events;
6561 (void)process_fds(manager, manager->events, swait->nevents);