| /external/tensorflow/tensorflow/core/platform/ |
| D | port_test.cc | 141 m.Await(Condition(&ping_pong)); in TEST()
150 m.Await(Condition(&Invert, &ping_pong)); in TEST()
153 m.Await(Condition(&done)); in TEST()
165 m.Await(Condition(&ping_pong)); in TEST()
174 m.Await(Condition(&invert, &InvertClass::Value)); in TEST()
177 m.Await(Condition(&done)); in TEST()
|
| /external/tensorflow/tensorflow/compiler/xla/pjrt/ |
| D | tracked_tfrt_cpu_device_buffer_test.cc | 48 tfrt::Await({tracked_buffer.definition_event().GetAsyncValue()}); in TEST()
86 tfrt::Await({tracked_buffer.definition_event().GetAsyncValue()}); in TEST()
117 tfrt::Await({tracked_buffer.definition_event().GetAsyncValue()}); in TEST()
152 tfrt::Await({tracked_buffer.definition_event().GetAsyncValue()}); in TEST()
|
| D | tracked_device_buffer.cc | 58 mu_.Await( in WaitForEventOnStream()
78 mu_.Await( in DefinedOn()
92 mu_.Await( in IsComplete()
|
| D | pjrt_future.h | 211 T Await() { in Await() function
215 tfrt::Await({promise_ref_.GetAsyncValue()}); in Await()
|
| /external/tensorflow/tensorflow/compiler/xla/runtime/ |
| D | async_runtime.cc | 220 void AsyncRuntime::Await(AsyncValue* awaitable) { in Await() function in xla::runtime::AsyncRuntime
223 tfrt::Await({awaitable}); in Await()
281 Await(token->GetAsyncValue()); in AwaitToken()
314 Await(value->GetAsyncValue()); in AwaitValue()
331 Await(group->GetCompletionAsyncValue()); in AwaitGroup()
|
| /external/tensorflow/tensorflow/tsl/platform/default/ |
| D | mutex.h | 50 inline void mutex::Await(const Condition& cond) { in Await() function
51 mu_.Await(absl::Condition(&cond, &Condition::Eval)); in Await()
|
| /external/tensorflow/tensorflow/core/tfrt/runtime/ |
| D | work_queue_interface.cc | 46 void Await( in Await() function in tensorflow::tfrt_stub::__anonb6644c1f0111::DefaultWorkQueueWrapperBase
48 work_queue_->Await(values); in Await()
|
| /external/tensorflow/tensorflow/core/tfrt/run_handler_thread_pool/ |
| D | run_handler_concurrent_work_queue.cc | 99 void RunHandlerThreadWorkQueue::Await( in Await() function in tfrt::tf::RunHandlerThreadWorkQueue
101 tfrt::Await(values); in Await()
|
| /external/tensorflow/tensorflow/compiler/xla/python/ |
| D | py_executable.cc | 30 Status PyToken::Await() { in Await() function in xla::PyToken
33 return future_.Await(); in Await()
36 Status PyShardedToken::Await() { in Await() function in xla::PyShardedToken
40 auto s = future.Await(); in Await()
|
| D | py_executable.h | 43 Status Await();
62 Status Await();
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/ |
| D | mutex_test.cc | 158 cxt->mu.Await(absl::Condition(&mc, &MyContext::MyTurn)); in TestAwait()
334 cxt->mu.Await(g0ge2); in TestTime()
447 state.release_mu.Await(absl::Condition(&state.release)); in TEST()
488 state.release_mu.Await(absl::Condition(&state.release)); in TEST()
531 x.mu.Await(absl::Condition(&NoAWaiters, &x)); // wait for them to exit in TEST()
764 x->mu2.Await(absl::Condition(&x->complete)); in GetReadLock()
809 x.mu.Await(absl::Condition(&AllDone, &x)); in TEST()
928 mu.Await(absl::Condition(&IntIsZero, &running));
1389 TEST_P(TimeoutTest, Await) { argument
1633 TEST_P(MutexVariableThreadCountTest, Await) { argument
|
| D | barrier.cc | 39 this->lock_.Await(Condition(IsZero, &this->num_to_block_)); in Block()
|
| D | blocking_counter.cc | 48 this->lock_.Await(Condition(IsZero, &this->count_)); in Wait()
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/ |
| D | barrier.cc | 39 this->lock_.Await(Condition(IsZero, &this->num_to_block_)); in Block()
|
| D | blocking_counter.cc | 48 this->lock_.Await(Condition(IsZero, &this->count_)); in Wait()
|
| /external/tensorflow/third_party/absl/abseil-cpp/absl/synchronization/ |
| D | barrier.cc | 39 this->lock_.Await(Condition(IsZero, &this->num_to_block_)); in Block()
|
| /external/angle/third_party/abseil-cpp/absl/synchronization/ |
| D | barrier.cc | 39 this->lock_.Await(Condition(IsZero, &this->num_to_block_)); in Block()
|
| D | blocking_counter.cc | 58 this->lock_.Await(Condition(IsDone, &this->done_)); in Wait()
|
| /external/abseil-cpp/absl/synchronization/ |
| D | barrier.cc | 39 this->lock_.Await(Condition(IsZero, &this->num_to_block_)); in Block()
|
| D | blocking_counter.cc | 58 this->lock_.Await(Condition(IsDone, &this->done_)); in Wait()
|
| /external/cronet/third_party/abseil-cpp/absl/synchronization/ |
| D | barrier.cc | 39 this->lock_.Await(Condition(IsZero, &this->num_to_block_)); in Block()
|
| D | blocking_counter.cc | 58 this->lock_.Await(Condition(IsDone, &this->done_)); in Wait()
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/ |
| D | barrier.cc | 39 this->lock_.Await(Condition(IsZero, &this->num_to_block_)); in Block()
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/ |
| D | barrier.cc | 39 this->lock_.Await(Condition(IsZero, &this->num_to_block_)); in Block()
|
| D | blocking_counter.cc | 48 this->lock_.Await(Condition(IsZero, &this->count_)); in Wait()
|