Lines Matching defs:loop
81 int uv__platform_loop_init(uv_loop_t* loop) {
82 loop->fs_fd = -1;
86 loop->backend_fd = pollset_create(-1);
88 if (loop->backend_fd == -1)
95 void uv__platform_loop_delete(uv_loop_t* loop) {
96 if (loop->fs_fd != -1) {
97 uv__close(loop->fs_fd);
98 loop->fs_fd = -1;
101 if (loop->backend_fd != -1) {
102 pollset_destroy(loop->backend_fd);
103 loop->backend_fd = -1;
108 int uv__io_fork(uv_loop_t* loop) {
109 uv__platform_loop_delete(loop);
111 return uv__platform_loop_init(loop);
115 int uv__io_check_fd(uv_loop_t* loop, int fd) {
122 if (pollset_ctl(loop->backend_fd, &pc, 1))
126 if (pollset_ctl(loop->backend_fd, &pc, 1))
133 void uv__io_poll(uv_loop_t* loop, int timeout) {
152 if (loop->nfds == 0) {
153 assert(QUEUE_EMPTY(&loop->watcher_queue));
157 while (!QUEUE_EMPTY(&loop->watcher_queue)) {
158 q = QUEUE_HEAD(&loop->watcher_queue);
165 assert(w->fd < (int) loop->nwatchers);
173 if (pollset_ctl(loop->backend_fd, &pc, 1)) {
180 rc = pollset_query(loop->backend_fd, &pqry);
202 if (pollset_ctl(loop->backend_fd, &pc, 1)) {
207 if (pollset_ctl(loop->backend_fd, &pc, 1)) {
217 base = loop->time;
220 if (uv__get_internal_fields(loop)->flags & UV_METRICS_IDLE_TIME) {
230 * will return early if the loop isn't configured with UV_METRICS_IDLE_TIME.
233 uv__metrics_set_provider_entry_time(loop);
235 nfds = pollset_poll(loop->backend_fd,
240 /* Update loop->time unconditionally. It's tempting to skip the update when
244 SAVE_ERRNO(uv__update_time(loop));
283 assert(loop->watchers != NULL);
284 loop->watchers[loop->nwatchers] = (void*) events;
285 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds;
297 assert((unsigned) pc.fd < loop->nwatchers);
299 w = loop->watchers[pc.fd];
307 pollset_ctl(loop->backend_fd, &pc, 1);
314 if (w == &loop->signal_io_watcher) {
317 uv__metrics_update_idle_time(loop);
318 w->cb(loop, w, pe->revents);
330 uv__metrics_update_idle_time(loop);
331 loop->signal_io_watcher.cb(loop, &loop->signal_io_watcher, POLLIN);
334 loop->watchers[loop->nwatchers] = NULL;
335 loop->watchers[loop->nwatchers + 1] = NULL;
338 return; /* Event loop should cycle now so don't poll again. */
358 diff = loop->time - base;
703 static void uv__ahafs_event(uv_loop_t* loop, uv__io_t* event_watch, unsigned int fflags) {
757 int uv_fs_event_init(uv_loop_t* loop, uv_fs_event_t* handle) {
759 uv__handle_init(loop, (uv_handle_t*)handle, UV_FS_EVENT);
820 uv__io_start(handle->loop, &handle->event_watcher, POLLIN);
824 * eventuality of an event that occurs in the current loop. */
843 uv__io_close(handle->loop, &handle->event_watcher);
1195 /* All conditions above must match count loop */
1280 void uv__platform_invalidate_fd(uv_loop_t* loop, int fd) {
1286 assert(loop->watchers != NULL);
1289 events = (struct pollfd*) loop->watchers[loop->nwatchers];
1290 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1];
1302 if(loop->backend_fd >= 0)
1303 pollset_ctl(loop->backend_fd, &pc, 1);