/foundation/multimedia/media_foundation/interface/inner_api/osal/task/ |
H A D | condition_variable.h | 42 bool WaitFor(AutoLock& lock, int64_t timeoutMs); 44 bool WaitFor(AutoLock& lock, int64_t timeoutMs, std::function<bool()> pred);
|
H A D | blocking_queue.h | 83 cvFull_.WaitFor(lock, timeoutMs, [this] { return !isActive || que_.size() < capacity_; }); in Push() 123 cvEmpty_.WaitFor(lock, timeoutMs, [this] { return !isActive || !que_.empty(); }); in Pop()
|
/foundation/multimedia/media_foundation/src/osal/task/ffrt/ |
H A D | condition_variable.cpp | 52 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs) in WaitFor() function in OHOS::Media::ConditionVariable 62 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs, std::function<bool()> pred) in WaitFor() function in OHOS::Media::ConditionVariable
|
/foundation/multimedia/media_foundation/engine/include/foundation/osal/base/ |
H A D | synchronizer.h | 57 bool WaitFor(SyncIdType syncId, const std::function<void()>& asyncOps, int timeoutMs) in WaitFor() function in OHOS::Media::OSAL::Synchronizer 67 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor() 90 bool WaitFor(SyncIdType syncId, const std::function<bool()>& asyncOps, int timeoutMs, ResultType& result) in WaitFor() function in OHOS::Media::OSAL::Synchronizer 103 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor()
|
/foundation/multimedia/media_foundation/src/osal/base/ |
H A D | synchronizer.h | 56 bool WaitFor(SyncIdType syncId, const std::function<void()>& asyncOps, int timeoutMs) in WaitFor() function in OHOS::Media::Synchronizer 66 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor() 89 bool WaitFor(SyncIdType syncId, const std::function<bool()>& asyncOps, int timeoutMs, ResultType& result) in WaitFor() function in OHOS::Media::Synchronizer 102 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor()
|
/foundation/multimedia/media_foundation/engine/include/foundation/osal/thread/ |
H A D | condition_variable.h | 50 bool WaitFor(ScopedLock& lock, int timeoutMs); 53 bool WaitFor(ScopedLock& lock, int timeoutMs, Predicate pred) in WaitFor() function in OHOS::Media::OSAL::ConditionVariable
|
/foundation/multimedia/media_foundation/test/unittest/ |
H A D | TestSynchronizer.cpp | 71 auto rtv = synchronizer.WaitFor( in HWTEST_F() 89 auto rtv = synchronizer.WaitFor( in HWTEST_F() 105 auto rtv = synchronizer.WaitFor( in HWTEST_F()
|
/foundation/multimedia/media_foundation/src/osal/task/pthread/ |
H A D | condition_variable.cpp | 95 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs) in WaitFor() function in OHOS::Media::ConditionVariable 100 false, "WaitFor uninitialized pthread cond"); in WaitFor() 111 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs, std::function<bool()> pred) in WaitFor() function in OHOS::Media::ConditionVariable 116 false, "WaitFor uninitialized pthread cond"); in WaitFor()
|
/foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler_impl/ |
H A D | io_waiter.h | 44 virtual bool WaitFor(std::unique_lock<std::mutex> &lock, int64_t nanoseconds) = 0;
|
H A D | none_io_waiter.h | 34 bool WaitFor(std::unique_lock<std::mutex> &lock, int64_t nanoseconds) final;
|
H A D | none_io_waiter.cpp | 36 bool NoneIoWaiter::WaitFor(std::unique_lock<std::mutex> &lock, int64_t nanoseconds) in WaitFor() function in OHOS::AppExecFwk::NoneIoWaiter
|
H A D | epoll_io_waiter.h | 44 bool WaitFor(std::unique_lock<std::mutex> &lock, int64_t nanoseconds) final;
|
/foundation/communication/netmanager_base/test/netconnmanager/unittest/net_conn_manager_test/ |
H A D | net_detection_callback_test.h | 33 void WaitFor(int timeoutSecond);
|
H A D | net_detection_callback_test.cpp | 32 void NetDetectionCallbackTest::WaitFor(int timeoutSecond) in WaitFor() function in OHOS::NetManagerStandard::NetDetectionCallbackTest
|
H A D | net_conn_callback_test.h | 36 void WaitFor(int timeoutSecond);
|
/foundation/communication/netmanager_base/test/netstatsmanager/unittest/net_stats_manager_test/ |
H A D | net_stats_callback_test.h | 33 void WaitFor(int32_t timeoutSecond);
|
H A D | net_stats_callback_test.cpp | 33 void NetStatsCallbackTest::WaitFor(int32_t timeoutSecond) in WaitFor() function in OHOS::NetManagerStandard::NetStatsCallbackTest
|
/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/ |
H A D | net_policy_callback_test.h | 37 void WaitFor(int32_t timeoutSecond);
|
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/ |
H A D | future.h | 91 StateType WaitFor(const TimeSpan& time) const in WaitFor() function in Future 93 return fut_ ? fut_->WaitFor(time) : IFuture::ABANDONED; in WaitFor()
|
/foundation/multimedia/media_foundation/engine/include/foundation/utils/ |
H A D | blocking_queue.h | 83 cvFull_.WaitFor(lock, timeoutMs, [this] { return !isActive || que_.size() < capacity_; }); in Push() 123 cvEmpty_.WaitFor(lock, timeoutMs, [this] { return !isActive || !que_.empty(); }); in Pop()
|
/foundation/resourceschedule/ffrt/src/queue/ |
H A D | serial_queue.cpp | 52 cond_.WaitFor(lock, std::chrono::microseconds(diff)); in Pull()
|
/foundation/resourceschedule/ffrt/src/sync/ |
H A D | record_condition_variable.h | 26 cv_status WaitFor(std::unique_lock<RecordMutex>& lk, const std::chrono::duration<Rep, Period>& sleep_time) noexcept
|
/foundation/multimedia/media_foundation/engine/plugin/plugins/codec_adapter/ |
H A D | codec_cmd_executor.cpp | 102 cond_.WaitFor(lock, timeout, [&] { in WaitCmdResult() 116 cond_.WaitFor(lock, timeout, [&] { in WaitCmdResult()
|
/foundation/multimedia/av_codec/services/media_engine/modules/sink/ |
H A D | media_synchronous_sink.cpp | 71 if (!prerollCond_.WaitFor(lock, Plugins::HstTime2Ms(waitPrerolledTimeout_), in WriteToPluginRefTimeSync()
|
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/interface/ |
H A D | intf_future.h | 71 virtual StateType WaitFor(const TimeSpan& time) const = 0;
|