| /third_party/libuv/src/unix/ |
| D | linux-inotify.c | 38 QUEUE watchers; member
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()
159 if ((!w->iterating) && QUEUE_EMPTY(&w->watchers)) { in maybe_free_watcher_list()
225 QUEUE_MOVE(&w->watchers, &queue); in uv__inotify_read()
[all …]
|
| D | epoll.c | 55 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()
391 loop->watchers[loop->nwatchers] = NULL; in uv__io_poll()
392 loop->watchers[loop->nwatchers + 1] = NULL; in uv__io_poll()
|
| D | poll.c | 120 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()
|
| D | loop.c | 60 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()
|
| D | kqueue.c | 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()
307 w = loop->watchers[fd]; 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 != 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()
|
| D | core.c | 816 uv__io_t** watchers; in maybe_resize() local
826 if (loop->watchers != NULL) { in maybe_resize()
827 fake_watcher_list = loop->watchers[loop->nwatchers]; in maybe_resize()
828 fake_watcher_count = loop->watchers[loop->nwatchers + 1]; in maybe_resize()
835 watchers = uv__reallocf(loop->watchers, in maybe_resize()
836 (nwatchers + 2) * sizeof(loop->watchers[0])); in maybe_resize()
838 if (watchers == NULL) in maybe_resize()
841 watchers[i] = NULL; in maybe_resize()
842 watchers[nwatchers] = fake_watcher_list; in maybe_resize()
843 watchers[nwatchers + 1] = fake_watcher_count; in maybe_resize()
[all …]
|
| D | sunos.c | 119 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()
284 assert(loop->watchers != NULL); in uv__io_poll()
285 loop->watchers[loop->nwatchers] = (void*) events; in uv__io_poll()
286 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds; in uv__io_poll()
298 w = loop->watchers[fd]; in uv__io_poll()
316 if (w != loop->watchers[fd]) 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()
|
| D | os390.c | 494 assert(loop->watchers != NULL); in uv__platform_invalidate_fd()
497 events = (struct epoll_event*) loop->watchers[loop->nwatchers]; in uv__platform_invalidate_fd()
498 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd()
785 assert(loop->watchers != NULL); in uv__io_poll()
786 loop->watchers[loop->nwatchers] = (void*) events; in uv__io_poll()
787 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds; in uv__io_poll()
805 w = loop->watchers[fd]; in uv__io_poll()
833 loop->watchers[loop->nwatchers] = NULL; in uv__io_poll()
834 loop->watchers[loop->nwatchers + 1] = NULL; in uv__io_poll()
|
| D | aix.c | 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()
299 w = loop->watchers[pc.fd]; 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 != NULL); in uv__platform_invalidate_fd()
1289 events = (struct pollfd*) loop->watchers[loop->nwatchers]; in uv__platform_invalidate_fd()
1290 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd()
|
| /third_party/typescript/src/typingsInstallerCore/ |
| D | typingsInstaller.ts | 89 function getDetailWatchInfo(projectName: string, watchers: ProjectWatchers) {
90 return `Project: ${projectName} watcher already invoked: ${watchers.isInvoked}`;
135 const watchers = this.projectWatchers.get(projectName); constant
136 if (!watchers) {
142 clearMap(watchers, closeFileWatcher);
417 let watchers = this.projectWatchers.get(projectName)!;
419 if (!watchers) {
420 watchers = new Map();
421 this.projectWatchers.set(projectName, watchers);
424 copyEntries(watchers, toRemove);
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-fs-watch-encoding.js | 31 const watchers = new Set(); constant
34 watchers.add(watcher);
39 watchers.delete(watcher);
40 if (watchers.size === 0) {
85 const done = common.mustCall(unregisterWatcher, watchers.size);
|
| /third_party/grpc/src/csharp/Grpc.HealthCheck/ |
| D | HealthServiceImpl.cs | 51 private readonly Dictionary<string, List<ChannelWriter<HealthCheckResponse>>> watchers = field in Grpc.HealthCheck.HealthServiceImpl
174 … if (!watchers.TryGetValue(service, out List<ChannelWriter<HealthCheckResponse>> channelWriters)) in Watch()
177 watchers.Add(service, channelWriters); in Watch()
187 … if (watchers.TryGetValue(service, out List<ChannelWriter<HealthCheckResponse>> channelWriters)) in Watch()
195 watchers.Remove(service); in Watch()
224 … if (watchers.TryGetValue(service, out List<ChannelWriter<HealthCheckResponse>> channelWriters)) in NotifyStatus()
|
| /third_party/typescript_eslint/packages/typescript-estree/src/create-program/ |
| D | createWatchProgram.ts | 71 const watchers = ((): Set<ts.FileWatcherCallback> => { constant
72 let watchers = trackingMap.get(normalizedFileName);
73 if (!watchers) {
74 watchers = new Set();
75 trackingMap.set(normalizedFileName, watchers);
77 return watchers;
79 watchers.add(callback);
83 watchers.delete(callback);
|
| /third_party/grpc/src/core/ext/xds/ |
| D | xds_client.cc | 203 for (const auto& p : state.watchers) { in OnTimerLocked()
209 for (const auto& p : state.watchers) { in OnTimerLocked()
214 for (const auto& p : state.watchers) { in OnTimerLocked()
219 for (const auto& p : state.watchers) { in OnTimerLocked()
907 for (const auto& p : listener_state.watchers) { in AcceptLdsUpdate()
926 for (const auto& p : listener_state.watchers) { in AcceptLdsUpdate()
942 for (const auto& p : route_config_state.watchers) { in AcceptLdsUpdate()
982 for (const auto& p : route_config_state.watchers) { in AcceptRdsUpdate()
1025 for (const auto& p : cluster_state.watchers) { in AcceptCdsUpdate()
1043 for (const auto& p : cluster_state.watchers) { in AcceptCdsUpdate()
[all …]
|
| D | xds_client.h | 248 watchers; member
256 watchers; member
263 watchers; member
271 watchers; member
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | ev_poll_posix.cc | 977 grpc_fd_watcher* watchers; local
984 watchers = watcher_space;
988 const size_t watch_size = sizeof(*watchers) * (pollset->fd_count + 2);
991 watchers = static_cast<grpc_fd_watcher*>(
1006 watchers[pfd_count].fd = pollset->fds[i];
1007 GRPC_FD_REF(watchers[pfd_count].fd, "multipoller_start");
1017 grpc_fd* fd = watchers[i].fd;
1019 fd_begin_poll(fd, pollset, &worker, POLLIN, POLLOUT, &watchers[i]));
1040 if (watchers[i].fd == nullptr) {
1041 fd_end_poll(&watchers[i], 0, 0);
[all …]
|
| /third_party/jsframework/runtime/vdom/ |
| D | Node.ts | 103 public get watchers() { method in Node
107 public set watchers(newWatchers: Watcher[]) { method in Node
|
| /third_party/jsframework/runtime/main/model/ |
| D | domHelper.ts | 112 if (anchor.watchers !== undefined) {
113 anchor.watchers.forEach(function(watcher) {
116 anchor.watchers = [];
|
| D | compiler.ts | 319 if (element.watchers !== undefined) {
320 element.watchers.forEach(function(watcher) {
323 element.watchers = [];
654 if (element.watchers !== undefined) {
655 element.watchers.forEach(function(watcher) {
658 element.watchers = [];
910 fragBlock.end.watchers.push(newWatcher);
|
| /third_party/node/doc/api/ |
| D | debugger.md | 104 every breakpoint, each expression from the watchers list will be evaluated
109 `watchers` will print the active watchers. To remove a watcher, type
206 * `watchers`: List all watchers and their values (automatically listed on each
|
| /third_party/grpc/test/cpp/interop/ |
| D | xds_interop_client.cc | 82 std::set<XdsStatsWatcher*> watchers; variable
219 for (auto watcher : watchers) { in AsyncCompleteRpc()
283 watchers.insert(watcher); in GetClientStats()
288 watchers.erase(watcher); in GetClientStats()
|
| /third_party/grpc/src/core/ext/filters/client_channel/xds/ |
| D | xds_client.cc | 197 for (const auto& p : state.watchers) { in OnTimerLocked()
203 for (const auto& p : state.watchers) { in OnTimerLocked()
1027 for (const auto& p : cluster_state.watchers) { in AcceptCdsUpdate()
1038 for (const auto& p : cluster_state.watchers) { in AcceptCdsUpdate()
1054 for (const auto& p : endpoint_state.watchers) { in AcceptCdsUpdate()
1139 for (const auto& p : endpoint_state.watchers) { in AcceptEdsUpdate()
1844 cluster_state.watchers[w] = std::move(watcher); in WatchClusterData()
1863 auto it = cluster_state.watchers.find(watcher); in CancelClusterDataWatch()
1864 if (it != cluster_state.watchers.end()) { in CancelClusterDataWatch()
1865 cluster_state.watchers.erase(it); in CancelClusterDataWatch()
[all …]
|
| /third_party/libuv/include/uv/ |
| D | linux.h | 31 void* watchers[2]; \
|
| /third_party/jsframework/test/ut/model/ |
| D | directive.ts | 77 watchers: [],
186 watchers: [],
|
| /third_party/libuv/test/ |
| D | test-fs-event.c | 678 uv_fs_event_t watchers[2]; in TEST_IMPL() local
683 timer.data = watchers; in TEST_IMPL()
685 ASSERT(0 == uv_fs_event_init(loop, watchers + 0)); in TEST_IMPL()
686 ASSERT(0 == uv_fs_event_start(watchers + 0, fail_cb, path, 0)); in TEST_IMPL()
687 ASSERT(0 == uv_fs_event_init(loop, watchers + 1)); in TEST_IMPL()
688 ASSERT(0 == uv_fs_event_start(watchers + 1, fail_cb, path, 0)); in TEST_IMPL()
|