kernel/events/wait_for_objects.cpp

69 	struct select_info*	set;
131 		void _PrintSet(TraceOutput& out, const char* name, fd_set* set)
136 			if (set != NULL) {
139 					if (!FD_ISSET(i, set))
356 fd_zero(fd_set *set, int numFDs)
358 	if (set != NULL)
359 		memset(set, 0, _howmany(numFDs, NFDBITS) * sizeof(fd_mask));
372 	// create info set
373 	sync->set = new(nothrow) select_info[numFDs];
374 	if (sync->set == NULL)
376 	ArrayDeleter<select_info> setDeleter(sync->set);
386 		sync->set[i].next = NULL;
387 		sync->set[i].sync = sync;
417 	delete[] set;
470 		sync->set[fd].selected_events = 0;
471 		sync->set[fd].events = 0;
474 			sync->set[fd].selected_events = SELECT_FLAG(B_SELECT_READ)
478 			sync->set[fd].selected_events |= SELECT_FLAG(B_SELECT_WRITE)
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);
490 	// set new signal mask
514 		deselect_fd(fd, sync->set + fd, kernel);
539 			if (readSet && sync->set[fd].events & (SELECT_FLAG(B_SELECT_READ)
545 				&& sync->set[fd].events & (SELECT_FLAG(B_SELECT_WRITE)
551 				&& sync->set[fd].events & SELECT_FLAG(B_SELECT_ERROR)) {
587 		sync->set[i].selected_events = fds[i].events
589 		sync->set[i].events = 0;
592 		if (fd >= 0 && select_fd(fd, sync->set + i, kernel) != B_OK) {
593 			sync->set[i].events = POLLNVAL;
600 	// set new signal mask
624 			deselect_fd(fds[i].fd, sync->set + i, kernel);
637 				fds[i].revents = sync->set[i].events
638 					& sync->set[i].selected_events;
679 		sync->set[i].selected_events = infos[i].events
681 		sync->set[i].events = 0;
684 		if (select_object(type, object, sync->set + i, kernel) != B_OK) {
685 			sync->set[i].events = B_EVENT_INVALID;
703 			deselect_object(type, infos[i].object, sync->set + i, kernel);
711 			infos[i].events = sync->set[i].events
712 				& sync->set[i].selected_events;