| /third_party/node/test/parallel/ |
| D | test-fs-watch-encoding.js | 33 function registerWatcher(watcher) { argument
34 watchers.add(watcher);
37 function unregisterWatcher(watcher) { argument
38 watcher.close();
39 watchers.delete(watcher);
47 const watcher = fs.watch( constant
52 done(watcher);
55 registerWatcher(watcher);
60 const watcher = fs.watch( constant
64 done(watcher);
[all …]
|
| D | test-fs-watchfile-ref-unref.js | 10 const watcher = fs.watchFile(__filename, uncalledListener); constant
12 watcher.unref();
13 watcher.unref();
14 watcher.ref();
15 watcher.unref();
16 watcher.ref();
17 watcher.ref();
18 watcher.unref();
|
| D | test-fs-watch.js | 53 const watcher = fs.watch(pathToWatch); constant
54 watcher.on('error', (err) => {
61 watcher.on('close', common.mustCall(() => {
62 watcher.close(); // Closing a closed watcher should be a noop
64 watcher.on('change', common.mustCall(function(eventType, argFilename) {
75 watcher.close();
79 watcher.close(); // Closing a closed watcher should be a noop
|
| D | test-fs-watch-close-when-destroyed.js | 19 const watcher = fs.watch(root, { persistent: false, recursive: false }); constant
23 watcher.addListener('error', () => {
25 () => { watcher.close(); }, // Should not crash if it's invoked
30 watcher.addListener('change', () => {
32 () => { watcher.close(); },
|
| D | test-fs-watch-ref-unref.js | 10 const watcher = fs.watch(__filename, common.mustNotCall()); constant
12 watcher.unref();
16 watcher.ref();
17 watcher.unref();
|
| D | test-fs-watch-abort-signal.js | 20 const watcher = fs.watch(file, { signal }); constant
21 watcher.once('close', common.mustCall());
30 const watcher = fs.watch(file, { signal }); constant
31 watcher.once('close', common.mustCall());
|
| /third_party/gstreamer/gstplugins_bad/sys/mediafoundation/ |
| D | gstmfdevice.c | 156 GstObject *watcher; member
177 watcher, WPARAM wparam, LPARAM lparam, gpointer user_data);
183 gst_mf_device_provider_device_added (GstWinRTDeviceWatcher * watcher,
187 gst_mf_device_provider_device_updated (GstWinRTDeviceWatcher * watcher,
191 watcher,
196 watcher, gpointer user_data);
224 self->watcher = (GstObject *) in gst_mf_device_provider_init()
229 if (!self->watcher) { in gst_mf_device_provider_init()
237 self->watcher = (GstObject *) in gst_mf_device_provider_init()
252 gst_clear_object (&self->watcher); in gst_mf_device_provider_dispose()
[all …]
|
| D | gstwin32devicewatcher.cpp | 337 gst_win32_device_watcher_start (GstWin32DeviceWatcher * watcher) in gst_win32_device_watcher_start() argument
341 g_return_val_if_fail (GST_IS_WIN32_DEVICE_WATCHER (watcher), FALSE); in gst_win32_device_watcher_start()
343 data.self = watcher; in gst_win32_device_watcher_start()
347 g_main_context_invoke (watcher->context, in gst_win32_device_watcher_start()
349 g_mutex_lock (&watcher->lock); in gst_win32_device_watcher_start()
351 g_cond_wait (&watcher->cond, &watcher->lock); in gst_win32_device_watcher_start()
352 g_mutex_unlock (&watcher->lock); in gst_win32_device_watcher_start()
378 gst_win32_device_watcher_stop (GstWin32DeviceWatcher * watcher) in gst_win32_device_watcher_stop() argument
382 g_return_if_fail (GST_IS_WIN32_DEVICE_WATCHER (watcher)); in gst_win32_device_watcher_stop()
384 data.self = watcher; in gst_win32_device_watcher_stop()
[all …]
|
| D | gstwin32devicewatcher.h | 34 void (*device_changed) (GstWin32DeviceWatcher * watcher,
46 gboolean gst_win32_device_watcher_start (GstWin32DeviceWatcher * watcher);
48 void gst_win32_device_watcher_stop (GstWin32DeviceWatcher * watcher);
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_unix_events.py | 1111 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._do_waitpid, f)
[all …]
|
| /third_party/libwebsockets/lib/event-libs/libevent/ |
| D | libevent.c | 119 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()
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 = event_new(ptpr->io_loop, fd, in elops_accept_event()
304 event_add(wpr->w_write.watcher, NULL); in elops_io_event()
[all …]
|
| /third_party/libwebsockets/lib/event-libs/libev/ |
| D | libev.c | 33 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, watcher->signum); in lws_ev_sigint_cb()
[all …]
|
| /third_party/gstreamer/gstplugins_bad/gst-libs/gst/winrt/ |
| D | gstwinrtdevicewatcher.cpp | 200 ComPtr < IDeviceWatcher > watcher; member
397 ComPtr < IDeviceWatcher > watcher; in gst_winrt_device_watcher_thread_func_inner() local
422 &watcher); in gst_winrt_device_watcher_thread_func_inner()
462 hr = watcher->add_Added (added_handler.Get (), &inner->added_token); in gst_winrt_device_watcher_thread_func_inner()
471 hr = watcher->add_Updated (updated_handler.Get (), &inner->updated_token); in gst_winrt_device_watcher_thread_func_inner()
480 hr = watcher->add_Removed (removed_handler.Get (), &inner->removed_token); in gst_winrt_device_watcher_thread_func_inner()
489 hr = watcher->add_EnumerationCompleted (enum_completed_handler.Get (), in gst_winrt_device_watcher_thread_func_inner()
500 hr = watcher->add_Stopped (stopped_handler.Get (), &inner->stopped_token); in gst_winrt_device_watcher_thread_func_inner()
509 inner->watcher = watcher; in gst_winrt_device_watcher_thread_func_inner()
519 watcher->Stop (); in gst_winrt_device_watcher_thread_func_inner()
[all …]
|
| D | gstwinrtdevicewatcher.h | 62 void (*added) (GstWinRTDeviceWatcher * watcher,
74 void (*updated) (GstWinRTDeviceWatcher * watcher,
86 void (*removed) (GstWinRTDeviceWatcher * watcher,
97 void (*enumeration_completed) (GstWinRTDeviceWatcher * watcher,
129 gboolean gst_winrt_device_watcher_start (GstWinRTDeviceWatcher * watcher);
132 void gst_winrt_device_watcher_stop (GstWinRTDeviceWatcher * watcher);
|
| /third_party/python/Lib/unittest/ |
| D | _log.py | 17 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/python/Doc/library/ |
| D | asyncio-policy.rst | 75 Get a child process watcher object.
77 Return a watcher object implementing the
82 .. method:: set_child_watcher(watcher)
84 Set the current child process watcher to *watcher*.
125 A process watcher allows customization of how an event loop monitors
142 The following two functions can be used to customize the child process watcher
147 Return the current child watcher for the current policy.
149 .. function:: set_child_watcher(watcher)
151 Set the current child watcher to *watcher* for the current
152 policy. *watcher* must implement methods defined in the
[all …]
|
| /third_party/node/test/sequential/ |
| D | test-fs-watch.js | 59 const watcher = fs.watch(filepath); constant
60 watcher.on('change', common.mustCall(function(event, filename) {
67 watcher.close();
80 const watcher = constant
88 watcher.close();
98 const watcher = constant
108 watcher.close();
|
| /third_party/gstreamer/gstplugins_bad/sys/wasapi2/ |
| D | gstwasapi2device.c | 143 GstWinRTDeviceWatcher *watcher; member
174 gst_wasapi2_device_provider_device_added (GstWinRTDeviceWatcher * watcher,
178 gst_wasapi2_device_provider_device_updated (GstWinRTDeviceWatcher * watcher,
182 watcher,
187 watcher, gpointer user_data);
237 self->watcher = in gst_wasapi2_device_provider_init()
247 gst_clear_object (&self->watcher); in gst_wasapi2_device_provider_dispose()
376 if (!self->watcher) { in gst_wasapi2_device_provider_start()
383 if (!gst_winrt_device_watcher_start (self->watcher)) in gst_wasapi2_device_provider_start()
409 if (self->watcher) in gst_wasapi2_device_provider_stop()
[all …]
|
| /third_party/jsframework/runtime/main/reactivity/ |
| D | state.js | 93 const watcher = new Watcher(owner, getter, null, {
97 if (watcher.dirty) {
98 watcher.evaluate();
101 watcher.depend();
103 return watcher.value;
|
| /third_party/node/test/async-hooks/ |
| D | test-statwatcher.js | 25 const checkWatcherStart = (name, watcher) => { argument
26 assert.strictEqual(watcher.type, 'STATWATCHER');
27 assert.strictEqual(typeof watcher.uid, 'number');
28 assert.strictEqual(watcher.triggerAsyncId, 1);
29 checkInvocations(watcher, { init: 1 },
|
| /third_party/typescript/src/compiler/ |
| D | watchUtilities.ts | 277 extendedConfigFilesMap.forEach((watcher, extendedConfigFilePath) => {
279 watcher.projects.delete(projectPath);
280 watcher.close();
331 watcher: FileWatcher; property
362 watcher: watchDirectory(directory, flags),
373 existingWatcher.watcher.close();
550 …const watcher = triggerInvokingFactory!.watchFile(file, cb, flags, options, detailInfo1, detailInf… constant
554 watcher.close();
570 …const watcher = triggerInvokingFactory!.watchDirectory(file, cb, flags, options, detailInfo1, deta… constant
578 watcher.close();
[all …]
|
| D | sys.ts | 321 const watcher = dirWatchers.get(dirPath) || constant
323 watcher.referenceCount++;
326 if (watcher.referenceCount === 1) {
327 watcher.close();
331 watcher.referenceCount--;
339 const watcher = fsWatch( constant
358 watcher.referenceCount = 0;
359 dirWatchers.set(dirPath, watcher);
360 return watcher;
370 watcher: FileWatcher;
[all …]
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-eventlib-foreign/ |
| D | libev.c | 26 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()
|
| /third_party/flutter/skia/third_party/externals/sdl/src/events/ |
| D | SDL_events.c | 508 SDL_EventWatcher *watcher, *tail; in SDL_AddEventWatch() local
510 watcher = (SDL_EventWatcher *)SDL_malloc(sizeof(*watcher)); in SDL_AddEventWatch()
511 if (!watcher) { in SDL_AddEventWatch()
517 watcher->callback = filter; in SDL_AddEventWatch()
518 watcher->userdata = userdata; in SDL_AddEventWatch()
519 watcher->next = NULL; in SDL_AddEventWatch()
526 tail->next = watcher; in SDL_AddEventWatch()
528 SDL_event_watchers = watcher; in SDL_AddEventWatch()
|
| /third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-threads-foreign-libuv-smp/ |
| D | minimal-ws-server.c | 118 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()
|