| /external/tensorflow/tensorflow/core/platform/ |
| D | blocking_counter.h | 45 cond_var_.notify_all(); in DecrementCount()
53 cond_var_.wait(l); in Wait()
63 const std::cv_status status = cond_var_.wait_for(l, ms); in WaitFor()
73 condition_variable cond_var_; variable
|
| D | unbounded_work_queue_test.cc | 40 cond_var_.notify_all(); in RunMultipleCopiesOfClosure()
48 cond_var_.wait(l); in BlockUntilClosuresDone()
62 condition_variable cond_var_; member in tensorflow::__anonfad0c5250111::UnboundedWorkQueueTest
|
| /external/tensorflow/tensorflow/core/util/ |
| D | exec_on_stall.h | 63 cond_var_.notify_all(); in disabled_()
73 cond_var_.wait(l); in ~ExecuteOnStall()
79 condition_variable cond_var_; variable
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | parallel_batch_dataset_op.cc | 172 cond_var_(std::make_shared<condition_variable>()), in Iterator()
174 params.dataset->num_parallel_calls_, mu_, cond_var_)) {} in Iterator()
203 cond_var_->wait(l); in GetNextInternal()
212 cond_var_->notify_all(); in GetNextInternal()
246 cond_var_->wait(l); in SaveInternal()
311 cond_var_->notify_all(); in CallCompleted()
381 cond_var_->notify_all(); in CancelThreads()
384 cond_var_->wait(l); in CancelThreads()
418 cond_var_->wait(l); in RunnerThread()
495 const std::shared_ptr<condition_variable> cond_var_; member in tensorflow::data::ParallelBatchDatasetOp::Dataset::Iterator
|
| D | prefetch_dataset_op.cc | 137 cond_var_(std::make_shared<condition_variable>()), in Iterator()
146 cond_var_)) { in Iterator()
181 cond_var_->wait(l); in GetNextInternal()
188 cond_var_->wait(l); in GetNextInternal()
362 cond_var_->notify_all(); in CancelThreads()
426 cond_var_->notify_all(); in Consume()
455 cond_var_->wait(l); in PrefetchThread()
461 cond_var_->notify_all(); in PrefetchThread()
495 cond_var_->notify_all(); in PrefetchThread()
505 cond_var_->notify_all(); in PrefetchThread()
[all …]
|
| D | parallel_map_dataset_op.cc | 206 cond_var_(std::make_shared<condition_variable>()), in Iterator()
208 params.dataset->num_parallel_calls_, mu_, cond_var_)), in Iterator()
248 cond_var_->wait(l); in GetNextInternal()
282 cond_var_->wait(l); in SaveInternal()
387 cond_var_->notify_all(); in CancelThreads()
390 cond_var_->wait(l); in CancelThreads()
415 cond_var_->notify_all(); in CallCompleted()
522 cond_var_->wait(l); in RunnerThread()
533 cond_var_->notify_all(); in RunnerThread()
561 cond_var_->notify_all(); in ShouldWait()
[all …]
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | gcs_dns_cache.h | 47 cond_var_.notify_one(); in ~GcsDnsCache()
64 condition_variable cond_var_; variable
|
| D | gcs_dns_cache.cc | 161 cond_var_.wait_for(l, std::chrono::seconds(refresh_rate_secs_)); in WorkerThread()
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | map_and_batch_dataset_op.cc | 192 cond_var_(std::make_shared<condition_variable>()), in Iterator()
194 params.dataset->num_parallel_calls_, mu_, cond_var_)) { in Iterator()
241 cond_var_->wait(l); in GetNextInternal()
250 cond_var_->notify_all(); in GetNextInternal()
285 cond_var_->wait(l); in SaveInternal()
390 cond_var_->notify_all(); in CallCompleted()
480 cond_var_->notify_all(); in CancelThreads()
483 cond_var_->wait(l); in CancelThreads()
556 cond_var_->wait(l); in RunnerThread()
655 const std::shared_ptr<condition_variable> cond_var_; member in tensorflow::data::experimental::MapAndBatchDatasetOp::Dataset::Iterator
|
| D | parse_example_dataset_op.cc | 367 cond_var_(std::make_shared<condition_variable>()), in Iterator()
369 params.dataset->num_parallel_calls_, mu_, cond_var_)), in Iterator()
401 cond_var_->wait(l); in GetNextInternal()
433 cond_var_->wait(l); in SaveInternal()
543 cond_var_->notify_all(); in CancelThreads()
546 cond_var_->wait(l); in CancelThreads()
572 cond_var_->notify_all(); in CallCompleted()
760 cond_var_->wait(l); in RunnerThread()
772 cond_var_->notify_all(); in RunnerThread()
800 cond_var_->notify_all(); in ShouldWait()
[all …]
|
| D | snapshot_dataset_op.cc | 1353 cond_var_.notify_all(); in ~SnapshotReaderIterator()
1355 cond_var_.wait(l); in ~SnapshotReaderIterator()
1411 cond_var_.wait(l); in GetNextInternal()
1468 cond_var_.notify_all(); in GetNextInternal()
1596 cond_var_.wait(l); in ReadFile()
1617 cond_var_.notify_all(); in ReadFile()
1643 cond_var_.notify_all(); in ReadingFilesLoop()
1666 cond_var_.notify_all(); in ReadingFilesLoop()
1676 cond_var_.notify_all(); in ReadingFilesLoop()
1726 condition_variable cond_var_; member in tensorflow::data::experimental::__anon94f7b5240311::SnapshotDatasetOp::Dataset::Iterator::SnapshotReaderIterator
[all …]
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | dataset.cc | 705 cond_var_.notify_one(); in ~BackgroundWorker()
723 cond_var_.notify_one(); in Schedule()
733 cond_var_.wait(l); in WorkerLoop()
|
| D | dataset.h | 1229 condition_variable cond_var_; variable
|