| /foundation/multimedia/player_framework/services/utils/ |
| D | watchdog.cpp | 55 cond_.notify_all(); in DisableWatchDog()
76 cond_.notify_all(); in PauseWatchDog()
85 cond_.notify_all(); in ResumeWatchDog()
97 cond_.notify_all(); in Notify()
101 cond_.notify_all(); in Notify()
121 cond_.wait(lock, [this] { in WatchDogThread()
130 cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs_), [this] { in WatchDogThread()
|
| D | task_queue.cpp | 58 cond_.notify_all(); in Stop()
106 cond_.notify_all(); in EnqueueTask()
131 cond_.wait(lock, [this] { return isExit_ || !taskList_.empty(); }); in TaskProcessor()
142 (void)cond_.wait_for(lock, std::chrono::nanoseconds(diff)); in TaskProcessor()
|
| D | avsharedmemorypool.cpp | 92 cond_.notify_all(); in ReleaseMemory()
193 cond_.wait(lock); in AcquireMemory()
219 cond_.notify_all(); in SetNonBlocking()
236 cond_.notify_all(); in Reset()
|
| /foundation/multimedia/histreamer/engine/foundation/osal/thread/ |
| D | condition_variable.cpp | 48 int rtv = pthread_cond_init(&cond_, &attr); in ConditionVariable()
59 pthread_cond_destroy(&cond_); in ~ConditionVariable()
65 int ret = pthread_cond_signal(&cond_); in NotifyOne()
73 int ret = pthread_cond_broadcast(&cond_); in NotifyAll()
81 pthread_cond_wait(&cond_, &(lock.mutex_->nativeHandle_)); in Wait()
97 return pthread_cond_timedwait(&cond_, &(lock.mutex_->nativeHandle_), in WaitFor()
|
| /foundation/communication/nfc/services/src/utils/ |
| D | synchronize_event.cpp | 34 pthread_cond_init(&cond_, &attr); in SynchronizeEvent()
40 pthread_cond_destroy(&cond_); in ~SynchronizeEvent()
61 int const res = pthread_cond_wait(&cond_, &lock_); in Wait()
82 int waitResult = pthread_cond_timedwait(&cond_, &lock_, &absoluteTime); in Wait()
92 int const res = pthread_cond_signal(&cond_); in NotifyOne()
|
| D | synchronize_event.h | 34 pthread_cond_t cond_; variable
|
| /foundation/resourceschedule/ffrt/src/util/ |
| D | ts_queue.h | 36 cond_.notify_one(); in Push()
42 cond_.wait(lg, [this] { return !queue_.empty(); }); in Pop()
51 std::condition_variable cond_; variable
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/mock/include/ |
| D | mock_app_device_change_listener.h | 37 cond_.notify_all(); in OnDeviceChanged()
44 cond_.wait(lock, [this] { return result_; }); in Wait()
59 mutable std::condition_variable cond_; variable
|
| /foundation/resourceschedule/ffrt/src/queue/ |
| D | serial_task.cpp | 40 cond_.wait(lock); in Wait()
48 cond_.notify_all(); in Notify()
|
| D | serial_queue.cpp | 34 cond_.notify_all(); in Quit()
54 cond_.notify_all(); in PushTask()
91 cond_.wait(lock); in Next()
119 (void)cond_.wait_for(lock, std::chrono::microseconds(diff)); in Next()
|
| D | serial_task.h | 34 ffrt::condition_variable cond_; variable
|
| /foundation/multimedia/player_framework/services/utils/include/ |
| D | task_queue.h | 141 cond_.notify_all();
151 cond_.wait(lock);
162 cond_.notify_all();
208 std::condition_variable cond_;
238 std::condition_variable cond_;
|
| /foundation/multimedia/histreamer/engine/include/foundation/osal/thread/ |
| D | condition_variable.h | 68 status = pthread_cond_timedwait(&cond_, &(lock.mutex_->nativeHandle_), in WaitFor()
79 pthread_cond_t cond_{};
|
| /foundation/multimedia/player_framework/services/engine/gstreamer/avmetadatahelper/ |
| D | avmeta_frame_extractor.cpp | 111 cond_.wait_for(lock, std::chrono::seconds(timeout), [this]() { in ExtractInternel()
161 cond_.wait_for(lock, std::chrono::seconds(timeout), [this]() { in StartExtract()
182 cond_.notify_all(); in StopExtract()
193 cond_.notify_all(); in NotifyPlayBinMsg()
239 thiz->cond_.notify_all(); in OnNewPrerollArrived()
|
| D | avmeta_meta_collector.cpp | 160 cond_.notify_all(); in Stop()
173 cond_.wait_for(lock, std::chrono::seconds(timeout), [this]() { in GetMetadata()
187 cond_.wait_for(lock, std::chrono::seconds(timeout), [this, key]() { in GetMetadata()
310 cond_.notify_all(); in UpdataMeta()
385 cond_.notify_all(); in AddElemBlocker()
|
| /foundation/distributeddatamgr/kv_store/frameworks/common/ |
| D | executor.h | 82 cond_.wait(lock, [this, wait]() { return !wait || running_ == STOPPED; });
112 cond_.notify_all(); in Run()
118 std::condition_variable cond_; variable
|
| /foundation/multimedia/player_framework/services/services/monitor/server/ |
| D | monitor_server.cpp | 93 cond_.notify_all(); in Click()
109 cond_.notify_all(); in EnableMonitor()
144 cond_.notify_all(); in DisableMonitor()
205 cond_.notify_all(); in OnClientDie()
274 cond_.wait_for(lock, std::chrono::milliseconds(GetWaitTime()), [this] { in MonitorThread()
|
| /foundation/multimedia/histreamer/engine/plugin/plugins/codec_adapter/ |
| D | codec_cmd_executor.cpp | 102 cond_.WaitFor(lock, timeout, [&] { in WaitCmdResult()
116 cond_.WaitFor(lock, timeout, [&] { in WaitCmdResult()
176 cond_.NotifyAll(); in HandleEventCmdComplete()
200 cond_.NotifyAll(); in HandleEventError()
|
| /foundation/multimedia/av_codec/services/dfx/ |
| D | avcodec_log_dump.cpp | 49 cond_.notify_all(); in ~AVCodecLogDump()
115 cond_.notify_all(); in SaveLog()
145 cond_.wait_for(lock, std::chrono::seconds(timeout), in TaskProcessor()
|
| D | avcodec_bitstream_dump.cpp | 57 cond_.notify_all(); in ~AVCodecBitStreamDumper()
123 cond_.notify_all(); in SaveBitStream()
149 cond_.wait_for(lock, std::chrono::seconds(timeout), in TaskProcessor()
|
| /foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| D | executor.h | 95 cond_.wait(lock, [this, wait]() { return !wait || running_ == STOPPED; });
125 cond_.notify_all(); in Run()
131 std::condition_variable cond_; variable
|
| /foundation/multimedia/player_framework/services/dfx/ |
| D | dfx_log_dump.cpp | 45 cond_.notify_all(); in ~DfxLogDump()
114 cond_.notify_all(); in SaveLog()
144 cond_.wait_for(lock, std::chrono::seconds(timeout), in TaskProcessor()
|
| D | dfx_log_dump.h | 39 std::condition_variable cond_; variable
|
| /foundation/multimedia/player_framework/frameworks/js/avplayer/ |
| D | media_data_source_callback.cpp | 32 cond_.notify_all(); in ~MediaDataSourceJsCallback()
41 …cond_.wait_for(lock, std::chrono::milliseconds(timeout), [this]() { return setResult_ || isExit_; … in WaitResult()
150 event->cond_.notify_all(); in UvWork()
204 cb_->cond_.notify_all(); in ClearCallbackReference()
|
| /foundation/multimedia/player_framework/services/engine/gstreamer/plugins/codec/hdi_plugins/ |
| D | hdi_venc_in_buffer_mgr.h | 36 std::condition_variable cond_; variable
|