Home
last modified time | relevance | path

Searched refs:watchers (Results 1 – 18 of 18) sorted by relevance

/libuv/src/unix/
H A Dpoll.c120 uv__io_t** watchers; in uv_poll_start() local
128 watchers = handle->loop->watchers; in uv_poll_start()
132 if (watchers[w->fd] != w) in uv_poll_start()
H A Dloop.c63 loop->watchers = NULL; in uv_loop_init()
126 uv__free(loop->watchers); in uv_loop_init()
151 w = loop->watchers[i]; in uv_loop_fork()
200 uv__free(loop->watchers); in uv__loop_close()
201 loop->watchers = NULL; in uv__loop_close()
H A Dkqueue.c305 assert(loop->watchers != NULL); in uv__io_poll()
306 loop->watchers[loop->nwatchers] = (void*) events; in uv__io_poll()
307 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds; in uv__io_poll()
329 w = loop->watchers[fd]; in uv__io_poll()
408 loop->watchers[loop->nwatchers] = NULL; in uv__io_poll()
409 loop->watchers[loop->nwatchers + 1] = NULL; in uv__io_poll()
446 assert(loop->watchers != NULL); in uv__platform_invalidate_fd()
449 events = (struct kevent*) loop->watchers[loop->nwatchers]; in uv__platform_invalidate_fd()
450 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd()
H A Dsunos.c119 assert(loop->watchers != NULL); in uv__platform_invalidate_fd()
122 events = (struct port_event*) loop->watchers[loop->nwatchers]; in uv__platform_invalidate_fd()
123 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd()
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()
297 w = loop->watchers[fd]; in uv__io_poll()
315 if (w != loop->watchers[fd]) in uv__io_poll()
335 loop->watchers[loop->nwatchers] = NULL; in uv__io_poll()
336 loop->watchers[loop->nwatchers + 1] = NULL; in uv__io_poll()
H A Dcore.c859 uv__io_t** watchers; in maybe_resize() local
869 if (loop->watchers != NULL) { in maybe_resize()
878 watchers = uv__reallocf(loop->watchers, in maybe_resize()
881 if (watchers == NULL) in maybe_resize()
884 watchers[i] = NULL; in maybe_resize()
885 watchers[nwatchers] = fake_watcher_list; in maybe_resize()
888 loop->watchers = watchers; in maybe_resize()
926 if (loop->watchers[w->fd] == NULL) { in uv__io_start()
927 loop->watchers[w->fd] = w; in uv__io_start()
953 if (w == loop->watchers[w->fd]) { in uv__io_stop()
[all …]
H A Dos390.c593 assert(loop->watchers != NULL); in uv__platform_invalidate_fd()
596 events = (struct epoll_event*) loop->watchers[loop->nwatchers]; in uv__platform_invalidate_fd()
597 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd()
960 assert(loop->watchers != NULL); in uv__io_poll()
961 loop->watchers[loop->nwatchers] = (void*) events; in uv__io_poll()
962 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds; in uv__io_poll()
981 w = loop->watchers[fd]; in uv__io_poll()
1029 loop->watchers[loop->nwatchers] = NULL; in uv__io_poll()
1030 loop->watchers[loop->nwatchers + 1] = NULL; in uv__io_poll()
H A Daix.c292 assert(loop->watchers != NULL); in uv__io_poll()
293 loop->watchers[loop->nwatchers] = (void*) events; in uv__io_poll()
294 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds; in uv__io_poll()
308 w = loop->watchers[pc.fd]; in uv__io_poll()
345 loop->watchers[loop->nwatchers] = NULL; in uv__io_poll()
346 loop->watchers[loop->nwatchers + 1] = NULL; in uv__io_poll()
1302 assert(loop->watchers != NULL); in uv__platform_invalidate_fd()
1305 events = (struct pollfd*) loop->watchers[loop->nwatchers]; in uv__platform_invalidate_fd()
1306 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd()
H A Dlinux.c261 struct uv__queue watchers; member
1485 w = loop->watchers[fd]; in uv__io_poll()
2451 uv__queue_init(&tmp_watcher_list.watchers); in uv__inotify_fork()
2460 uv__queue_move(&watcher_list->watchers, &queue); in uv__inotify_fork()
2474 uv__queue_insert_tail(&tmp_watcher_list.watchers, &handle->watchers); in uv__inotify_fork()
2481 uv__queue_move(&tmp_watcher_list.watchers, &queue); in uv__inotify_fork()
2574 uv__queue_move(&w->watchers, &queue); in uv__inotify_read()
2580 uv__queue_insert_tail(&w->watchers, q); in uv__inotify_read()
2642 uv__queue_init(&w->watchers); in uv_fs_event_start()
2648 uv__queue_insert_tail(&w->watchers, &handle->watchers); in uv_fs_event_start()
[all …]
H A Dposix-poll.c278 w = loop->watchers[fd]; in uv__io_poll()
/libuv/include/uv/
H A Dlinux.h31 struct uv__queue watchers; \
H A Dunix.h225 uv__io_t** watchers; \
/libuv/test/
H A Dtest-fs-event.c664 uv_fs_event_t watchers[2]; in TEST_IMPL() local
669 timer.data = watchers; in TEST_IMPL()
671 ASSERT_OK(uv_fs_event_init(loop, watchers + 0)); in TEST_IMPL()
672 ASSERT_OK(uv_fs_event_start(watchers + 0, fail_cb, path, 0)); in TEST_IMPL()
673 ASSERT_OK(uv_fs_event_init(loop, watchers + 1)); in TEST_IMPL()
674 ASSERT_OK(uv_fs_event_start(watchers + 1, fail_cb, path, 0)); in TEST_IMPL()
/libuv/docs/src/
H A Dsignal.rst53 manage threads. Installing watchers for those signals will lead to unpredictable behavior
H A Dloop.rst188 Previously started watchers will continue to be started in the
/libuv/docs/src/guide/
H A Dbasics.rst144 .. rubric:: libuv watchers
217 event watchers are active.
H A Dutilities.rst80 other watchers are done. In that case just unref the timer immediately after
85 the JS API. A ``uv_handle_t`` (the superclass of all watchers) is created per
303 Check & Prepare watchers
H A Dfilesystem.rst13 watchers registered with the event loop when application interaction is
/libuv/
H A DChangeLog3058 * unix: make loops and watchers usable after fork() (Jason Madden)
5515 * fsevents: share FSEventStream between multiple FS watchers, which removes a
5516 limit on the maximum number of file watchers that can be created on OS X.
5536 * fsevents: share FSEventStream between multiple FS watchers, which removes a
5537 limit on the maximum number of file watchers that can be created on OS X.

Completed in 102 milliseconds