Home
last modified time | relevance | path

Searched refs:cond_var_ (Results 1 – 12 of 12) sorted by relevance

/external/webrtc/webrtc/system_wrappers/source/
Dcondition_variable_unittest.cc40 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/
Dparallel_map_iterator.cc56 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 …]
Dparallel_interleave_dataset_op.cc205 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 …]
Dprefetch_dataset_op.cc97 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
Dmodel_dataset_op.cc104 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/
Dblocking_counter.h45 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/
Dexec_on_stall.h63 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/
Dgcs_dns_cache.h47 cond_var_.notify_one(); in ~GcsDnsCache()
64 condition_variable cond_var_; variable
Dgcs_dns_cache.cc159 cond_var_.wait_for(l, std::chrono::seconds(refresh_rate_secs_)); in WorkerThread()
/external/tensorflow/tensorflow/core/kernels/data/experimental/
Dmap_and_batch_dataset_op.cc259 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/
Ddataset.cc444 cond_var_.notify_one(); in ~BackgroundWorker()
458 cond_var_.notify_one(); in Schedule()
467 cond_var_.wait(l); in WorkerLoop()
Ddataset.h937 condition_variable cond_var_; variable