Home
last modified time | relevance | path

Searched refs:Notify (Results 1 – 25 of 175) sorted by relevance

1234567

/external/tensorflow/tensorflow/core/kernels/batching_util/
Dshared_batch_scheduler_test.cc204 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 …]
Dadaptive_shared_batch_scheduler_test.cc114 finish_processing.Notify(); in TEST()
190 start_teardown.Notify(); in TEST()
192 stop_teardown.Notify(); in TEST()
260 finish_processing.Notify(); in TEST()
261 start_teardown.Notify(); in TEST()
263 stop_teardown.Notify(); in TEST()
303 finish_processing.Notify(); in TEST()
335 finish_processing.Notify(); in TEST()
382 finish_processing.Notify(); in TEST()
Dserial_device_batch_scheduler_test.cc111 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()
/external/libchrome/base/
Dcallback_list_unittest.cc124 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 …]
Dobserver_list_unittest.cc159 list_->Notify(FROM_HERE, &Foo::Observe, 10); in AddTask()
445 observer_list->Notify(FROM_HERE, &Foo::Observe, 10); in TEST()
451 observer_list->Notify(FROM_HERE, &Foo::Observe, 10); in TEST()
475 observer_list->Notify(FROM_HERE, &Foo::Observe, 10); in TEST()
486 observer_list->Notify(FROM_HERE, &Foo::Observe, 10); in TEST()
508 observer_list->Notify(FROM_HERE, &Foo::Observe, 10); in TEST()
522 observer_list->Notify(FROM_HERE, &Foo::Observe, 20); in TEST()
536 observer_list->Notify(FROM_HERE, &Foo::Observe, 30); in TEST()
581 observer_list->Notify(FROM_HERE, &Foo::Observe, 1); in TEST()
629 observer_list->Notify(FROM_HERE, &Foo::Observe, 10); in ThreadSafeObserverHarness()
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/
Dlocal_master.cc60 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()
Drpc_collective_executor_mgr_test.cc90 note.Notify(); in TEST_F()
113 note.Notify(); in TEST_F()
140 note.Notify(); in TEST_F()
160 note.Notify(); in TEST_F()
Dcollective_rma_distributed_test.cc271 producer_note.Notify(); in TEST_F()
285 consumer_note.Notify(); in TEST_F()
313 consumer_note.Notify(); in TEST_F()
320 producer_note.Notify(); in TEST_F()
345 consumer_note.Notify(); in TEST_F()
/external/tensorflow/tensorflow/core/common_runtime/
Dbuf_rendezvous_test.cc58 note.Notify(); in TEST_F()
100 note.Notify(); in TEST_F()
120 note.Notify(); in TEST_F()
152 cons_note.Notify(); in TEST_F()
157 prod_note.Notify(); in TEST_F()
181 cons_note.Notify(); in TEST_F()
186 prod_note.Notify(); in TEST_F()
Dcollective_rma_local_test.cc75 recv_note.Notify(); in TEST_F()
90 send_note.Notify(); in TEST_F()
118 recv_note.Notify(); in TEST_F()
135 send_note.Notify(); in TEST_F()
Dring_reducer.cc98 note.Notify(); in Run()
132 group_size_tensor_ready_.Notify(); in ContinueAfterInputCopy()
136 group_size_tensor_ready_.Notify(); in ContinueAfterInputCopy()
140 group_size_tensor_ready_.Notify(); in ContinueAfterInputCopy()
180 col_ctx_->device, gpu_info->stream, [&note]() { note.Notify(); }); in RunAsyncParts()
Ddevice_resolver_local_test.cc60 note.Notify(); in TEST_F()
78 note.Notify(); in TEST_F()
Drendezvous_util_test.cc63 &received_keys, [&n](const Status& status) { n.Notify(); }); in TEST_F()
77 &received_keys, [&n](const Status& status) { n.Notify(); }); in TEST_F()
Dcollective_executor_mgr_test.cc79 ss_note.Notify(); in TEST_F()
92 gs_note.Notify(); in TEST_F()
/external/tensorflow/tensorflow/core/lib/core/
Dnotification_test.cc34 start.Notify(); in TEST()
46 proceed.Notify(); in TEST()
76 n.Notify(); in TEST()
83 n.Notify(); in TEST()
/external/tensorflow/tensorflow/core/framework/
Dcancellation_test.cc107 n->Notify(); in TEST()
150 cancel_started.Notify(); in TEST()
158 cancel_complete.Notify(); in TEST()
165 finish_callback.Notify(); in TEST()
/external/tcpdump/tests/
Dlisp_eid_notify.out2 192.168.0.105.4342 > 127.0.0.1.4342: LISP-Map-Notify, flags [none],
18 192.168.0.105.4342 > 127.0.0.1.4342: LISP-Map-Notify, flags [I-xTR-ID-Present],
33 192.168.0.105.4342 > 127.0.0.1.4342: LISP-Map-Notify, flags [I-xTR-ID-Present],
50 192.168.0.105.4342 > 127.0.0.1.4342: LISP-Map-Notify, flags [none],
Dlisp_ipv6.out2 …92.168.0.105.4342 > 127.0.0.1.4342: LISP-Map-Register, flags [I-xTR-ID-Present, M-Want-Map-Notify],
15 192.168.0.105.4342 > 127.0.0.1.4342: LISP-Map-Notify, flags [none],
/external/eigen/unsupported/test/
Dcxx11_eventcount.cpp32 ec.Notify(false); in test_basic_eventcount()
34 ec.Notify(true); in test_basic_eventcount()
97 ec.Notify(false); in test_stress_eventcount()
Dcxx11_tensor_notification.cpp49 n.Notify(); in test_notification_single()
72 n.Notify(); in test_notification_multiple()
/external/tensorflow/tensorflow/cc/training/
Dcoordinator_test.cc34 about_to_wait->Notify(); in WaitForStopThread()
36 done->Notify(); in WaitForStopThread()
153 start.Notify(); in TEST()
193 start.Notify(); in TEST()
/external/eigen/unsupported/Eigen/CXX11/src/Tensor/
DTensorDeviceThreadPool.h37 void Notify() { in Notify() function
83 n->Notify(); in run()
93 b->Notify(); in run()
253 barrier.Notify(); in parallelFor()
/external/tensorflow/tensorflow/core/kernels/
Dcollective_nccl_reducer.cc116 group_size_ready.Notify(); in Run()
119 group_size_ready.Notify(); in Run()
142 nccl_done.Notify(); in Run()
/external/google-breakpad/src/testing/gtest/test/
Dgtest_output_test_.cc274 check_points->n1.Notify(); in ThreadWithScopedTrace()
282 check_points->n3.Notify(); in ThreadWithScopedTrace()
298 check_points.n2.Notify(); in TEST()
473 notifications->spawn_thread_started.Notify(); in ThreadRoutine()
496 notifications_.spawn_thread_ok_to_terminate.Notify(); in TearDown()
/external/libchrome/mojo/public/cpp/system/
Dwait_set.cc245 ->Notify(event->result, event->signals_state); in OnNotification()
253 void Notify(MojoResult result, MojoHandleSignalsState signals_state) { in Notify() function in mojo::WaitSet::State::Context
254 state_->Notify(handle_, result, signals_state, this); in Notify()
265 void Notify(Handle handle, in Notify() function in mojo::WaitSet::State

1234567