Home
last modified time | relevance | path

Searched refs:condition_ (Results 1 - 25 of 51) sorted by relevance

123

/foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler_impl/
H A Dnone_io_waiter.cpp40 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 Dinner_event.cpp41 condition_.wait(lock);
51 condition_.notify_all();
57 std::condition_variable condition_; member in OHOS::AppExecFwk::__anon9111::final
H A Dnone_io_waiter.h47 std::condition_variable condition_; member in OHOS::AppExecFwk::final
H A Devent_runner.cpp85 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 Dsemaphore.cpp39 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 Dhandler.cpp36 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 Dhandler.cpp36 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 Devent.cpp42 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 Dbackground_task_executor.cpp73 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 Dbackground_task_executor.h55 std::condition_variable condition_; member in OHOS::Ace::BackgroundTaskExecutor
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor.h73 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 Dexecutor.h87 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 Dnotify_test.h34 condition_.notify_one();
39 std::condition_variable condition_; member in OHOS::Media::TestObserver
/foundation/resourceschedule/device_standby/plugins/strategy/src/
H A Dnetwork_strategy.cpp32 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 Dtask_scheduler.h76 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 Dskia_task_executor.cpp73 condition_.notify_one(); in EnqueueTask()
101 condition_.wait(lock); in ThreadLoop()
/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/
H A Dpicture_manager_thread.cpp81 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 Daudio_player.cpp129 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 Ddatashare_connection.cpp45 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 Dhandler.h54 std::condition_variable condition_; member in OHOS::CastEngine::CastEngineService::Handler
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/include/
H A Dhandler.h54 std::condition_variable condition_; member in OHOS::CastEngine::CastEngineService::Handler
/foundation/filemanagement/app_file_service/services/backup_sa/src/module_ipc/
H A Dsvc_backup_connection.cpp102 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 Di_cast_stream_manager.cpp51 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 Di_cast_stream_manager.cpp51 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 Dhdi_codec.cpp193 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()

Completed in 10 milliseconds

123