/external/OpenCL-CTS/test_common/harness/ |
D | ThreadPool.cpp | 152 static void _InitializeConditionVariable(_PCONDITION_VARIABLE cond_var) in _InitializeConditionVariable() argument 154 cond_var->mEvent = CreateEvent(NULL, TRUE, FALSE, NULL); in _InitializeConditionVariable() 155 InitializeCriticalSection(cond_var->mLock); in _InitializeConditionVariable() 156 cond_var->mWaiters = 0; in _InitializeConditionVariable() 157 cond_var->mGeneration = 0; in _InitializeConditionVariable() 159 cond_var->mReleaseCount = 0; in _InitializeConditionVariable() 163 static void _SleepConditionVariableCS(_PCONDITION_VARIABLE cond_var, in _SleepConditionVariableCS() argument 167 EnterCriticalSection(cond_var->mLock); in _SleepConditionVariableCS() 168 cl_int generation = cond_var->mGeneration; in _SleepConditionVariableCS() 169 ++cond_var->mWaiters; in _SleepConditionVariableCS() [all …]
|
/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/rust/crates/grpcio-sys/grpc/src/core/lib/gpr/ |
D | sync_posix.cc | 102 GPR_ASSERT(pthread_cond_init(&cv->cond_var, &attr) == 0); in gpr_cv_init() 112 GPR_ASSERT(pthread_cond_destroy(&cv->cond_var) == 0); in gpr_cv_destroy() 124 err = pthread_cond_wait(&cv->cond_var, &mu->mutex); in gpr_cv_wait() 138 err = pthread_cond_timedwait(&cv->cond_var, &mu->mutex, &abs_deadline_ts); in gpr_cv_wait() 149 GPR_ASSERT(pthread_cond_signal(&cv->cond_var) == 0); in gpr_cv_signal() 157 GPR_ASSERT(pthread_cond_broadcast(&cv->cond_var) == 0); in gpr_cv_broadcast()
|
/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-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-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-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 | 340 current_worker->cond_var.notify_one(); in GetNextInternal() 393 workers_[interleave_indices_[next_index_]].cond_var.wait(l); in GetNextInternal() 604 condition_variable cond_var; member 617 cond_var.notify_one(); in SetInputs() 653 worker.cond_var.notify_all(); in CancelThreads() 712 workers_[thread_index].cond_var.notify_all(); in WorkerThread() 751 workers_[thread_index].cond_var.wait(l); in WorkerThread() 804 workers_[thread_index].cond_var.wait(l); in WorkerThread() 817 workers_[thread_index].cond_var.notify_one(); in WorkerThread() 864 workers_[thread_index].cond_var.wait(l); in WorkerThread() [all …]
|
/external/rust/crates/grpcio-sys/grpc/include/grpc/impl/codegen/ |
D | sync_posix.h | 41 pthread_cond_t cond_var; member
|
/external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/impl/codegen/ |
D | sync_posix.h | 41 pthread_cond_t cond_var; member
|
/external/tensorflow/tensorflow/core/framework/ |
D | model.h | 62 std::shared_ptr<condition_variable> cond_var) in SharedState() 65 cond_var(std::move(cond_var)), in SharedState() 70 const std::shared_ptr<condition_variable> cond_var; member
|
D | model.cc | 124 parameter->state->cond_var->notify_all(); in UpdateStateValues()
|
/external/tensorflow/tensorflow/core/kernels/data/ |
D | multi_device_iterator_ops.cc | 179 buffer_[i].cond_var.notify_all(); in Reset() 220 buffer_[shard_num].cond_var.notify_all(); in GetNextFromShard() 228 buffer_[shard_num].cond_var.notify_all(); in GetNextFromShard() 303 buffer_[shard_to_fetch].cond_var.wait(l); in BackgroundThread() 353 condition_variable cond_var; member
|
D | parallel_interleave_dataset_op.cc | 369 current_elements_[cycle_index_]->cond_var.wait(l); in GetNextInternal() 548 condition_variable cond_var; member 570 element->cond_var.notify_all(); in CancelThreads() 889 element->cond_var.notify_one(); in FutureWorkerThread() 1037 void WaitWorkerThread(condition_variable* cond_var, mutex_lock* l) in WaitWorkerThread() argument 1041 cond_var->wait(*l); in WaitWorkerThread() 1049 element->cond_var.notify_one(); in NotifyElementUpdate()
|
/external/tensorflow/tensorflow/core/platform/cloud/ |
D | ram_file_block_cache.cc | 151 block->cond_var.notify_all(); in MaybeFetch() 154 block->cond_var.wait_for(l, std::chrono::seconds(60)); in MaybeFetch()
|
D | ram_file_block_cache.h | 183 condition_variable cond_var; member
|
/external/tensorflow/tensorflow/c/experimental/filesystem/plugins/gcs/ |
D | ram_file_block_cache.cc | 150 block->cond_var.SignalAll(); in MaybeFetch() 153 block->cond_var.WaitWithTimeout(&block->mu, absl::Minutes(1)); in MaybeFetch()
|
D | ram_file_block_cache.h | 199 absl::CondVar cond_var; member
|