| /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
|