| /ohos5.0/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->p… in WaitFor()
60 condition_.notify_one(); in NotifyOne()
68 condition_.notify_all(); in NotifyAll()
|
| H A D | inner_event.cpp | 41 condition_.wait(lock); in Wait()
51 condition_.notify_all(); in Notify()
57 std::condition_variable condition_; member in OHOS::AppExecFwk::__anon37c86ff60110::WaiterImp
|
| 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::__anon214a92540110::ThreadCollector
258 : collectorLock_(), condition_(), reclaims_(), depositMap_(), threadLock_(), thread_(nullptr) in ThreadCollector()
|
| /ohos5.0/base/notification/eventhandler/frameworks/eventhandler/src/ |
| H A D | none_io_waiter.cpp | 41 condition_.wait(lock, [this] { return this->pred_; }); in WaitFor()
50 …(void)condition_.wait_for(lock, (duration > oneYear) ? oneYear : duration, [this] { return this->p… in WaitFor()
61 condition_.notify_one(); in NotifyOne()
69 condition_.notify_all(); in NotifyAll()
|
| H A D | inner_event.cpp | 46 condition_.wait(lock); in Wait()
56 condition_.notify_all(); in Notify()
62 std::condition_variable condition_; member in OHOS::AppExecFwk::__anon97b7ba540110::WaiterImp
|
| /ohos5.0/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
|
| /ohos5.0/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 in OHOS::AI::Event
|
| /ohos5.0/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_; variable
|
| /ohos5.0/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_; variable
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/base/thread/ |
| H A D | background_task_executor.cpp | 74 condition_.notify_all(); in ~BackgroundTaskExecutor()
113 condition_.notify_one(); in PostTask()
147 condition_.notify_one(); in PostTask()
201 condition_.wait(lock); in ThreadLoop()
232 condition_.notify_all(); in TriggerGarbageCollection()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/ |
| H A D | task_scheduler.h | 76 condition_.notify_one();
98 condition_.notify_one(); in Reset()
128 condition_.notify_one();
157 condition_.wait(lock, [this] { in Loop()
162 condition_.wait_until(lock, time); in Loop()
203 std::condition_variable condition_; variable
|
| /ohos5.0/drivers/peripheral/display/hal/default_standard/src/display_device/vsync/ |
| H A D | sorft_vsync.cpp | 54 condition_.notify_one(); in ~SorftVsync()
63 condition_.wait(ul, [this]() { return (enable_ || !running_); }); in CheckRuning()
74 condition_.notify_one(); in EnableVsync()
|
| /ohos5.0/base/location/frameworks/native/locator_sdk/source/ |
| H A D | geo_convert_callback_host.cpp | 71 condition_.notify_all(); in OnResults()
79 condition_.notify_all(); in OnErrorReport()
87 auto waitStatus = condition_.wait_for( in GetResult()
|
| /ohos5.0/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()
|
| /ohos5.0/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 …NDBYSERVICE_LOGD("enter NetworkStrategy HandleEvent, current condition is %{public}u", condition_); in UpdateNetResourceConfig()
|
| H A D | base_network_strategy.cpp | 228 condition_ = TimeProvider::GetCondition(); in GetBackgroundTaskApp()
232 } else if (condition_ == ConditionType::DAY_STANDBY || in GetBackgroundTaskApp()
326 if ((condition_ == ConditionType::NIGHT_STANDBY) && in SetNetAllowApps()
478 condition_ = TimeProvider::GetCondition(); in GetExemptedFlag()
479 if ((condition_ == ConditionType::NIGHT_STANDBY) && in GetExemptedFlag()
|
| /ohos5.0/base/update/updater/services/script/script_interpreter/ |
| H A D | script_statement.h | 168 condition_(condition), after_(after), statements_(statements) {} in UScriptForStatement()
175 UScriptExpression* condition_ = nullptr; variable
183 : UScriptStatement(STATEMENT_TYPE_WHILE), condition_(condition), statements_(statements) {} in UScriptWhileStatement()
189 UScriptExpression *condition_ = nullptr;
|
| H A D | script_statement.cpp | 193 if (condition_ != nullptr) { in Execute()
194 UScriptValuePtr v = condition_->Execute(interpreter, context); in Execute()
230 if (condition_ != nullptr) { in Execute()
231 UScriptValuePtr v = condition_->Execute(interpreter, context); in Execute()
326 delete condition_; in ~UScriptForStatement()
333 delete condition_; in ~UScriptWhileStatement()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/notify_test/include/ |
| H A D | notify_test.h | 34 condition_.notify_one(); in OnChange()
39 std::condition_variable condition_; variable
|
| /ohos5.0/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()
|
| /ohos5.0/base/update/updateservice/services/engine/src/ |
| H A D | progress_thread.cpp | 41 condition_.notify_one(); in QuitDownloadThread()
59 condition_.notify_one(); in StartProgress()
68 condition_.notify_one(); in StopProgress()
78 condition_.wait(lock); in ExecuteThreadFunc()
|
| /ohos5.0/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()
|
| /ohos5.0/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()
|
| /ohos5.0/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/common/ |
| H A D | hdi_codec.cpp | 217 condition_.wait_for(lock, std::chrono::milliseconds(TIMEOUT_MS), in SendCommand()
260 …condition_.wait_for(lock, std::chrono::milliseconds(TIMEOUT_MS), [this] { return outputOmxBuffer_ … in FillThisBuffer()
301 condition_.notify_all(); in OnEventHandler()
314 condition_.notify_all(); in OnFillBufferDone()
|
| /ohos5.0/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()
|