Home
last modified time | relevance | path

Searched refs:pred (Results 1 - 25 of 26) sorted by relevance

12

/foundation/multimedia/media_foundation/engine/include/foundation/osal/thread/
H A Dcondition_variable.h43 void Wait(ScopedLock& lock, Predicate pred) noexcept
45 while (!pred()) {
53 bool WaitFor(ScopedLock& lock, int timeoutMs, Predicate pred) in WaitFor() argument
67 while (!pred() && (status == 0)) { in WaitFor()
71 return pred(); in WaitFor()
/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Dcondition_variable.cpp45 void ConditionVariable::Wait(AutoLock& lock, std::function<bool()> pred) noexcept
47 while (!pred()) {
62 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs, std::function<bool()> pred) in WaitFor() argument
64 return cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs), pred); in WaitFor()
/foundation/resourceschedule/ffrt/interfaces/kits/cpp/
H A Dcondition_variable.h51 std::unique_lock<mutex>& lk, const std::chrono::time_point<Clock, Duration>& tp, Pred&& pred) noexcept
53 while (!pred()) {
55 return pred();
75 std::unique_lock<mutex>& lk, const std::chrono::duration<Rep, Period>& sleepTime, Pred&& pred) noexcept
77 return wait_until(lk, std::chrono::steady_clock::now() + sleepTime, std::forward<Pred>(pred));
81 void wait(std::unique_lock<mutex>& lk, Pred&& pred) in wait() argument
83 while (!pred()) { in wait()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvstore_sync_manager.cpp71 auto pred = [syncId](const KvSyncOperation &op) -> bool { return syncId == op.syncId; }; in RemoveSyncOperation() local
73 uint32_t count = DoRemoveSyncingOp(pred, realtimeSyncingOps_); in RemoveSyncOperation()
74 count += DoRemoveSyncingOp(pred, delaySyncingOps_); in RemoveSyncOperation()
77 if (pred(it->second)) { in RemoveSyncOperation()
87 uint32_t KvStoreSyncManager::DoRemoveSyncingOp(OpPred pred, std::list<KvSyncOperation> &syncingOps) in DoRemoveSyncingOp() argument
91 if (pred(*it)) { in DoRemoveSyncingOp()
104 auto pred = [opSeq](const KvSyncOperation &op) -> bool { return opSeq == op.opSeq; }; in RemoveSyncingOp() local
106 uint32_t count = DoRemoveSyncingOp(pred, syncingOps); in RemoveSyncingOp()
H A Dkvstore_sync_manager.h62 uint32_t DoRemoveSyncingOp(OpPred pred, std::list<KvSyncOperation> &syncingOps);
/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A Dcondition_variable.cpp87 void ConditionVariable::Wait(AutoLock& lock, std::function<bool()> pred) noexcept
90 while (!pred()) {
111 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs, std::function<bool()> pred) in WaitFor() argument
125 while (!pred() && (status == 0)) { in WaitFor()
128 return pred(); in WaitFor()
/foundation/multimedia/media_foundation/interface/inner_api/osal/task/
H A Dcondition_variable.h40 void Wait(AutoLock& lock, std::function<bool()> pred) noexcept;
44 bool WaitFor(AutoLock& lock, int64_t timeoutMs, std::function<bool()> pred);
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/utils/
H A Dmedia_cached_buffer.h121 FragmentIterator GetOffsetFragmentCache(FragmentIterator& fragmentPos, uint64_t offset, Pred pred) in GetOffsetFragmentCache() argument
124 if (pred(offset, fragmentPos->offsetBegin, fragmentPos->offsetBegin + fragmentPos->dataLength)) { in GetOffsetFragmentCache()
130 [offset, pred](const auto& fragment) { in GetOffsetFragmentCache()
131 if (pred(offset, fragment.offsetBegin, fragment.offsetBegin + fragment.dataLength)) { in GetOffsetFragmentCache()
141 static ChunkIterator GetOffsetChunkCache(CacheChunkList& chunkCaches, uint64_t offset, Pred pred) in GetOffsetChunkCache() argument
144 [offset, pred](const auto& fragment) { in GetOffsetChunkCache()
145 if (pred(offset, fragment->offset, fragment->offset + fragment->dataLength)) { in GetOffsetChunkCache()
/foundation/multimedia/av_codec/services/engine/codec/video/hcodec/
H A Dmsg_handle_loop.cpp77 const auto pred = [this, id]() { in SendSyncMsg() local
81 m_replyCond.wait(lock, pred); in SendSyncMsg()
83 if (!m_replyCond.wait_for(lock, chrono::milliseconds(waitMs), pred)) { in SendSyncMsg()
/foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/hardware/imagecodec/
H A Dmsg_handle_loop.cpp78 const auto pred = [this, id]() { in SendSyncMsg() local
82 m_replyCond.wait(lock, pred); in SendSyncMsg()
84 if (!m_replyCond.wait_for(lock, chrono::milliseconds(waitMs), pred)) { in SendSyncMsg()
/foundation/multimedia/ringtone_library/services/ringtone_data_extension/src/
H A Dringtone_data_command.cpp37 void RingtoneDataCommand::SetDataSharePred(const DataShare::DataSharePredicates &pred) in SetDataSharePred() argument
39 datasharePred_ = make_unique<const DataSharePredicates>(pred); in SetDataSharePred()
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/common/
H A Drs_thread_looper_impl.cpp51 auto pred = [this]() { return !queue_.empty() || HaveDelayedMessageToProcess() || wakeup_; }; in WaitForMessage() local
53 cv_.wait(lock, pred); in WaitForMessage()
61 cv_.wait_until(lock, time, pred); in WaitForMessage()
/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/fuzztest/medialibraryutil_fuzzer/src/
H A Dmedialibrary_util_fuzzer.cpp82 DataShare::DataSharePredicates pred; in CommandTest() local
83 cmd.SetDataSharePred(pred); in CommandTest()
142 DataShare::DataSharePredicates pred; in AnalysisTest() local
155 static_cast<Media::OperationType>(FuzzInt32(data)), values, pred); in AnalysisTest()
/foundation/multimodalinput/input/intention/prototype/include/
H A Di_device_manager.h37 virtual bool AnyOf(std::function<bool(std::shared_ptr<IDevice>)> pred) = 0;
/foundation/multimodalinput/input/intention/services/device_manager/src/
H A Ddevice_manager.cpp401 bool DeviceManager::AnyOf(std::function<bool(std::shared_ptr<IDevice>)> pred) in AnyOf() argument
403 return std::any_of(devices_.cbegin(), devices_.cend(), [pred](const auto &item) { in AnyOf()
404 return (pred != nullptr ? pred(item.second) : false); in AnyOf()
/foundation/multimedia/ringtone_library/services/ringtone_data_extension/include/
H A Dringtone_data_command.h55 EXPORT void SetDataSharePred(const DataShare::DataSharePredicates &pred);
/foundation/ability/ability_runtime/test/moduletest/ipc_ability_scheduler_test/
H A Dipc_ability_scheduler_module_test.cpp433 const NativeRdb::DataAbilityPredicates& pred) { in HWTEST_F()
471 auto mockHandler = [&](const Uri& uri, const NativeRdb::DataAbilityPredicates& pred) { in HWTEST_F()
512 const NativeRdb::DataAbilityPredicates& pred) { in HWTEST_F()
/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/include/
H A Dmedialibrary_command.h65 EXPORT void SetDataSharePred(const DataShare::DataSharePredicates &pred);
/foundation/multimodalinput/input/intention/services/device_manager/include/
H A Ddevice_manager.h52 bool AnyOf(std::function<bool(std::shared_ptr<IDevice>)> pred) override;
/foundation/resourceschedule/ffrt/src/eu/
H A Dco_routine.h131 void CoWait(const std::function<bool(ffrt::CPUEUTask*)>& pred);
H A Dco_routine.cpp503 void CoWait(const std::function<bool(ffrt::CPUEUTask*)>& pred)
505 GetCoEnv()->pending = &pred;
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/include/common/
H A Drs_common_def.h410 inline typename Container::size_type EraseIf(Container& container, Predicate pred) in EraseIf() argument
412 // erase from container if pred returns true, backport of c++20 std::remove_if in EraseIf()
416 if (pred(*iter)) { in EraseIf()
/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/
H A Dmedialibrary_command.cpp381 void MediaLibraryCommand::SetDataSharePred(const DataSharePredicates &pred) in SetDataSharePred() argument
383 datasharePred_ = make_unique<const DataSharePredicates>(pred); in SetDataSharePred()
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/
H A Drs_uifirst_manager.cpp1609 auto pred = [uifirstRootSurfaceNodeDrawable] { in CheckAndWaitPreFirstLevelDrawableNotify() local
1615 notifyCv_.wait_for(lock, TIME_OUT, pred); in CheckAndWaitPreFirstLevelDrawableNotify()
1616 auto ret = pred(); in CheckAndWaitPreFirstLevelDrawableNotify()
/foundation/graphic/graphic_3d/lume/Lume_3D/src/ecs/systems/
H A Dnode_system.cpp142 inline auto FindIf(ListType&& list, Predicate&& pred) in FindIf() argument
144 return std::find_if(list.begin(), list.end(), BASE_NS::forward<Predicate>(pred)); in FindIf()

Completed in 14 milliseconds

12