Home
last modified time | relevance | path

Searched refs:watcher (Results 1 - 25 of 38) sorted by relevance

12

/third_party/node/test/parallel/
H A Dtest-fs-watch-encoding.js33 function registerWatcher(watcher) {
34 watchers.add(watcher);
37 function unregisterWatcher(watcher) {
38 watcher.close();
39 watchers.delete(watcher);
47 const watcher = fs.watch(
52 done(watcher);
55 registerWatcher(watcher);
60 const watcher = fs.watch(
64 done(watcher);
[all...]
H A Dtest-fs-watchfile-bigint.js43 const watcher =
63 watcher.stop(); // Stopping a stopped watcher should be a noop
67 // 'stop' should only be emitted once - stopping a stopped watcher should
69 watcher.on('stop', common.mustCall());
/third_party/python/Lib/test/test_asyncio/
H A Dtest_unix_events.py1111 watcher = asyncio.AbstractChildWatcher()
1113 NotImplementedError, watcher.add_child_handler, f, f)
1115 NotImplementedError, watcher.remove_child_handler, f)
1117 NotImplementedError, watcher.attach_loop, f)
1119 NotImplementedError, watcher.close)
1121 NotImplementedError, watcher.is_active)
1123 NotImplementedError, watcher.__enter__)
1125 NotImplementedError, watcher.__exit__, f, f, f)
1132 watcher = unix_events.BaseChildWatcher()
1134 NotImplementedError, watcher
[all...]
H A Dtest_subprocess.py585 # manually to avoid a warning when the watcher is detached.
717 watcher = self.Watcher()
718 watcher.attach_loop(self.loop)
719 policy.set_child_watcher(watcher)
724 watcher = policy.get_child_watcher()
726 watcher.attach_loop(None)
727 watcher.close()
772 watcher = mock.create_autospec(
778 asyncio.set_child_watcher(watcher)
784 watcher
[all...]
/third_party/libwebsockets/lib/event-libs/libevent/
H A Dlibevent.c119 event_del(lws_io->event.watcher); in lws_event_cb()
120 event_free(lws_io->event.watcher); in lws_event_cb()
164 struct event *signal = pt_to_priv_event(pt)->w_sigint.watcher; in lws_event_sigint_cb()
187 w_read->watcher = event_new(ptpr->io_loop, wsi->desc.sockfd, in elops_listen_init_event()
189 event_add(w_read->watcher, NULL); in elops_listen_init_event()
233 /* Register the signal watcher unless it's a foreign loop */ in elops_init_pt_event()
238 ptpr->w_sigint.watcher = evsignal_new(loop, SIGINT, in elops_init_pt_event()
240 event_add(ptpr->w_sigint.watcher, NULL); in elops_init_pt_event()
280 wpr->w_read.watcher = event_new(ptpr->io_loop, fd, in elops_accept_event()
282 wpr->w_write.watcher in elops_accept_event()
[all...]
H A Dprivate-lib-event-libs-libevent.h28 struct event *watcher; member
40 struct event *watcher; member
/third_party/libwebsockets/lib/event-libs/libev/
H A Dlibev.c33 lws_ev_hrtimer_cb(struct ev_loop *loop, struct ev_timer *watcher, int revents) in lws_ev_hrtimer_cb() argument
35 struct lws_pt_eventlibs_libev *ptpr = lws_container_of(watcher, in lws_ev_hrtimer_cb()
88 lws_accept_cb(struct ev_loop *loop, struct ev_io *watcher, int revents) in lws_accept_cb() argument
90 struct lws_io_watcher_libev *lws_io = lws_container_of(watcher, in lws_accept_cb()
91 struct lws_io_watcher_libev, watcher); in lws_accept_cb()
101 eventfd.fd = watcher->fd; in lws_accept_cb()
114 wsi = wsi_from_fd(context, watcher->fd); in lws_accept_cb()
124 lws_ev_sigint_cb(struct ev_loop *loop, struct ev_signal *watcher, int revents) in lws_ev_sigint_cb() argument
126 struct lws_context *context = watcher->data; in lws_ev_sigint_cb()
129 context->eventlib_signal_cb((void *)watcher, watche in lws_ev_sigint_cb()
[all...]
H A Dprivate-lib-event-libs-libev.h37 ev_signal watcher; member
50 ev_io watcher; member
/third_party/python/Lib/unittest/
H A D_log.py17 self.watcher = _LoggingWatcher([], [])
23 self.watcher.records.append(record)
25 self.watcher.output.append(msg)
52 self.watcher = handler.watcher
61 return handler.watcher
74 if len(self.watcher.records) > 0:
77 self.watcher.output
83 if len(self.watcher.records) == 0:
/third_party/node/test/sequential/
H A Dtest-fs-watch.js45 // Because macOS (and possibly other operating systems) can return a watcher
59 const watcher = fs.watch(filepath);
60 watcher.on('change', common.mustCall(function(event, filename) {
67 watcher.close();
80 const watcher =
88 watcher.close();
98 const watcher =
108 watcher.close();
118 // https://github.com/joyent/node/issues/2293 - non-persistent watcher should
/third_party/node/lib/internal/main/
H A Dwatch_mode.js45 const watcher = new FilesWatcher({ debounce: 200, mode: kShouldFilterModules ? 'filter' : 'all' });
46 ArrayPrototypeForEach(kWatchedPaths, (p) => watcher.watchPath(p));
56 watcher.watchChildProcessModules(child);
98 watcher.clearFileFilters();
118 for await (const _ of on(watcher, 'changed')) {
131 watcher.clear();
/third_party/jsframework/runtime/main/reactivity/
H A Dstate.js2 import Watcher from './watcher';
93 const watcher = new Watcher(owner, getter, null, {
97 if (watcher.dirty) {
98 watcher.evaluate();
101 watcher.depend();
103 return watcher.value;
/third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-eventlib-foreign/
H A Dlibev.c26 timer_cb_ev(struct ev_loop *loop, struct ev_timer *watcher, int revents) in timer_cb_ev() argument
32 signal_cb_ev(struct ev_loop *loop, struct ev_signal *watcher, int revents) in signal_cb_ev() argument
34 signal_cb(watcher->signum); in signal_cb_ev()
H A Dlibuv.c38 signal_cb_uv(uv_signal_t *watcher, int signum) in signal_cb_uv() argument
/third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-threads-foreign-libuv-smp/
H A Dminimal-ws-server.c118 signal_cb(uv_signal_t *watcher, int signum) in signal_cb() argument
122 n = (int)(watcher - signal_outer); in signal_cb()
125 watcher->signum); in signal_cb()
127 uv_signal_stop(watcher); in signal_cb()
/third_party/typescript/lib/
H A DwatchGuard.js24 var watcher = fs.watch(directoryName, { recursive: true }, function () { return ({}); });
25 watcher.close();
/third_party/libwebsockets/lwsws/
H A Dmain.c97 void signal_cb(uv_signal_t *watcher, int signum) in signal_cb() argument
99 switch (watcher->signum) { in signal_cb()
116 lwsl_err("Signal %d caught\n", watcher->signum); in signal_cb()
117 uv_signal_stop(watcher); in signal_cb()
/third_party/node/test/report/
H A Dtest-report-uv-handles.js22 let watcher;
24 watcher = fs.watch(__filename);
29 childData.skip_fs_watch = watcher === undefined;
32 if (watcher) watcher.close();
/third_party/node/test/async-hooks/
H A Dtest-fseventwrap.js19 const watcher = fs.watch(__filename, onwatcherChanged);
22 watcher.close();
/third_party/libwebsockets/lib/event-libs/libuv/
H A Dlibuv.c94 lws_io_cb(uv_poll_t *watcher, int status, int revents) in lws_io_cb() argument
96 struct lws *wsi = (struct lws *)((uv_handle_t *)watcher)->data; in lws_io_cb()
115 eventfd.fd = watcher->socket; in lws_io_cb()
117 eventfd.fd = watcher->io_watcher.fd; in lws_io_cb()
182 lws_uv_signal_handler(uv_signal_t *watcher, int signum) in lws_uv_signal_handler() argument
185 watcher->data; in lws_uv_signal_handler()
188 pt->context->eventlib_signal_cb((void *)watcher, signum); in lws_uv_signal_handler()
452 lwsl_wsi_warn(wsi, "Waiting for libuv watcher to close"); in elops_check_client_connect_ok_uv()
564 lwsl_wsi_info(wsi, "no watcher"); in elops_io_uv()
676 uv_signal_stop(&pt_to_priv_uv(pt)->w_sigint.watcher); in elops_destroy_pt_uv()
[all...]
H A Dprivate-lib-event-libs-libuv.h50 uv_signal_t watcher; member
/third_party/node/lib/internal/test_runner/
H A Drunner.js381 filesWatcher.watcher.watchChildProcessModules(child, path);
447 const watcher = new FilesWatcher({ __proto__: null, debounce: 200, mode: 'filter', signal: opts.signal });
448 const filesWatcher = { __proto__: null, watcher, runningProcesses, runningSubtests };
450 watcher.on('changed', ({ owners }) => {
451 watcher.unfilterFilesOwnedBy(owners);
/third_party/libwebsockets/lib/event-libs/sdevent/
H A Dsdevent.c97 struct sd_event_source *idletimer, *watcher; in sock_accept_handler() local
143 watcher = wsi_to_priv_sd(wsi)->source; in sock_accept_handler()
144 if (watcher) in sock_accept_handler()
145 sd_event_source_set_enabled(watcher, SD_EVENT_ONESHOT); in sock_accept_handler()
/third_party/python/Lib/asyncio/
H A Dunix_events.py198 with events.get_child_watcher() as watcher:
199 if not watcher.is_active():
202 # prevents subprocess execution if the watcher
212 watcher.add_child_handler(transp.get_pid(),
838 process must be done within a 'with' block to allow the watcher to suspend
843 with watcher:
845 watcher.add_child_handler(proc.pid, callback)
850 Since child watcher objects may catch the SIGCHLD signal and call
874 """Attach the watcher to an event loop.
876 If the watcher wa
[all...]
/third_party/node/deps/v8/src/torque/ls/
H A Dmessage-handler.cc237 FileSystemWatcher watcher = options.add_watchers(); in HandleInitializedNotification() local
238 watcher.set_globPattern("**/*.tq"); in HandleInitializedNotification()
239 watcher.set_kind(FileSystemWatcher::WatchKind::kAll); in HandleInitializedNotification()

Completed in 16 milliseconds

12