| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | shared_batch_scheduler_test.cc | 204 first_batch_processed.Notify(); in TEST()
206 second_batch_processed.Notify(); in TEST()
208 third_batch_processed.Notify(); in TEST()
252 start_teardown.Notify(); in TEST()
254 stop_teardown.Notify(); in TEST()
263 first_batch_processed.Notify(); in TEST()
265 second_batch_processed.Notify(); in TEST()
306 first_batch_processed.Notify(); in TEST()
308 second_batch_processed.Notify(); in TEST()
334 start_teardown.Notify(); in TEST()
[all …]
|
| D | serial_device_batch_scheduler_test.cc | 111 finish_processing.Notify(); in TEST()
193 start_processing.Notify(); in TEST()
255 start_teardown.Notify(); in TEST()
257 stop_teardown.Notify(); in TEST()
306 finish_processing.Notify(); in TEST()
327 finish_processing.Notify(); in TEST()
343 start_processing.Notify(); in TEST()
390 finish_processing.Notify(); in TEST()
|
| D | adaptive_shared_batch_scheduler_test.cc | 117 finish_processing.Notify(); in TEST()
197 start_teardown.Notify(); in TEST()
199 stop_teardown.Notify(); in TEST()
270 finish_processing.Notify(); in TEST()
271 start_teardown.Notify(); in TEST()
273 stop_teardown.Notify(); in TEST()
311 1000, [&finish_processing] { finish_processing.Notify(); }); in TEST()
356 finish_processing.Notify(); in TEST()
|
| /external/rust/crates/tokio/tests/ |
| D | sync_notify.rs | 4 use tokio::sync::Notify;
9 impl AssertSend for Notify {} implementation
13 let notify = Notify::new(); in notify_notified_one()
22 let notify = Notify::new(); in notified_one_notify()
34 let notify = Notify::new(); in notified_multi_notify()
51 let notify = Notify::new(); in notify_notified_multi()
69 let notify = Notify::new(); in notified_drop_notified_notify()
86 let notify = Notify::new(); in notified_multi_notify_drop_one()
110 let notify = Arc::new(Notify::new()); in notify_in_drop_after_wake()
112 struct NotifyOnDrop(Arc<Notify>); in notify_in_drop_after_wake()
[all …]
|
| /external/perfetto/src/base/ |
| D | task_runner_unittest.cc | 113 evt.Notify(); in TEST_F()
120 evt.Notify(); in TEST_F()
135 evt.Notify(); in TEST_F()
153 evt.Notify(); in TEST_F()
154 evt2.Notify(); in TEST_F()
167 evt.Notify(); in TEST_F()
172 evt2.Notify(); in TEST_F()
189 evt.Notify(); in TEST_F()
192 evt2.Notify(); in TEST_F()
207 evt.Notify(); in TEST_F()
[all …]
|
| D | event_fd.cc | 50 void EventFd::Notify() { in Notify() function in perfetto::base::EventFd
68 void EventFd::Notify() { in Notify() function in perfetto::base::EventFd
92 void EventFd::Notify() { in Notify() function in perfetto::base::EventFd
|
| /external/libchrome/base/ |
| D | callback_list_unittest.cc | 124 c1.Notify(1); in TEST()
131 c2.Notify(1, 2); in TEST()
138 c3.Notify(1, 2, 3); in TEST()
145 c4.Notify(1, 2, 3, 4); in TEST()
152 c5.Notify(1, 2, 3, 4, 5); in TEST()
160 c6.Notify(1, 2, 3, 4, 5, 6); in TEST()
178 cb_reg.Notify(); in TEST()
188 cb_reg.Notify(); in TEST()
213 cb_reg.Notify(10); in TEST()
223 cb_reg.Notify(10); in TEST()
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | local_master.cc | 60 n.Notify(); in CreateSession()
74 n.Notify(); in ExtendSession()
88 n.Notify(); in PartialRunSetup()
103 n.Notify(); in RunStep()
125 n.Notify(); in CloseSession()
139 n.Notify(); in ListDevices()
153 n.Notify(); in Reset()
167 n.Notify(); in MakeCallable()
181 n.Notify(); in RunCallable()
194 n.Notify(); in ReleaseCallable()
|
| D | collective_rma_distributed_test.cc | 314 producer_note.Notify(); in TEST_F()
330 consumer_note.Notify(); in TEST_F()
360 consumer_note.Notify(); in TEST_F()
367 producer_note.Notify(); in TEST_F()
395 consumer_note.Notify(); in TEST_F()
423 consumer_note.Notify(); in TEST_F()
430 producer_note.Notify(); in TEST_F()
451 post_restart_note.Notify(); in TEST_F()
465 check_health_done.Notify(); in TEST_F()
478 check_health_done.Notify(); in TEST_F()
[all …]
|
| D | rpc_collective_executor_mgr_test.cc | 93 note.Notify(); in TEST_F()
116 note.Notify(); in TEST_F()
143 note.Notify(); in TEST_F()
163 note.Notify(); in TEST_F()
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 111 pub struct Notify { struct
147 notify: &'a Notify,
195 impl Notify { implementation
205 pub fn new() -> Notify { in new()
206 Notify { in new()
223 pub const fn const_new() -> Notify { in const_new()
224 Notify { in const_new()
457 impl Default for Notify { implementation
458 fn default() -> Notify { in default()
459 Notify::new() in default()
[all …]
|
| /external/libchrome/base/memory/ |
| D | memory_pressure_listener.cc | 34 void Notify( in Notify() function in base::__anon09a089580111::MemoryPressureObserver
36 async_observers_->Notify(FROM_HERE, &MemoryPressureListener::Notify, in Notify()
80 void MemoryPressureListener::Notify(MemoryPressureLevel memory_pressure_level) { in Notify() function in base::MemoryPressureListener
126 GetMemoryPressureObserver()->Notify(memory_pressure_level); in DoNotifyMemoryPressure()
|
| D | memory_coordinator_client_registry.cc | 32 void MemoryCoordinatorClientRegistry::Notify(MemoryState state) { in Notify() function in base::MemoryCoordinatorClientRegistry
33 clients_->Notify(FROM_HERE, in Notify()
38 clients_->Notify(FROM_HERE, &base::MemoryCoordinatorClient::OnPurgeMemory); in PurgeMemory()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | buf_rendezvous_test.cc | 93 note.Notify(); in TEST_F()
142 note.Notify(); in TEST_F()
164 note.Notify(); in TEST_F()
201 cons_note.Notify(); in TEST_F()
208 prod_note.Notify(); in TEST_F()
234 cons_note.Notify(); in TEST_F()
241 prod_note.Notify(); in TEST_F()
265 note.Notify(); in TEST_F()
279 note.Notify(); in TEST_F()
299 note.Notify(); in TEST_F()
[all …]
|
| D | collective_rma_local_test.cc | 82 recv_note.Notify(); in TEST_F()
97 send_note.Notify(); in TEST_F()
125 recv_note.Notify(); in TEST_F()
142 send_note.Notify(); in TEST_F()
162 done.Notify(); in TEST_F()
182 recv_note.Notify(); in TEST_F()
205 recv_note.Notify(); in TEST_F()
225 send_note.Notify(); in TEST_F()
247 send_note.Notify(); in TEST_F()
|
| /external/tensorflow/tensorflow/core/lib/core/ |
| D | notification_test.cc | 34 start.Notify(); in TEST()
46 proceed.Notify(); in TEST()
76 n.Notify(); in TEST()
83 n.Notify(); in TEST()
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_notify.rs | 1 use crate::sync::Notify;
10 let tx = Arc::new(Notify::new()); in notify_one()
27 let notify = Arc::new(Notify::new()); in notify_waiters()
48 let notify = Arc::new(Notify::new()); in notify_multi()
82 let notify = Arc::new(Notify::new()); in notify_drop()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | cancellation_test.cc | 112 n->Notify(); in TEST()
132 started_cancelling.Notify(); in TEST()
137 cancel_done.Notify(); in TEST()
141 can_finish_cancel.Notify(); in TEST()
179 cancel_started.Notify(); in TEST()
187 cancel_complete.Notify(); in TEST()
194 finish_callback.Notify(); in TEST()
|
| /external/libchrome/base/power_monitor/ |
| D | power_monitor.cc | 52 observers_->Notify(FROM_HERE, &PowerObserver::OnPowerStateChange, in NotifyPowerStateChange()
58 observers_->Notify(FROM_HERE, &PowerObserver::OnSuspend); in NotifySuspend()
63 observers_->Notify(FROM_HERE, &PowerObserver::OnResume); in NotifyResume()
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_oneshot.rs | 1 use loom::sync::Notify;
7 notify: Notify::new(), in channel()
28 notify: Notify,
|
| /external/libchrome/base/android/ |
| D | application_status_listener.cc | 52 void ApplicationStatusListener::Notify(ApplicationState state) { in Notify() function in base::android::ApplicationStatusListener
59 g_observers.Get().Notify(FROM_HERE, &ApplicationStatusListener::Notify, in NotifyApplicationStateChange()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | connectivity_state.cc | 93 void AsyncConnectivityStateWatcherInterface::Notify( in Notify() function in grpc_core::AsyncConnectivityStateWatcherInterface
113 p.second->Notify(GRPC_CHANNEL_SHUTDOWN, absl::Status()); in ~ConnectivityStateTracker()
132 watcher->Notify(current_state, status_); in AddWatcher()
169 p.second->Notify(state, status); in SetState()
|
| /external/libchrome/components/policy/core/common/ |
| D | schema_registry.cc | 52 Notify(true); in RegisterComponents()
60 Notify(false); in UnregisterComponent()
118 void SchemaRegistry::Notify(bool has_new_schemas) { in Notify() function in policy::SchemaRegistry
214 Notify(has_new_schemas); in Combine()
254 Notify(has_new_schemas); in OnSchemaRegistryUpdated()
|
| /external/llvm-project/llvm/lib/Support/ |
| D | ThreadPool.cpp | 53 bool Notify; in ThreadPool() local
58 Notify = workCompletedUnlocked(); in ThreadPool()
62 if (Notify) in ThreadPool()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | shell.rs | 6 use crate::sync::Notify;
18 notify: Notify,
33 notify: Notify::new(), in new()
|