/foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler_impl/ |
H A D | none_io_waiter.cpp | 40 condition_.wait(lock, [this] { return this->pred_; }); in WaitFor() 49 (void)condition_.wait_for(lock, (duration > oneYear) ? oneYear : duration, [this] { return this->pred_; }); in WaitFor() 60 condition_.notify_one(); in NotifyOne() 68 condition_.notify_all(); in NotifyAll()
|
H A D | inner_event.cpp | 41 condition_.wait(lock); 51 condition_.notify_all(); 57 std::condition_variable condition_; member in OHOS::AppExecFwk::__anon9111::final
|
H A D | none_io_waiter.h | 47 std::condition_variable condition_; member in OHOS::AppExecFwk::final
|
H A D | event_runner.cpp | 85 condition_.notify_one(); in ReclaimCurrentThread() 147 condition_.notify_all(); in Stop() 211 condition_.wait(lock); in Run() 219 std::condition_variable condition_; member in OHOS::AppExecFwk::__anon9109::ThreadCollector 258 : collectorLock_(), condition_(), reclaims_(), depositMap_(), threadLock_(), thread_(nullptr) in ThreadCollector()
|
/foundation/ai/ai_engine/services/common/platform/semaphore/source/ |
H A D | semaphore.cpp | 39 condition_.wait(lock, [&]()->bool { return count_ > 0; }); in Wait() 47 if (!condition_.wait_for(lock, milliseconds_type(milliSeconds), [&]()->bool { return count_ > 0; })) { in Wait() 58 condition_.notify_one(); in Signal() 64 std::condition_variable condition_; member in OHOS::AI::Semaphore
|
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/src/ |
H A D | handler.cpp | 36 this->condition_.wait(lock);
in Handler() 45 (this->condition_.wait_until(lock, this->msgQueue_.back().when_) != std::cv_status::timeout)) {
in Handler() 66 condition_.notify_all();
in ~Handler() 93 condition_.notify_one();
in SendCastMessage() 133 condition_.notify_one();
in RemoveMessage() 151 condition_.notify_all();
in StopSafty()
|
/foundation/CastEngine/castengine_cast_plus_stream/src/utils/src/ |
H A D | handler.cpp | 36 this->condition_.wait(lock); in Handler() 45 (this->condition_.wait_until(lock, this->msgQueue_.back().when_) != std::cv_status::timeout)) { in Handler() 66 condition_.notify_all(); in ~Handler() 93 condition_.notify_one(); in SendCastMessage() 133 condition_.notify_one(); in RemoveMessage() 151 condition_.notify_all(); in StopSafty()
|
/foundation/ai/ai_engine/services/common/platform/event/source/ |
H A D | event.cpp | 42 condition_.wait(lock, [&]()->bool { return flag_; }); in Wait() 49 return condition_.wait_for(lock, milliseconds_type(milliSeconds), [&]()->bool { return flag_; }); in Wait() 58 condition_.notify_all(); in Signal() 79 mutable std::condition_variable condition_; member
|
/foundation/arkui/ace_engine/frameworks/base/thread/ |
H A D | background_task_executor.cpp | 73 condition_.notify_all(); in ~BackgroundTaskExecutor() 112 condition_.notify_one(); in PostTask() 146 condition_.notify_one(); in PostTask() 199 condition_.wait(lock); in ThreadLoop() 230 condition_.notify_all(); in TriggerGarbageCollection()
|
H A D | background_task_executor.h | 55 std::condition_variable condition_; member in OHOS::Ace::BackgroundTaskExecutor
|
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
H A D | executor.h | 73 condition_.notify_one(); in Bind() 80 condition_.notify_one(); 91 condition_.wait(lock, [this] { in Run() 106 condition_.wait_until(lock, std::chrono::steady_clock::now() + TIME_OUT, [this]() { in Run() 116 std::condition_variable condition_; member in OHOS::Executor
|
/foundation/distributeddatamgr/preferences/frameworks/native/include/ |
H A D | executor.h | 87 condition_.notify_one(); in Bind() 94 condition_.notify_one(); 105 condition_.wait(lock, [this] { in Run() 120 condition_.wait_until(lock, std::chrono::steady_clock::now() + TIME_OUT, [this]() { in Run() 130 std::condition_variable condition_; member in OHOS::NativePreferences::Executor
|
/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/notify_test/include/ |
H A D | notify_test.h | 34 condition_.notify_one(); 39 std::condition_variable condition_; member in OHOS::Media::TestObserver
|
/foundation/resourceschedule/device_standby/plugins/strategy/src/ |
H A D | network_strategy.cpp | 32 condition_ = TimeProvider::GetCondition(); in OnCreated() 79 condition_ = static_cast<uint32_t>(message.want_->GetIntParam(RES_CTRL_CONDITION, 0)); in UpdateNetResourceConfig() 80 STANDBYSERVICE_LOGD("enter NetworkStrategy HandleEvent, current condition is %{public}u", condition_); in UpdateNetResourceConfig()
|
/foundation/distributeddatamgr/kv_store/frameworks/common/ |
H A D | task_scheduler.h | 76 condition_.notify_one(); in At() 98 condition_.notify_one(); in Reset() 128 condition_.notify_one(); in Remove() 157 condition_.wait(lock, [this] { in Loop() 162 condition_.wait_until(lock, time); in Loop() 203 std::condition_variable condition_; member in OHOS::TaskScheduler
|
/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/engine_adapter/skia_adapter/ |
H A D | skia_task_executor.cpp | 73 condition_.notify_one(); in EnqueueTask() 101 condition_.wait(lock); in ThreadLoop()
|
/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
H A D | picture_manager_thread.cpp | 81 condition_.notify_all(); // Notify one waiting thread, if there is one.
in Stop() 104 condition_.notify_all();
in Resume() 120 condition_.wait_for(locker, std::chrono::seconds(1)); // 实际1S扫描一次
in Run()
|
/foundation/multimedia/media_lite/interfaces/kits/player_lite/js/builtin/src/ |
H A D | audio_player.cpp | 129 pthread_cond_t AudioPlayer::condition_ = PTHREAD_COND_INITIALIZER; member in OHOS::ACELite::AudioPlayer 165 retCode = pthread_cond_init(&condition_, nullptr); in ForkUpdateTimeThread() 175 (void)pthread_cond_destroy(&condition_); in ForkUpdateTimeThread() 204 (void)pthread_cond_wait(&condition_, &lock_); in UpdateTimeHandler() 213 retCode = pthread_cond_timedwait(&condition_, &lock_, &timeout); in UpdateTimeHandler() 225 (void)pthread_cond_destroy(&condition_); in UpdateTimeHandler() 326 int retCode = pthread_cond_signal(&condition_); in Play()
|
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/ |
H A D | datashare_connection.cpp | 45 condition_.condition.notify_all(); in OnAbilityConnectDone() 52 condition_.condition.notify_all(); in OnAbilityConnectDone() 184 std::unique_lock<std::mutex> condLock(condition_.mutex); in ConnectDataShareExtAbility() 185 if (condition_.condition.wait_for(condLock, std::chrono::seconds(waitTime_), in ConnectDataShareExtAbility()
|
/foundation/CastEngine/castengine_cast_plus_stream/src/utils/include/ |
H A D | handler.h | 54 std::condition_variable condition_; member in OHOS::CastEngine::CastEngineService::Handler
|
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/include/ |
H A D | handler.h | 54 std::condition_variable condition_;
member in OHOS::CastEngine::CastEngineService::Handler
|
/foundation/filemanagement/app_file_service/services/backup_sa/src/module_ipc/ |
H A D | svc_backup_connection.cpp | 102 condition_.notify_all(); in OnAbilityDisconnectDone() 130 if (condition_.wait_for(lock, std::chrono::seconds(WAIT_TIME), callback)) { in DisconnectBackupExtAbility()
|
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/stream/src/ |
H A D | i_cast_stream_manager.cpp | 51 condition_.notify_all(); in ~ICastStreamManager() 67 condition_.wait(lock, [this] { return (!this->workQueue_.empty() || !this->isRunning_.load()); }); in Handle() 109 condition_.notify_all(); in ProcessActionsEvent()
|
/foundation/CastEngine/castengine_cast_plus_stream/src/stream/src/ |
H A D | i_cast_stream_manager.cpp | 51 condition_.notify_all(); in ~ICastStreamManager() 67 condition_.wait(lock, [this] { return (!this->workQueue_.empty() || !this->isRunning_.load()); }); in Handle() 109 condition_.notify_all(); in ProcessActionsEvent()
|
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/common/ |
H A D | hdi_codec.cpp | 193 condition_.wait_for(lock, std::chrono::milliseconds(TIMEOUT_MS), in SendCommand() 228 condition_.wait_for(lock, std::chrono::milliseconds(TIMEOUT_MS), [this] { return outputOmxBuffer_ != nullptr; }); in FillThisBuffer() 260 condition_.notify_all(); in OnEventHandler() 273 condition_.notify_all(); in OnFillBufferDone()
|