| /external/libchrome/mojo/core/ |
| D | request_context.cc | 53 for (const scoped_refptr<Watch>& watch : in ~RequestContext() local
66 watch->InvokeCallback(MOJO_RESULT_CANCELLED, closed_state, flags); in ~RequestContext()
69 for (const WatchNotifyFinalizer& watch : in ~RequestContext() local
72 watch.watch->InvokeCallback(watch.result, watch.state, flags); in ~RequestContext()
87 void RequestContext::AddWatchNotifyFinalizer(scoped_refptr<Watch> watch, in AddWatchNotifyFinalizer() argument
92 WatchNotifyFinalizer(std::move(watch), result, state)); in AddWatchNotifyFinalizer()
95 void RequestContext::AddWatchCancelFinalizer(scoped_refptr<Watch> watch) { in AddWatchCancelFinalizer() argument
97 watch_cancel_finalizers_->push_back(std::move(watch)); in AddWatchCancelFinalizer()
105 scoped_refptr<Watch> watch, in WatchNotifyFinalizer() argument
108 : watch(std::move(watch)), result(result), state(state) {} in WatchNotifyFinalizer()
|
| D | watcher_dispatcher.cc | 41 scoped_refptr<Watch> watch; in NotifyHandleClosed() local
48 watch = std::move(it->second); in NotifyHandleClosed()
51 watches_.erase(watch->context()); in NotifyHandleClosed()
52 ready_watches_.erase(watch.get()); in NotifyHandleClosed()
58 watch->Cancel(); in NotifyHandleClosed()
135 scoped_refptr<Watch> watch = in WatchDispatcher() local
137 watches_.insert({context, watch}); in WatchDispatcher()
139 watched_handles_.insert(std::make_pair(dispatcher.get(), watch)); in WatchDispatcher()
171 scoped_refptr<Watch> watch; in CancelWatch() local
179 watch = it->second; in CancelWatch()
[all …]
|
| D | request_context.h | 56 void AddWatchNotifyFinalizer(scoped_refptr<Watch> watch,
64 void AddWatchCancelFinalizer(scoped_refptr<Watch> watch);
71 WatchNotifyFinalizer(scoped_refptr<Watch> watch,
77 scoped_refptr<Watch> watch; member
|
| /external/libchrome/base/files/ |
| D | file_path_watcher_linux.cc | 75 void RemoveWatch(Watch watch, FilePathWatcherImpl* watcher);
154 : watch(InotifyReader::kInvalidWatch), in WatchEntry()
157 InotifyReader::Watch watch; member
181 void TrackWatchForRecursion(InotifyReader::Watch watch, const FilePath& path);
299 Watch watch = inotify_add_watch(inotify_fd_, path.value().c_str(), in AddWatch() local
304 if (watch == kInvalidWatch) in AddWatch()
307 watchers_[watch].insert(watcher); in AddWatch()
309 return watch; in AddWatch()
312 void InotifyReader::RemoveWatch(Watch watch, FilePathWatcherImpl* watcher) { in RemoveWatch() argument
313 if (!valid_ || (watch == kInvalidWatch)) in RemoveWatch()
[all …]
|
| /external/adhd/cras/src/server/ |
| D | cras_dbus.c | 20 DBusWatch *watch = (DBusWatch *)arg; in dbus_watch_callback() local
24 pollfd.fd = dbus_watch_get_unix_fd(watch); in dbus_watch_callback()
37 if (!dbus_watch_handle(watch, flags)) in dbus_watch_callback()
41 static dbus_bool_t dbus_watch_add(DBusWatch *watch, void *data) in dbus_watch_add() argument
44 unsigned int flags = dbus_watch_get_flags(watch); in dbus_watch_add()
49 if ((flags & DBUS_WATCH_READABLE) && dbus_watch_get_enabled(watch)) { in dbus_watch_add()
50 r = cras_system_add_select_fd(dbus_watch_get_unix_fd(watch), in dbus_watch_add()
51 dbus_watch_callback, watch, in dbus_watch_add()
60 static void dbus_watch_remove(DBusWatch *watch, void *data) in dbus_watch_remove() argument
62 unsigned int flags = dbus_watch_get_flags(watch); in dbus_watch_remove()
[all …]
|
| /external/wpa_supplicant_8/wpa_supplicant/dbus/ |
| D | dbus_common.c | 59 DBusWatch *watch, eloop_event_type type) in process_watch() argument
66 dbus_watch_handle(watch, DBUS_WATCH_READABLE); in process_watch()
68 dbus_watch_handle(watch, DBUS_WATCH_WRITABLE); in process_watch()
70 dbus_watch_handle(watch, DBUS_WATCH_ERROR); in process_watch()
99 static dbus_bool_t add_watch(DBusWatch *watch, void *data) in add_watch() argument
105 if (!dbus_watch_get_enabled(watch)) in add_watch()
108 flags = dbus_watch_get_flags(watch); in add_watch()
109 fd = dbus_watch_get_unix_fd(watch); in add_watch()
112 process_watch_exception, priv, watch) < 0) in add_watch()
117 priv, watch) < 0) in add_watch()
[all …]
|
| /external/tensorflow/tensorflow/core/debug/ |
| D | grpc_session_debug_test.cc | 170 DebugTensorWatch* watch = debug_options->add_debug_tensor_watch_opts(); in TEST_F() local
171 watch->set_node_name(node_names[0]); in TEST_F()
172 watch->set_output_slot(0); in TEST_F()
173 watch->add_debug_ops("DebugIdentity"); in TEST_F()
174 watch->add_debug_urls(GetDebugURL()); in TEST_F()
177 watch = debug_options->add_debug_tensor_watch_opts(); in TEST_F()
178 watch->set_node_name(node_names[1]); in TEST_F()
179 watch->set_output_slot(0); in TEST_F()
180 watch->add_debug_ops("DebugIdentity"); in TEST_F()
181 watch->add_debug_urls(GetDebugURL()); in TEST_F()
[all …]
|
| D | debug_graph_utils.cc | 71 for (const DebugTensorWatch& watch : watches) { in InsertNodes() local
72 if (watch.debug_ops().empty()) { in InsertNodes()
76 if (watch.debug_urls().empty()) { in InsertNodes()
80 if (watch.node_name() == "*") { in InsertNodes()
81 if (watch.output_slot() == -1) { in InsertNodes()
83 watch.debug_ops().begin(), in InsertNodes()
84 watch.debug_ops().end()); in InsertNodes()
86 watch.debug_urls().begin(), in InsertNodes()
87 watch.debug_urls().end()); in InsertNodes()
92 "node name (\"*\"), but got ", watch.output_slot())); in InsertNodes()
[all …]
|
| D | debugger_state_impl.cc | 24 for (const DebugTensorWatch& watch : in DebuggerState() local
26 for (const string& url : watch.debug_urls()) { in DebuggerState()
60 for (const DebugTensorWatch& watch : in PublishGraph() local
62 for (const string& url : watch.debug_urls()) { in PublishGraph()
|
| /external/pigweed/pw_watch/ |
| D | docs.rst | 21 using the Pigweed environment as ``pw watch``. By default, ``pw_watch`` watches
24 this behavior, provide the ``-C`` argument to ``pw watch``.
29 pw watch
32 pw watch python.lint stm32f429i
35 pw watch -C out/cmake pw_run_tests.modules
38 pw watch -C out -C out/cmake pw_apps
41 pw watch python.tests -C out/cmake pw_apps
43 ``pw watch`` only rebuilds when a file that is not ignored by Git changes.
44 Adding exclusions to a ``.gitignore`` causes watch to ignore them, even if the
53 By default, ``pw watch`` automatically restarts an ongoing build when files
[all …]
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | debugger_state_interface.cc | 32 for (const DebugTensorWatch& watch : watches) { in SummarizeDebugTensorWatches() local
34 strings::StrCat(watch.node_name(), ":", watch.output_slot()); in SummarizeDebugTensorWatches()
35 if (watch.tolerate_debug_op_creation_failures()) { in SummarizeDebugTensorWatches()
40 for (const string& debug_op : watch.debug_ops()) { in SummarizeDebugTensorWatches()
45 for (const string& debug_url : watch.debug_urls()) { in SummarizeDebugTensorWatches()
|
| /external/tensorflow/tensorflow/python/eager/ |
| D | backprop_test.py | 145 t.watch(x)
146 t.watch(x1)
147 t.watch(x2)
148 t.watch(x3)
149 t.watch(x4)
189 t.watch([x, y])
216 t.watch([x, y])
318 t.watch(x)
325 t.watch(x)
337 t.watch(x)
[all …]
|
| /external/pigweed/pw_watch/py/ |
| D | watch_test.py | 21 from pw_watch import watch
40 subdirectories_to_watch = watch.minimal_watch_directories(
55 subdirectories_to_watch = watch.minimal_watch_directories(
73 subdirectories_to_watch = watch.minimal_watch_directories(
93 subdirectories_to_watch = watch.minimal_watch_directories(
112 subdirectories_to_watch = watch.minimal_watch_directories(
142 subdirectories_to_watch = watch.minimal_watch_directories(
169 subdirectories_to_watch = watch.minimal_watch_directories(
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| D | gradient_correctness_test.py | 38 tape.watch(x)
52 tape.watch(x)
60 tape.watch(x)
68 tape.watch(x)
79 tape.watch(x)
91 tape.watch([k, x])
101 tape.watch(k)
111 tape.watch(k)
121 tape.watch(k)
133 tape.watch(k)
|
| D | map_ops_test.py | 194 tape.watch(v)
210 tape.watch(v)
211 tape.watch(v2)
212 tape.watch(v3)
233 tape.watch(v)
248 tape.watch(v)
249 tape.watch(v2)
272 tape.watch(v)
273 tape.watch(v2)
292 tape.watch(v)
[all …]
|
| /external/llvm-project/debuginfo-tests/dexter/dex/command/commands/ |
| D | DexExpectWatchBase.py | 102 def _get_expected_field(self, watch): argument
176 watch = step.program_state.frames[0].watches[self.expression]
180 expected_field = self._get_expected_field(watch)
181 step_info = StepValueInfo(step.step_index, watch,
189 for watch in self.expected_watches:
190 if watch.expected_value != prev_value:
191 value_change_watches.append(watch)
192 prev_value = watch.expected_value
|
| /external/mockito/src/test/java/org/mockitousage/verification/ |
| D | VerificationWithAfterTest.java | 43 private Stopwatch watch = createNotStarted(); field in VerificationWithAfterTest
204 watch.start(); in should_fail_early_when_at_most_is_used()
218 watch.assertElapsedTimeIsLessThan(2000, MILLISECONDS); in should_fail_early_when_at_most_is_used()
223 watch.start(); in should_fail_early_when_never_is_used()
236 watch.assertElapsedTimeIsLessThan(2000, MILLISECONDS); in should_fail_early_when_never_is_used()
242 watch.start(); in should_fail_early_when_only_is_used()
256 watch.assertElapsedTimeIsLessThan(2000, MILLISECONDS); in should_fail_early_when_only_is_used()
262 watch.start(); in should_fail_early_when_time_x_is_used()
276 watch.assertElapsedTimeIsLessThan(2000, MILLISECONDS); in should_fail_early_when_time_x_is_used()
|
| /external/openscreen/osp/public/ |
| D | message_demuxer_unittest.cc | 62 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F() local
65 ASSERT_TRUE(watch); in TEST_F()
88 watch = MessageDemuxer::MessageWatch(); in TEST_F()
98 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F() local
101 ASSERT_TRUE(watch); in TEST_F()
129 MessageDemuxer::MessageWatch watch = demuxer_.SetDefaultMessageTypeWatch( in TEST_F() local
131 ASSERT_TRUE(watch); in TEST_F()
162 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F() local
165 ASSERT_TRUE(watch); in TEST_F()
218 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F() local
[all …]
|
| /external/mockito/src/test/java/org/mockitoutil/async/ |
| D | AsyncTestingTest.java | 20 private Stopwatch watch = createNotStarted(); field in AsyncTestingTest
30 watch.start(); in sanity_test()
44 watch.waitFor(300); in sanity_test()
47 watch.assertElapsedTimeIsMoreThan(200, MILLISECONDS); in sanity_test()
|
| /external/ltp/testcases/kernel/syscalls/utils/ |
| D | inotify.h | 172 static inline void inotify_init_watch(struct inotify_watch *watch) in inotify_init_watch() argument
193 struct inotify_watch *watch, in inotify_add_watch() argument
200 struct inotify_watch *watch) in inotify_rm_watch() argument
211 struct inotify_watch *watch) in inotify_remove_watch_locked() argument
215 static inline void get_inotify_watch(struct inotify_watch *watch) in get_inotify_watch() argument
219 static inline void put_inotify_watch(struct inotify_watch *watch) in put_inotify_watch() argument
|
| /external/llvm-project/debuginfo-tests/dexter/dex/debugger/DebuggerControllers/ |
| D | ControllerHelpers.py | 28 for watch in towatch:
31 and os.path.samefile(watch.path, loc.path)
32 and watch.lineno == loc.lineno):
33 result = watch.eval(step_info)
|
| /external/tensorflow/tensorflow/python/debug/lib/ |
| D | debug_utils.py | 64 watch = watch_opts.add()
65 watch.tolerate_debug_op_creation_failures = (
67 watch.node_name = node_name
68 watch.output_slot = output_slot
73 watch.debug_ops.extend(debug_ops)
79 watch.debug_urls.extend(debug_urls)
|
| /external/adhd/cras/src/tests/ |
| D | dbus_test.cc | 548 dbus_bool_t DBusTest::AddWatchThunk(DBusWatch* watch, void* data) { in AddWatchThunk() argument
550 return test->AddWatch(watch); in AddWatchThunk()
553 dbus_bool_t DBusTest::AddWatch(DBusWatch* watch) { in AddWatch() argument
554 watches_.push_back(watch); in AddWatch()
558 void DBusTest::RemoveWatchThunk(DBusWatch* watch, void* data) { in RemoveWatchThunk() argument
560 test->RemoveWatch(watch); in RemoveWatchThunk()
563 void DBusTest::RemoveWatch(DBusWatch* watch) { in RemoveWatch() argument
565 find(watches_.begin(), watches_.end(), watch); in RemoveWatch()
570 void DBusTest::WatchToggledThunk(DBusWatch* watch, void* data) { in WatchToggledThunk() argument
572 test->WatchToggled(watch); in WatchToggledThunk()
[all …]
|
| /external/rust/crates/tokio/src/sync/ |
| D | barrier.rs | 1 use crate::sync::watch;
43 wait: watch::Receiver<usize>,
49 waker: watch::Sender<usize>,
60 let (waker, wait) = crate::sync::watch::channel(0); in new()
|
| /external/rust/crates/tokio/tests/ |
| D | sync_watch.rs | 5 use tokio::sync::watch;
11 let (tx, mut rx) = watch::channel("one"); in single_rx_recv()
46 let (tx, mut rx1) = watch::channel("one"); in multi_rx()
115 let (tx, mut rx) = watch::channel("one"); in rx_observes_final_value()
126 let (tx, mut rx) = watch::channel("one"); in rx_observes_final_value()
158 let (tx, rx) = watch::channel("one"); in poll_close()
|