48 static void uv__fs_event(uv_loop_t* loop, uv__io_t* w, unsigned int fflags);
51 int uv__kqueue_init(uv_loop_t* loop) {  in uv__kqueue_init()  argument
52   loop->backend_fd = kqueue();  in uv__kqueue_init()
53   if (loop->backend_fd == -1)  in uv__kqueue_init()
56   uv__cloexec(loop->backend_fd, 1);  in uv__kqueue_init()
66 int uv__io_fork(uv_loop_t* loop) {  in uv__io_fork()  argument
68   loop->backend_fd = -1;  in uv__io_fork()
69   err = uv__kqueue_init(loop);  in uv__io_fork()
74   if (loop->cf_state != NULL) {  in uv__io_fork()
86     uv__free(loop->cf_state);  in uv__io_fork()
87     loop->cf_state = NULL;  in uv__io_fork()
94 int uv__io_check_fd(uv_loop_t* loop, int fd) {  in uv__io_check_fd()  argument
100   if (kevent(loop->backend_fd, &ev, 1, NULL, 0, NULL))  in uv__io_check_fd()
105     if (kevent(loop->backend_fd, &ev, 1, NULL, 0, NULL))  in uv__io_check_fd()
112 void uv__io_poll(uv_loop_t* loop, int timeout) {  in uv__io_poll()  argument
136   if (loop->nfds == 0) {  in uv__io_poll()
137     assert(QUEUE_EMPTY(&loop->watcher_queue));  in uv__io_poll()
143   while (!QUEUE_EMPTY(&loop->watcher_queue)) {  in uv__io_poll()
144     q = QUEUE_HEAD(&loop->watcher_queue);  in uv__io_poll()
151     assert(w->fd < (int) loop->nwatchers);  in uv__io_poll()
168         if (kevent(loop->backend_fd, events, nevents, NULL, 0, NULL))  in uv__io_poll()
178         if (kevent(loop->backend_fd, events, nevents, NULL, 0, NULL))  in uv__io_poll()
188         if (kevent(loop->backend_fd, events, nevents, NULL, 0, NULL))  in uv__io_poll()
198   if (loop->flags & UV_LOOP_BLOCK_SIGPROF) {  in uv__io_poll()
205   base = loop->time;  in uv__io_poll()
208   if (uv__get_internal_fields(loop)->flags & UV_METRICS_IDLE_TIME) {  in uv__io_poll()
221       uv__metrics_set_provider_entry_time(loop);  in uv__io_poll()
231     nfds = kevent(loop->backend_fd,  in uv__io_poll()
245     SAVE_ERRNO(uv__update_time(loop));  in uv__io_poll()
283     assert(loop->watchers != NULL);  in uv__io_poll()
284     loop->watchers[loop->nwatchers] = (void*) events;  in uv__io_poll()
285     loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds;  in uv__io_poll()
292         QUEUE_FOREACH(q, &loop->process_handles) {  in uv__io_poll()
296             loop->flags |= UV_LOOP_REAP_CHILDREN;  in uv__io_poll()
307       w = loop->watchers[fd];  in uv__io_poll()
315         if (kevent(loop->backend_fd, events, 1, NULL, 0, NULL))  in uv__io_poll()
325         uv__metrics_update_idle_time(loop);  in uv__io_poll()
326         w->cb(loop, w, ev->fflags); /* XXX always uv__fs_event() */  in uv__io_poll()
341           if (kevent(loop->backend_fd, events, 1, NULL, 0, NULL))  in uv__io_poll()
357           if (kevent(loop->backend_fd, events, 1, NULL, 0, NULL))  in uv__io_poll()
371           if (kevent(loop->backend_fd, events, 1, NULL, 0, NULL))  in uv__io_poll()
386       if (w == &loop->signal_io_watcher) {  in uv__io_poll()
389         uv__metrics_update_idle_time(loop);  in uv__io_poll()
390         w->cb(loop, w, revents);  in uv__io_poll()
396     if (loop->flags & UV_LOOP_REAP_CHILDREN) {  in uv__io_poll()
397       loop->flags &= ~UV_LOOP_REAP_CHILDREN;  in uv__io_poll()
398       uv__wait_children(loop);  in uv__io_poll()
407       uv__metrics_update_idle_time(loop);  in uv__io_poll()
408       loop->signal_io_watcher.cb(loop, &loop->signal_io_watcher, POLLIN);  in uv__io_poll()
411     loop->watchers[loop->nwatchers] = NULL;  in uv__io_poll()
412     loop->watchers[loop->nwatchers + 1] = NULL;  in uv__io_poll()
435     diff = loop->time - base;  in uv__io_poll()
444 void uv__platform_invalidate_fd(uv_loop_t* loop, int fd) {  in uv__platform_invalidate_fd()  argument
449   assert(loop->watchers != NULL);  in uv__platform_invalidate_fd()
452   events = (struct kevent*) loop->watchers[loop->nwatchers];  in uv__platform_invalidate_fd()
453   nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1];  in uv__platform_invalidate_fd()
464 static void uv__fs_event(uv_loop_t* loop, uv__io_t* w, unsigned int fflags) {  in uv__fs_event()  argument
501   if (kevent(loop->backend_fd, &ev, 1, NULL, 0, NULL))  in uv__fs_event()
506 int uv_fs_event_init(uv_loop_t* loop, uv_fs_event_t* handle) {  in uv_fs_event_init()  argument
507   uv__handle_init(loop, (uv_handle_t*)handle, UV_FS_EVENT);  in uv_fs_event_init()
569   uv__io_start(handle->loop, &handle->event_watcher, POLLIN);  in uv_fs_event_start()
591     uv__io_close(handle->loop, &handle->event_watcher);  in uv_fs_event_stop()