| /external/libhevc/encoder/ |
| D | osal_cond_var.c | 120 if(0 != pthread_cond_init(&(cond_var_handle->cond_var), 0)) in osal_cond_var_create()
171 status = pthread_cond_destroy(&(handle->cond_var)); in osal_cond_var_destroy()
217 cond_var_handle_t *cond_var = (cond_var_handle_t *)cond_var_handle; in osal_cond_var_wait() local
219 return pthread_cond_wait(&(cond_var->cond_var), &(mutex->mutex_handle)); in osal_cond_var_wait()
256 cond_var_handle_t *cond_var = (cond_var_handle_t *)cond_var_handle; in osal_cond_var_signal() local
257 return pthread_cond_signal(&(cond_var->cond_var)); in osal_cond_var_signal()
|
| D | osal_cond_var.h | 44 pthread_cond_t cond_var; /* Mutex Identifier */ member
|
| /external/autotest/client/deps/lansim/src/py/ |
| D | simulator.py | 345 cond_var = threading.Condition(lock_cond)
353 callback, ret, cond_var, condition)
362 with cond_var:
365 cond_var.wait()
370 cond_var.wait(cur_timeout)
377 def _condition_poller(self, callback, ref_value, cond_var, func): argument
384 with cond_var:
387 cond_var.notify()
|
| /external/ltp/testcases/realtime/func/pi-tests/ |
| D | testpi-1.c | 79 static pthread_cond_t cond_var = PTHREAD_COND_INITIALIZER; variable
96 pthread_cond_wait(&cond_var, &cond_mutex); in func_nonrt()
153 pthread_cond_broadcast(&cond_var); in func_noise()
218 pthread_cond_destroy(&cond_var); in main()
|
| D | testpi-4.c | 80 static pthread_cond_t cond_var = PTHREAD_COND_INITIALIZER; variable
98 pthread_cond_wait(&cond_var, &cond_mutex); in func_nonrt()
154 pthread_cond_broadcast(&cond_var); in func_noise()
222 pthread_cond_destroy(&cond_var); in main()
|
| D | testpi-2.c | 81 static pthread_cond_t cond_var = PTHREAD_COND_INITIALIZER; variable
98 pthread_cond_wait(&cond_var, &cond_mutex); in func_lowrt()
155 pthread_cond_broadcast(&cond_var); in func_noise()
219 pthread_cond_destroy(&cond_var); in main()
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | parallel_interleave_dataset_op.cc | 249 worker.cond_var.notify_all(); in ~Iterator()
303 current_worker->cond_var.notify_one(); in GetNextInternal()
358 workers_[interleave_indices_[next_index_]].cond_var.wait(l); in GetNextInternal()
536 condition_variable cond_var; member
549 cond_var.notify_one(); in SetInputs()
637 workers_[thread_index].cond_var.notify_all(); in WorkerThread()
677 workers_[thread_index].cond_var.wait(l); in WorkerThread()
729 workers_[thread_index].cond_var.wait(l); in WorkerThread()
742 workers_[thread_index].cond_var.notify_one(); in WorkerThread()
780 workers_[thread_index].cond_var.wait(l); in WorkerThread()
[all …]
|
| /external/webrtc/webrtc/system_wrappers/source/ |
| D | condition_variable_unittest.cc | 191 rtc::scoped_ptr<ConditionVariableWrapper> cond_var( in TEST() local
195 EXPECT_FALSE(cond_var->SleepCS(*(crit_sect), kVeryShortWaitMs)); in TEST()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | model.h | 45 std::shared_ptr<condition_variable> cond_var) in SharedState()
48 cond_var(std::move(cond_var)), in SharedState()
53 std::shared_ptr<condition_variable> cond_var; member
|
| D | model.cc | 462 parameter->state->cond_var->notify_all(); in Optimize()
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | multi_device_iterator_ops.cc | 160 buffer_[i].cond_var.notify_all(); in Reset()
199 buffer_[shard_num].cond_var.notify_all(); in GetNextFromShard()
280 buffer_[shard_to_fetch].cond_var.wait(l); in BackgroundThread()
330 condition_variable cond_var; member
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | ram_file_block_cache.cc | 141 block->cond_var.notify_all(); in MaybeFetch()
144 block->cond_var.wait_for(l, std::chrono::seconds(60)); in MaybeFetch()
|
| D | ram_file_block_cache.h | 182 condition_variable cond_var; member
|