/external/webrtc/webrtc/system_wrappers/source/ |
D | condition_variable_unittest.cc | 40 cond_var_(ConditionVariableWrapper::CreateConditionVariable()), in Baton() 48 delete cond_var_; in ~Baton() 86 if (!cond_var_->SleepCS(*crit_sect_, timeout_ms)) { in WaitUntilBatonOffered() 91 cond_var_->Wake(); in WaitUntilBatonOffered() 98 cond_var_->Wake(); in SignalBatonAvailable() 110 not_timeout = cond_var_->SleepCS(*crit_sect_, timeout_ms); in TakeBatonIfStillFree() 130 ConditionVariableWrapper* cond_var_; member in webrtc::__anon1f132e4c0111::Baton
|
/external/tensorflow/tensorflow/core/kernels/data/ |
D | parallel_map_iterator.cc | 56 cond_var_(std::make_shared<condition_variable>()), in ParallelMapIterator() 58 params.num_parallel_calls, mu_, cond_var_)), in ParallelMapIterator() 68 cond_var_->notify_all(); in ~ParallelMapIterator() 71 cond_var_->wait(l); in ~ParallelMapIterator() 93 cond_var_->wait(l); in GetNextInternal() 117 cond_var_->wait(l); in SaveInternal() 214 cond_var_->notify_all(); in CallCompleted() 289 cond_var_->wait(l); in RunnerThread() 307 cond_var_->notify_all(); in RunnerThread() 327 cond_var_->notify_all(); in ShouldWait() [all …]
|
D | parallel_interleave_dataset_op.cc | 205 cond_var_(std::make_shared<condition_variable>()), in ParallelInterleaveIterator() 207 params.dataset->num_parallel_calls_, mu_, cond_var_)), in ParallelInterleaveIterator() 221 cond_var_->notify_all(); in ~ParallelInterleaveIterator() 224 cond_var_->wait(l); in ~ParallelInterleaveIterator() 248 cond_var_->wait(l); in GetNextInternal() 277 cond_var_->wait(l); in SaveInternal() 390 cond_var_->notify_all(); in ConsumeHelper() 401 cond_var_->notify_all(); in ConsumeHelper() 465 cond_var_->wait(l); in CurrentElementsManager() 512 cond_var_->notify_all(); in CurrentElementsManager() [all …]
|
D | prefetch_dataset_op.cc | 97 cond_var_.notify_all(); in ~Iterator() 118 cond_var_.wait(l); in GetNextInternal() 262 cond_var_.notify_all(); in Consume() 290 cond_var_.wait(l); in PrefetchThread() 313 cond_var_.notify_all(); in PrefetchThread() 322 cond_var_.notify_all(); in PrefetchThread() 371 condition_variable cond_var_; member in tensorflow::data::PrefetchDatasetOp::Dataset::Iterator
|
D | model_dataset_op.cc | 104 cond_var_.notify_all(); in ~Iterator() 168 cond_var_.wait_for( in OptimizeThread() 191 condition_variable cond_var_; member in tensorflow::data::__anoncf0bc9ca0111::ModelDatasetOp::Dataset::Iterator
|
/external/tensorflow/tensorflow/core/lib/core/ |
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
|
/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/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 | 159 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 | 259 cond_var_(std::make_shared<condition_variable>()), in Iterator() 261 params.dataset->num_parallel_calls_, mu_, cond_var_)), in Iterator() 273 cond_var_->notify_all(); in ~Iterator() 276 cond_var_->wait(l); in ~Iterator() 302 cond_var_->wait(l); in GetNextInternal() 308 cond_var_->notify_all(); in GetNextInternal() 326 cond_var_->wait(l); in SaveInternal() 408 cond_var_->notify_all(); in CallCompleted() 627 cond_var_->wait(l); in RunnerThread() 787 const std::shared_ptr<condition_variable> cond_var_; member in tensorflow::data::__anon2c387ec70111::MapAndBatchDatasetOp::Dataset::Iterator
|
/external/tensorflow/tensorflow/core/framework/ |
D | dataset.cc | 444 cond_var_.notify_one(); in ~BackgroundWorker() 458 cond_var_.notify_one(); in Schedule() 467 cond_var_.wait(l); in WorkerLoop()
|
D | dataset.h | 937 condition_variable cond_var_; variable
|