kernel/events/wait_for_objects.cpp

25 #include <fs/fd.h>
230 						fEntries[i].fd = fds->fd;
261 					out.Print("<%u: ", fEntries[i].fd);
264 					out.Print(", <%u: ", fEntries[i].fd);
283 			uint16	fd;
443 	int fd;
451 	for (fd = 0; fd < numFDs; fd++) {
452 		if (((readSet && FD_ISSET(fd, readSet))
453 			|| (writeSet && FD_ISSET(fd, writeSet))
454 			|| (errorSet && FD_ISSET(fd, errorSet)))
455 			&& !fd_is_valid(fd, kernel))
469 	for (fd = 0; fd < numFDs; fd++) {
470 		sync->set[fd].selected_events = 0;
471 		sync->set[fd].events = 0;
473 		if (readSet && FD_ISSET(fd, readSet)) {
474 			sync->set[fd].selected_events = SELECT_FLAG(B_SELECT_READ)
477 		if (writeSet && FD_ISSET(fd, writeSet)) {
478 			sync->set[fd].selected_events |= SELECT_FLAG(B_SELECT_WRITE)
481 		if (errorSet && FD_ISSET(fd, errorSet))
482 			sync->set[fd].selected_events |= SELECT_FLAG(B_SELECT_ERROR);
484 		if (sync->set[fd].selected_events != 0) {
485 			select_fd(fd, sync->set + fd, kernel);
486 				// array position is the same as the fd for select()
513 	for (fd = 0; fd < numFDs; fd++)
514 		deselect_fd(fd, sync->set + fd, kernel);
538 		for (count = 0, fd = 0;fd < numFDs; fd++) {
539 			if (readSet && sync->set[fd].events & (SELECT_FLAG(B_SELECT_READ)
541 				FD_SET(fd, readSet);
545 				&& sync->set[fd].events & (SELECT_FLAG(B_SELECT_WRITE)
547 				FD_SET(fd, writeSet);
551 				&& sync->set[fd].events & SELECT_FLAG(B_SELECT_ERROR)) {
552 				FD_SET(fd, errorSet);
584 		int fd = fds[i].fd;
592 		if (fd >= 0 && select_fd(fd, sync->set + i, kernel) != B_OK) {
623 		if (fds[i].fd >= 0 && (fds[i].revents & POLLNVAL) == 0)
624 			deselect_fd(fds[i].fd, sync->set + i, kernel);
633 				if (fds[i].fd < 0)