isc/unix/socket.c

179  * during intermittent events or the kernel bug is triggered.  If the next
207  * Maximum number of events communicated with the kernel.  There should normally
241  * DLVL(70)  --  Socket "correctness" -- including returning of events, etc.
243  * DLVL(50)  --  Event tracing, including receiving/sending completion events.
322 	 * Internal events.  Posted when a descriptor is readable or
368 	struct kevent		*events;
373 	struct epoll_event	*events;
378 	struct pollfd		*events;
826 		event.events = EPOLLIN;
828 		event.events = EPOLLOUT;
843 		pfd.events = POLLIN;
845 		pfd.events = POLLOUT;
894 		event.events = EPOLLIN;
896 		event.events = EPOLLOUT;
914 	pfds[0].events = POLLREMOVE;
925 		pfds[1].events = POLLOUT;
931 		pfds[1].events = POLLIN;
2134 	 * Initialize readable and writable events
2981 	 * Are there any done events left, or were they all canceled
3363 			 * the events with an EOF result code.
3599 process_fds(isc__socketmgr_t *manager, struct kevent *events, int nevents) {
3615 			    "maximum number of FD events (%d) received",
3620 		REQUIRE(events[i].ident < manager->maxsocks);
3622 		if (events[i].ident == (uintptr_t)manager->pipe_fds[0]) {
3627 		readable = ISC_TF(events[i].filter == EVFILT_READ);
3628 		writable = ISC_TF(events[i].filter == EVFILT_WRITE);
3629 		process_fd(manager, events[i].ident, readable, writable);
3641 process_fds(isc__socketmgr_t *manager, struct epoll_event *events, int nevents)
3652 			    "maximum number of FD events (%d) received",
3657 		REQUIRE(events[i].data.fd < (int)manager->maxsocks);
3659 		if (events[i].data.fd == manager->pipe_fds[0]) {
3664 		if ((events[i].events & EPOLLERR) != 0 ||
3665 		    (events[i].events & EPOLLHUP) != 0) {
3670 			 * events.  Note also that the read or write attempt
3673 			events[i].events |= (EPOLLIN | EPOLLOUT);
3675 		process_fd(manager, events[i].data.fd,
3676 			   (events[i].events & EPOLLIN) != 0,
3677 			   (events[i].events & EPOLLOUT) != 0);
3689 process_fds(isc__socketmgr_t *manager, struct pollfd *events, int nevents) {
3699 			    "maximum number of FD events (%d) received",
3704 		REQUIRE(events[i].fd < (int)manager->maxsocks);
3706 		if (events[i].fd == manager->pipe_fds[0]) {
3711 		process_fd(manager, events[i].fd,
3712 			   (events[i].events & POLLIN) != 0,
3713 			   (events[i].events & POLLOUT) != 0);
3824 				    manager->events, manager->nevents, NULL);
3826 			cc = epoll_wait(manager->epoll_fd, manager->events,
3829 			dvp.dp_fds = manager->events;
3891 		done = process_fds(manager, manager->events, cc);
3945 	manager->events = isc_mem_get(mctx, sizeof(struct kevent) *
3947 	if (manager->events == NULL)
3958 		isc_mem_put(mctx, manager->events,
3967 		isc_mem_put(mctx, manager->events,
3974 	manager->events = isc_mem_get(mctx, sizeof(struct epoll_event) *
3976 	if (manager->events == NULL)
3987 		isc_mem_put(mctx, manager->events,
3995 		isc_mem_put(mctx, manager->events,
4002 	 * XXXJT: /dev/poll seems to reject large numbers of events,
4006 	manager->events = isc_mem_get(mctx, sizeof(struct pollfd) *
4008 	if (manager->events == NULL)
4017 		isc_mem_put(mctx, manager->events,
4031 		isc_mem_put(mctx, manager->events,
4041 		isc_mem_put(mctx, manager->events,
4122 	isc_mem_put(mctx, manager->events,
4126 	isc_mem_put(mctx, manager->events,
4130 	isc_mem_put(mctx, manager->events,
5572  * Run through the list of events on this socket, and cancel the ones
5795 				       manager->events, manager->nevents,
5804 					   manager->events,
5808 	dvp.dp_fds = manager->events;
5848 	(void)process_fds(manager, manager->events, swait->nevents);