Home
last modified time | relevance | path

Searched refs:watchers (Results 1 - 25 of 31) sorted by relevance

12

/third_party/node/deps/uv/src/unix/
H A Dlinux-inotify.c38 QUEUE watchers; member
87 /* Open the inotify_fd, and re-arm all the inotify watchers. */ in uv__inotify_fork()
103 QUEUE_INIT(&tmp_watcher_list.watchers); in uv__inotify_fork()
112 QUEUE_MOVE(&watcher_list->watchers, &queue); in uv__inotify_fork()
115 handle = QUEUE_DATA(q, uv_fs_event_t, watchers); in uv__inotify_fork()
123 QUEUE_INSERT_TAIL(&watcher_list->watchers, q); in uv__inotify_fork()
126 QUEUE_INSERT_TAIL(&tmp_watcher_list.watchers, &handle->watchers); in uv__inotify_fork()
133 QUEUE_MOVE(&tmp_watcher_list.watchers, &queue); in uv__inotify_fork()
137 handle = QUEUE_DATA(q, uv_fs_event_t, watchers); in uv__inotify_fork()
[all...]
H A Depoll.c55 assert(loop->watchers != NULL); in uv__platform_invalidate_fd()
58 events = (struct epoll_event*) loop->watchers[loop->nwatchers]; in uv__platform_invalidate_fd()
59 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd()
308 uv__io_t* watchers; in uv__io_poll() member
312 assert(loop->watchers != NULL); in uv__io_poll()
313 loop->watchers[loop->nwatchers] = x.watchers; in uv__io_poll()
314 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds; in uv__io_poll()
328 w = loop->watchers[fd]; in uv__io_poll()
367 /* Run signal watchers las in uv__io_poll()
[all...]
H A Dloop.c60 loop->watchers = NULL; in uv_loop_init()
126 uv__free(loop->watchers); in uv_loop_init()
149 /* Rearm all the watchers that aren't re-queued by the above. */ in uv_loop_fork()
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 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 Dkqueue.c283 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()
307 w = loop->watchers[fd]; in uv__io_poll()
383 /* Run signal watchers last. This also affects child process watchers in uv__io_poll()
384 * because those are implemented in terms of signal watchers. 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()
449 assert(loop->watchers ! in uv__platform_invalidate_fd()
[all...]
H A Dcore.c827 uv__io_t** watchers; in maybe_resize() local
836 /* Preserve fake watcher list and count at the end of the watchers */ in maybe_resize()
837 if (loop->watchers != NULL) { in maybe_resize()
838 fake_watcher_list = loop->watchers[loop->nwatchers]; in maybe_resize()
839 fake_watcher_count = loop->watchers[loop->nwatchers + 1]; in maybe_resize()
846 watchers = uv__reallocf(loop->watchers, in maybe_resize()
847 (nwatchers + 2) * sizeof(loop->watchers[0])); in maybe_resize()
849 if (watchers == NULL) in maybe_resize()
852 watchers[ in maybe_resize()
[all...]
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()
303 /* Run signal watchers last. This also affects child process watchers in uv__io_poll()
304 * because those are implemented in terms of signal watchers in uv__io_poll()
[all...]
H A Daix.c283 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()
299 w = loop->watchers[pc.fd]; in uv__io_poll()
311 /* Run signal watchers last. This also affects child process watchers in uv__io_poll()
312 * because those are implemented in terms of signal watchers. in uv__io_poll()
334 loop->watchers[loop->nwatchers] = NULL; in uv__io_poll()
335 loop->watchers[loop->nwatchers + 1] = NULL; in uv__io_poll()
1286 assert(loop->watchers ! in uv__platform_invalidate_fd()
[all...]
H A Dos390.c586 assert(loop->watchers != NULL); in uv__platform_invalidate_fd()
589 events = (struct epoll_event*) loop->watchers[loop->nwatchers]; in uv__platform_invalidate_fd()
590 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd()
944 assert(loop->watchers != NULL); in uv__io_poll()
945 loop->watchers[loop->nwatchers] = (void*) events; in uv__io_poll()
946 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds; in uv__io_poll()
965 w = loop->watchers[fd]; in uv__io_poll()
988 /* Run signal watchers last. This also affects child process watchers in uv__io_poll()
989 * because those are implemented in terms of signal watchers in uv__io_poll()
[all...]
/third_party/node/test/parallel/
H A Dtest-fs-watch-encoding.js8 // directory might trigger an event on the watchers that are instantiated after
31 const watchers = new Set();
34 watchers.add(watcher);
39 watchers.delete(watcher);
40 if (watchers.size === 0) {
85 const done = common.mustCall(unregisterWatcher, watchers.size);
/third_party/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 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()
378 /* Run signal watchers last. This also affects child process watchers in uv__io_poll()
379 * because those are implemented in terms of signal watchers. 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 ! in uv__platform_invalidate_fd()
[all...]
H A Dloop.c72 loop->watchers = NULL; in uv_loop_init()
136 uv__free(loop->watchers); in uv_loop_init()
159 /* Rearm all the watchers that aren't re-queued by the above. */ in uv_loop_fork()
161 w = loop->watchers[i]; in uv_loop_fork()
217 uv__free(loop->watchers); in uv__loop_close()
218 loop->watchers = NULL; in uv__loop_close()
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()
303 /* Run signal watchers last. This also affects child process watchers in uv__io_poll()
304 * because those are implemented in terms of signal watchers in uv__io_poll()
[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()
1004 /* Run signal watchers last. This also affects child process watchers in uv__io_poll()
1005 * because those are implemented in terms of signal watchers in uv__io_poll()
[all...]
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()
320 /* Run signal watchers last. This also affects child process watchers in uv__io_poll()
321 * because those are implemented in terms of signal watchers. 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 ! in uv__platform_invalidate_fd()
[all...]
H A Dcore.c883 uv__io_t** watchers; in maybe_resize() local
892 /* Preserve fake watcher list and count at the end of the watchers */ in maybe_resize()
893 if (loop->watchers != NULL) { in maybe_resize()
894 fake_watcher_list = loop->watchers[loop->nwatchers]; in maybe_resize()
895 fake_watcher_count = loop->watchers[loop->nwatchers + 1]; in maybe_resize()
902 watchers = uv__reallocf(loop->watchers, in maybe_resize()
903 (nwatchers + 2) * sizeof(loop->watchers[0])); in maybe_resize()
905 if (watchers == NULL) in maybe_resize()
908 watchers[ in maybe_resize()
[all...]
H A Dlinux.c284 struct uv__queue watchers; member
1544 w = loop->watchers[fd]; in uv__io_poll()
1583 /* Run signal watchers last. This also affects child process watchers in uv__io_poll()
1584 * because those are implemented in terms of signal watchers. in uv__io_poll()
2379 /* Open the inotify_fd, and re-arm all the inotify watchers. */ in uv__inotify_fork()
2397 uv__queue_init(&tmp_watcher_list.watchers); in uv__inotify_fork()
2406 uv__queue_move(&watcher_list->watchers, &queue); in uv__inotify_fork()
2409 handle = uv__queue_data(q, uv_fs_event_t, watchers); in uv__inotify_fork()
2417 uv__queue_insert_tail(&watcher_list->watchers, in uv__inotify_fork()
[all...]
H A Dposix-poll.c158 /* Take queued watchers and add their fds to our poll fds array. */ in uv__io_poll()
278 w = loop->watchers[fd]; in uv__io_poll()
292 /* Run signal watchers last. */ in uv__io_poll()
/third_party/node/deps/uv/include/uv/
H A Dlinux.h31 void* watchers[2]; \
/third_party/libuv/include/uv/
H A Dlinux.h31 struct uv__queue watchers; \
H A Dunix.h226 uv__io_t** watchers; \
/third_party/libuv/test/
H A Dtest-fs-event.c663 uv_fs_event_t watchers[2]; in TEST_IMPL() local
668 timer.data = watchers; in TEST_IMPL()
670 ASSERT_OK(uv_fs_event_init(loop, watchers + 0)); in TEST_IMPL()
671 ASSERT_OK(uv_fs_event_start(watchers + 0, fail_cb, path, 0)); in TEST_IMPL()
672 ASSERT_OK(uv_fs_event_init(loop, watchers + 1)); in TEST_IMPL()
673 ASSERT_OK(uv_fs_event_start(watchers + 1, fail_cb, path, 0)); in TEST_IMPL()
/third_party/node/lib/
H A Dfs.js2400 * @returns {watchers.FSWatcher}
2416 const watchers = require('internal/fs/watchers');
2417 const watcher = new watchers.FSWatcher();
2418 watcher[watchers.kFSWatchStart](filename,
2456 * @returns {watchers.StatWatcher}
2480 const watchers = require('internal/fs/watchers');
2482 stat = new watchers.StatWatcher(options.bigint);
2483 stat[watchers
[all...]
/third_party/node/lib/internal/debugger/
H A Dinspect_repl.js95 watchers Print all watched expressions and their current values
675 function watchers(verbose = false) {
1077 get watchers() {
1078 return watchers();

Completed in 26 milliseconds

12