libs/bsd/kqueue.cpp

49 	BStackOrHeapArray<event_wait_info, 16> waitInfos(max_c(nchanges, nevents));
51 	event_wait_info* waitInfo = waitInfos;
152 		status_t status = _kern_event_queue_select(kq, waitInfos, changedInfos);
156 				__set_errno(waitInfos[0].events);
163 				if (waitInfos[i].events > 0)
168 				short filter = filter_from_info(waitInfos[i]);
169 				int64_t data = waitInfos[i].events;
170 				EV_SET(eventlist, waitInfos[i].object,
171 					filter, EV_ERROR, 0, data, waitInfos[i].user_data);
191 		ssize_t events = _kern_event_queue_wait(kq, waitInfos,
200 				if (waitInfos[i].events < 0) {
202 					data = waitInfos[i].events;
203 				} else if ((waitInfos[i].events & B_EVENT_DISCONNECTED) != 0) {
205 				} else if ((waitInfos[i].events & B_EVENT_INVALID) != 0) {
206 					switch (waitInfos[i].type) {
215 							status_t status = wait_for_thread(waitInfos[i].object, &returnValue);
223 				} else if ((waitInfos[i].events & B_EVENT_ERROR) != 0) {
228 				short filter = filter_from_info(waitInfos[i]);
229 				if (waitInfos[i].type == B_OBJECT_TYPE_FD && (flags & (EV_ERROR | EV_EOF)) == 0) {
231 					if ((waitInfos[i].events & (B_EVENT_READ | B_EVENT_WRITE))
235 							EV_SET(eventlist, waitInfos[i].object,
236 								EVFILT_WRITE, flags, fflags, data, waitInfos[i].user_data);
245 				EV_SET(eventlist, waitInfos[i].object,
246 					filter, flags, fflags, data, waitInfos[i].user_data);