| /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 | 7 // Tests if `filename` is provided to watcher on supported platforms
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-abort-signal.js | 16 // Signal aborted after creating the watcher
20 const watcher = fs.watch(file, { signal }); constant
21 watcher.once('close', common.mustCall());
25 // Signal aborted before creating the watcher
30 const watcher = fs.watch(file, { signal }); constant
31 watcher.once('close', common.mustCall());
|
| D | test-fs-watch-close-when-destroyed.js | 3 // This tests that closing a watcher when the underlying handle is
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(); },
|
| /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 | 32 #define GST_WIN32_HWND_PROP_NAME "gst-win32-device-watcher"
138 GST_WARNING ("Failed to get watcher object"); in window_proc()
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
[all …]
|
| /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/grpc/src/core/lib/transport/ |
| D | connectivity_state.cc | 57 // state notification to a watcher.
60 Notifier(RefCountedPtr<AsyncConnectivityStateWatcherInterface> watcher, in Notifier() argument
63 : watcher_(std::move(watcher)), state_(state), status_(status) { in Notifier()
79 gpr_log(GPR_INFO, "watcher %p: delivering async notification for %s (%s)", in SendNotification()
109 "ConnectivityStateTracker %s[%p]: notifying watcher %p: %s -> %s", in ~ConnectivityStateTracker()
119 OrphanablePtr<ConnectivityStateWatcherInterface> watcher) { in AddWatcher() argument
121 gpr_log(GPR_INFO, "ConnectivityStateTracker %s[%p]: add watcher %p", name_, in AddWatcher()
122 this, watcher.get()); in AddWatcher()
128 "ConnectivityStateTracker %s[%p]: notifying watcher %p: %s -> %s", in AddWatcher()
129 name_, this, watcher.get(), ConnectivityStateName(initial_state), in AddWatcher()
[all …]
|
| /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/grpc/test/core/transport/ |
| D | connectivity_state_test.cc | 43 class Watcher : public ConnectivityStateWatcherInterface { class
45 Watcher(int* count, grpc_connectivity_state* output, in Watcher() function in grpc_core::__anon1e0829340111::Watcher
49 ~Watcher() { in ~Watcher()
76 MakeOrphanable<Watcher>(&count, &state)); in TEST()
86 MakeOrphanable<Watcher>(&count, &state)); in TEST()
99 ConnectivityStateWatcherInterface* watcher = in TEST() local
100 new Watcher(&count, &state, &destroyed); in TEST()
102 OrphanablePtr<ConnectivityStateWatcherInterface>(watcher)); in TEST()
108 tracker.RemoveWatcher(watcher); in TEST()
119 ConnectivityStateWatcherInterface* watcher = in TEST() local
[all …]
|
| /third_party/grpc/src/core/lib/security/credentials/tls/ |
| D | grpc_tls_certificate_distributor.h | 58 // Note that if a watcher sees an error, it simply means the Provider is
59 // having problems renewing new data. If the watcher has previously received
62 // In that case, watcher might simply log the error. If the watcher hasn't
64 // data is available yet, and the watcher should either fail or "waiting"
109 // certificate name is watched by a newly registered watcher, or when a
132 // Registers a watcher. The caller may keep a raw pointer to the watcher,
134 // the watcher, the pointer must not be used for any other purpose.) At least
137 // @param watcher The watcher being registered.
144 std::unique_ptr<TlsCertificatesWatcherInterface> watcher,
148 // Cancels a watcher.
[all …]
|
| D | grpc_tls_certificate_distributor.cc | 114 // watcher is watching, if there is any. in SetErrorForCert()
134 // root_cert_error_to_report is the error of the root cert this watcher is in SetErrorForCert()
157 for (const auto& watcher : watchers_) { in SetError() local
158 const auto watcher_ptr = watcher.first; in SetError()
160 const auto& watcher_info = watcher.second; in SetError()
176 std::unique_ptr<TlsCertificatesWatcherInterface> watcher, in WatchTlsCertificates() argument
184 TlsCertificatesWatcherInterface* watcher_ptr = watcher.get(); in WatchTlsCertificates()
190 // The caller needs to cancel the watcher first if it wants to re-register in WatchTlsCertificates()
191 // the watcher. in WatchTlsCertificates()
193 watchers_[watcher_ptr] = {std::move(watcher), root_cert_name, in WatchTlsCertificates()
[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 | 56 * @watcher: a #GstWinRTDeviceWatcher
62 void (*added) (GstWinRTDeviceWatcher * watcher,
68 * @watcher: a #GstWinRTDeviceWatcher
74 void (*updated) (GstWinRTDeviceWatcher * watcher,
80 * @watcher: a #GstWinRTDeviceWatcher
86 void (*removed) (GstWinRTDeviceWatcher * watcher,
92 * @watcher: a #GstWinRTDeviceWatcher
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/grpc/src/core/ext/xds/ |
| D | xds_client.h | 46 // Listener data watcher interface. Implemented by callers.
55 // RouteConfiguration data watcher interface. Implemented by callers.
64 // Cluster data watcher interface. Implemented by callers.
73 // Endpoint data watcher interface. Implemented by callers.
112 // The XdsClient takes ownership of the watcher, but the caller may
113 // keep a raw pointer to the watcher, which may be used only for
114 // cancellation. (Because the caller does not own the watcher, the
119 std::unique_ptr<ListenerWatcherInterface> watcher);
121 ListenerWatcherInterface* watcher,
125 // The XdsClient takes ownership of the watcher, but the caller may
[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()
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 = event_new(ptpr->io_loop, fd, in elops_accept_event()
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | subchannel_interface.h | 41 // given watcher instance at any given time.
59 // The first callback to the watcher will be delivered when the
64 // The watcher will be destroyed either when the subchannel is
66 // There can be only one watcher of a given subchannel. It is not
68 // the previous watcher using CancelConnectivityStateWatch().
71 std::unique_ptr<ConnectivityStateWatcherInterface> watcher) = 0;
74 // If the watcher has already been destroyed, this is a no-op.
76 ConnectivityStateWatcherInterface* watcher) = 0;
110 std::unique_ptr<ConnectivityStateWatcherInterface> watcher) override { in WatchConnectivityState() argument
112 std::move(watcher)); in WatchConnectivityState()
[all …]
|
| /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/jsframework/runtime/main/reactivity/ |
| D | watcher.js | 12 * A watcher parses an expression, collects dependencies,
30 export default function Watcher (vm, expOrFn, cb, options) { class
62 Watcher.prototype.get = function () {
79 Watcher.prototype.addDep = function (dep) {
93 Watcher.prototype.cleanupDeps = function () {
115 Watcher.prototype.update = function (shallow) {
126 Watcher.prototype.run = function () {
143 * Evaluate the value of the watcher. This only gets called for lazy watchers.
145 Watcher.prototype.evaluate = function () {
151 * Depend on all deps collected by this watcher.
[all …]
|
| D | state.js | 2 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/libuv/test/ |
| D | test-loop-handles.c | 28 * - A watcher must be able to safely stop or close itself;
29 * - Once a watcher is stopped or closed its callback should never be called.
30 * - If a watcher is closed, it is implicitly stopped and its close_cb should
32 * - A watcher can safely start and stop other watchers of the same type.
36 * - If a watcher starts another watcher of the same type its callback is not
38 * a watcher makes another of the same type active, it'll not be called until
40 * newly activated idle watcher might not be queued immediately.
50 * stops itself. It verifies that a watcher is not queued immediately
51 * if created by another watcher of the same type.
52 * - There's a check watcher that stops the event loop after a certain number
[all …]
|
| /third_party/grpc/src/ruby/pb/test/ |
| D | xds_client.rb | 133 watcher = {}
135 watcher = {
141 $watchers << watcher
144 while watcher['rpcs_needed'] > 0 && seconds_remaining > 0
149 $watchers.delete_at($watchers.index(watcher))
153 watcher['rpcs_by_method'].each do |rpc_name, rpcs_by_peer|
160 rpcs_by_peer: watcher['rpcs_by_peer'],
161 num_failures: watcher['no_remote_peer'] + watcher['rpcs_needed']
280 $watchers.each do |watcher|
282 watcher['rpcs_needed'] -= 1
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | cds.cc | 69 // Watcher for getting cluster data from XdsClient.
110 // Pointer to watcher, to be used when cancelling.
112 ClusterWatcher* watcher = nullptr; member
113 // Most recent update obtained from this watcher.
149 XdsClient::ClusterWatcherInterface* watcher,
293 for (auto& watcher : watchers_) { in ShutdownLocked() local
296 watcher.first.c_str()); in ShutdownLocked()
298 CancelClusterDataWatch(watcher.first, watcher.second.watcher, in ShutdownLocked()
336 // If cluster name changed, cancel watcher and restart. in UpdateLocked()
339 for (auto& watcher : watchers_) { in UpdateLocked() local
[all …]
|