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.c332 assert(loop->watchers != NULL); in uv__io_poll()
333 loop->watchers[loop->nwatchers] = (void*) events; in uv__io_poll()
334 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds; in uv__io_poll()
356 w = loop->watchers[fd]; in uv__io_poll()
446 loop->watchers[loop->nwatchers] = NULL; in uv__io_poll()
447 loop->watchers[loop->nwatchers + 1] = NULL; in uv__io_poll()
484 assert(loop->watchers != NULL); in uv__platform_invalidate_fd()
487 events = (struct kevent*) loop->watchers[loop->nwatchers]; in uv__platform_invalidate_fd()
488 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.c869 uv__io_t** watchers; in maybe_resize() local
879 if (loop->watchers != NULL) { in maybe_resize()
888 watchers = uv__reallocf(loop->watchers, in maybe_resize()
891 if (watchers == NULL) in maybe_resize()
894 watchers[i] = NULL; in maybe_resize()
895 watchers[nwatchers] = fake_watcher_list; in maybe_resize()
898 loop->watchers = watchers; in maybe_resize()
936 if (loop->watchers[w->fd] == NULL) { in uv__io_start()
937 loop->watchers[w->fd] = w; in uv__io_start()
963 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.c259 struct uv__queue watchers; member
1514 w = loop->watchers[fd]; in uv__io_poll()
2480 uv__queue_init(&tmp_watcher_list.watchers); in uv__inotify_fork()
2489 uv__queue_move(&watcher_list->watchers, &queue); in uv__inotify_fork()
2503 uv__queue_insert_tail(&tmp_watcher_list.watchers, &handle->watchers); in uv__inotify_fork()
2510 uv__queue_move(&tmp_watcher_list.watchers, &queue); in uv__inotify_fork()
2603 uv__queue_move(&w->watchers, &queue); in uv__inotify_read()
2609 uv__queue_insert_tail(&w->watchers, q); in uv__inotify_read()
2671 uv__queue_init(&w->watchers); in uv_fs_event_start()
2677 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.c730 uv_fs_event_t watchers[2]; in TEST_IMPL() local
735 timer.data = watchers; in TEST_IMPL()
737 ASSERT_OK(uv_fs_event_init(loop, watchers + 0)); in TEST_IMPL()
738 ASSERT_OK(uv_fs_event_start(watchers + 0, fail_cb, path, 0)); in TEST_IMPL()
739 ASSERT_OK(uv_fs_event_init(loop, watchers + 1)); in TEST_IMPL()
740 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.rst206 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 DChangeLog3309 * unix: make loops and watchers usable after fork() (Jason Madden)
5766 * fsevents: share FSEventStream between multiple FS watchers, which removes a
5767 limit on the maximum number of file watchers that can be created on OS X.
5787 * fsevents: share FSEventStream between multiple FS watchers, which removes a
5788 limit on the maximum number of file watchers that can be created on OS X.

Completed in 290 milliseconds