Lines Matching refs:events
169 * during intermittent events or the kernel bug is triggered. If the next
197 * Maximum number of events communicated with the kernel. There should normally
231 * DLVL(70) -- Socket "correctness" -- including returning of events, etc.
233 * DLVL(50) -- Event tracing, including receiving/sending completion events.
307 * Internal events. Posted when a descriptor is readable or
352 struct kevent *events;
357 struct epoll_event *events;
362 struct pollfd *events;
657 event.events = EPOLLIN;
659 event.events = EPOLLOUT;
674 pfd.events = POLLIN;
676 pfd.events = POLLOUT;
725 event.events = EPOLLIN;
727 event.events = EPOLLOUT;
745 pfds[0].events = POLLREMOVE;
756 pfds[1].events = POLLOUT;
762 pfds[1].events = POLLIN;
1962 * Initialize readable and writable events.
2716 * Are there any done events left, or were they all canceled
3104 * the events with an EOF result code.
3338 process_fds(isc_socketmgr_t *manager, struct kevent *events, int nevents) {
3354 "maximum number of FD events (%d) received",
3359 REQUIRE(events[i].ident < manager->maxsocks);
3361 if (events[i].ident == (uintptr_t)manager->pipe_fds[0]) {
3366 readable = ISC_TF(events[i].filter == EVFILT_READ);
3367 writable = ISC_TF(events[i].filter == EVFILT_WRITE);
3368 process_fd(manager, events[i].ident, readable, writable);
3380 process_fds(isc_socketmgr_t *manager, struct epoll_event *events, int nevents) {
3390 "maximum number of FD events (%d) received",
3395 REQUIRE(events[i].data.fd < (int)manager->maxsocks);
3397 if (events[i].data.fd == manager->pipe_fds[0]) {
3402 if ((events[i].events & EPOLLERR) != 0 ||
3403 (events[i].events & EPOLLHUP) != 0) {
3408 * events. Note also that the read or write attempt
3411 events[i].events |= (EPOLLIN | EPOLLOUT);
3413 process_fd(manager, events[i].data.fd,
3414 (events[i].events & EPOLLIN) != 0,
3415 (events[i].events & EPOLLOUT) != 0);
3427 process_fds(isc_socketmgr_t *manager, struct pollfd *events, int nevents) {
3437 "maximum number of FD events (%d) received",
3442 REQUIRE(events[i].fd < (int)manager->maxsocks);
3444 if (events[i].fd == manager->pipe_fds[0]) {
3449 process_fd(manager, events[i].fd,
3450 (events[i].events & POLLIN) != 0,
3451 (events[i].events & POLLOUT) != 0);
3562 manager->events, manager->nevents, NULL);
3564 cc = epoll_wait(manager->epoll_fd, manager->events,
3567 dvp.dp_fds = manager->events;
3629 done = process_fds(manager, manager->events, cc);
3671 manager->events = isc_mem_get(mctx, sizeof(struct kevent) *
3673 if (manager->events == NULL)
3684 isc_mem_put(mctx, manager->events,
3693 isc_mem_put(mctx, manager->events,
3700 manager->events = isc_mem_get(mctx, sizeof(struct epoll_event) *
3702 if (manager->events == NULL)
3713 isc_mem_put(mctx, manager->events,
3721 isc_mem_put(mctx, manager->events,
3728 * XXXJT: /dev/poll seems to reject large numbers of events,
3732 manager->events = isc_mem_get(mctx, sizeof(struct pollfd) *
3734 if (manager->events == NULL)
3743 isc_mem_put(mctx, manager->events,
3757 isc_mem_put(mctx, manager->events,
3767 isc_mem_put(mctx, manager->events,
3848 isc_mem_put(mctx, manager->events,
3852 isc_mem_put(mctx, manager->events,
3856 isc_mem_put(mctx, manager->events,
5278 * Run through the list of events on this socket, and cancel the ones
5480 socketmgr->events, socketmgr->nevents,
5489 socketmgr->events,
5493 dvp.dp_fds = socketmgr->events;
5528 (void)process_fds(socketmgr, socketmgr->events, swait->nevents);