/foundation/barrierfree/accessibility/frameworks/aafwk/src/ |
H A D | accessible_ability_channel_client.cpp | 93 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElementInfo() 94 if (wait != ffrt::future_status::ready) { in FindFocusedElementInfo() 149 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in GetCursorPosition() 150 if (wait != ffrt::future_status::ready) { in GetCursorPosition() 193 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in ExecuteAction() 194 if (wait != ffrt::future_status::ready) { in ExecuteAction() 263 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByAccessibilityId() 264 if (wait != ffrt::future_status::ready) { in SearchElementInfosByAccessibilityId() 351 ffrt::future_status wait = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByText() 352 if (wait != ffrt::future_status in SearchElementInfosByText() [all...] |
/foundation/barrierfree/accessibility/services/aams/src/ |
H A D | accessible_ability_channel.cpp | 100 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfoByAccessibilityId() 101 if (wait != ffrt::future_status::ready) { in SearchElementInfoByAccessibilityId() 153 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByText() 154 if (wait != ffrt::future_status::ready) { in SearchElementInfosByText() 206 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElementInfo() 207 if (wait != ffrt::future_status::ready) { in FindFocusedElementInfo() 258 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FocusMoveSearch() 259 if (wait != ffrt::future_status::ready) { in FocusMoveSearch() 372 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in ExecuteAction() 373 if (wait != ffrt::future_status in ExecuteAction() [all...] |
H A D | accessible_ability_manager_service.cpp | 489 ffrt::future_status waitFocus = focusFuture.wait_for(std::chrono::milliseconds(timeOut)); in FindFocusedElementByConnection() 490 if (waitFocus != ffrt::future_status::ready) { in FindFocusedElementByConnection() 533 ffrt::future_status waitFocus = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElement() 534 if (waitFocus != ffrt::future_status::ready) { in FindFocusedElement() 604 ffrt::future_status waitAction = actionFuture.wait_for(std::chrono::milliseconds(timeOut)); in ExecuteActionOnAccessibilityFocused() 605 if (waitAction != ffrt::future_status::ready) { in ExecuteActionOnAccessibilityFocused() 673 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterCaptionObserver() 674 if (wait != ffrt::future_status::ready) { in RegisterCaptionObserver() 718 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterEnableAbilityListsObserver() 719 if (wait != ffrt::future_status in RegisterEnableAbilityListsObserver() [all...] |
/foundation/bundlemanager/bundle_framework/services/bundlemgr/test/mock/src/ |
H A D | mock_bundle_status.cpp | 34 std::future_status status = future.wait_for(std::chrono::seconds(1)); in GetResultCode() 35 if (status == std::future_status::timeout) { in GetResultCode()
|
H A D | mock_status_receiver.cpp | 48 if (future.wait_for(std::chrono::seconds(WAIT_TIME)) == std::future_status::ready) { in GetResultCode()
|
/foundation/barrierfree/accessibility/services/test/xts/src/asac_register_elemnt_operator_test/ |
H A D | asac_ability_channel_benchmark.cpp | 100 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfoByA11yBenchmarkId() 101 if (wait != ffrt::future_status::ready) { in SearchElementInfoByA11yBenchmarkId() 153 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in SearchElementInfosByText() 154 if (wait != ffrt::future_status::ready) { in SearchElementInfosByText() 206 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElementInfo() 207 if (wait != ffrt::future_status::ready) { in FindFocusedElementInfo() 258 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FocusMoveSearch() 259 if (wait != ffrt::future_status::ready) { in FocusMoveSearch() 372 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in ExecuteAction() 373 if (wait != ffrt::future_status in ExecuteAction() [all...] |
/foundation/bundlemanager/bundle_tool/frameworks/src/ |
H A D | status_receiver_impl.cpp | 62 if (future.wait_for(std::chrono::seconds(waittingTime_)) == std::future_status::ready) { in GetResultCode() 72 if (future.wait_for(std::chrono::seconds(waittingTime_)) == std::future_status::ready) { in GetResultMsg()
|
H A D | quick_fix_status_callback_host_impl.cpp | 57 if (future.wait_for(std::chrono::seconds(WAITTING_TIME)) == std::future_status::ready) { in GetResultCode()
|
/foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/ |
H A D | future.h | 31 enum class future_status { ready, timeout, deferred }; class 43 future_status wait_for(const std::chrono::duration<Rep, Period>& waitTime) const noexcept 46 return m_cv.wait_for(lk, waitTime, [this] { return get_derived().has_value(); }) ? future_status::ready : 47 future_status::timeout; 51 future_status wait_until(const std::chrono::time_point<Clock, Duration>& tp) const noexcept 54 return m_cv.wait_until(lk, tp, [this] { return get_derived().has_value(); }) ? future_status::ready : 55 future_status::timeout; 181 future_status wait_for(const std::chrono::duration<Rep, Period>& waitTime) const noexcept 187 future_status wait_until(const std::chrono::time_point<Clock, Duration>& tp) const noexcept
|
/foundation/multimodalinput/input/intention/scheduler/task_scheduler/src/ |
H A D | task_scheduler.cpp | 98 if (res == std::future_status::timeout) { in PostSyncTask() 101 } else if (res == std::future_status::deferred) { in PostSyncTask()
|
/foundation/communication/wifi/wifi/utils/src/ |
H A D | wifi_event_handler.cpp | 316 ffrt::future_status status = f.wait_for(std::chrono::milliseconds(waitTime)); in PostSyncTimeOutTask() 317 if (status == ffrt::future_status::timeout) { in PostSyncTimeOutTask() 325 std::future_status status = f.wait_for(std::chrono::milliseconds(waitTime)); in PostSyncTimeOutTask() 326 if (status == std::future_status::timeout) { in PostSyncTimeOutTask()
|
/foundation/multimodalinput/input/service/delegate_task/src/ |
H A D | delegate_tasks.cpp | 105 if (res == std::future_status::timeout) { in PostSyncTask() 108 } else if (res == std::future_status::deferred) { in PostSyncTask()
|
/foundation/barrierfree/accessibility/services/test/xts/src/sa_perform_action_test/ |
H A D | sa_perform_action_xts.cpp | 489 ffrt::future_status waitFocus = focusFuture.wait_for(std::chrono::milliseconds(timeOut)); in FindFocusedElementByConnection() 490 if (waitFocus != ffrt::future_status::ready) { in FindFocusedElementByConnection() 533 ffrt::future_status waitFocus = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElement() 534 if (waitFocus != ffrt::future_status::ready) { in FindFocusedElement() 604 ffrt::future_status waitAction = actionFuture.wait_for(std::chrono::milliseconds(timeOut)); in ExecuteActionOnA11yFocused() 605 if (waitAction != ffrt::future_status::ready) { in ExecuteActionOnA11yFocused() 673 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterCaptionObserver() 674 if (wait != ffrt::future_status::ready) { in RegisterCaptionObserver() 718 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterEnableAbilityListsObserver() 719 if (wait != ffrt::future_status in RegisterEnableAbilityListsObserver() [all...] |
/foundation/barrierfree/accessibility/services/test/xts/src/samgr_register_element_test/ |
H A D | samgr_register_element_test.cpp | 489 ffrt::future_status waitFocus = focusFuture.wait_for(std::chrono::milliseconds(timeOut)); in FindFocusedElementByConnection() 490 if (waitFocus != ffrt::future_status::ready) { in FindFocusedElementByConnection() 533 ffrt::future_status waitFocus = promiseFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in FindFocusedElement() 534 if (waitFocus != ffrt::future_status::ready) { in FindFocusedElement() 604 ffrt::future_status waitAction = actionFuture.wait_for(std::chrono::milliseconds(timeOut)); in ExecuteActionOnA11yRegisterElementFocused() 605 if (waitAction != ffrt::future_status::ready) { in ExecuteActionOnA11yRegisterElementFocused() 673 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterCaptionObserver() 674 if (wait != ffrt::future_status::ready) { in RegisterCaptionObserver() 718 ffrt::future_status wait = syncFuture.wait_for(std::chrono::milliseconds(TIME_OUT_OPERATOR)); in RegisterEnableAbilityListsObserver() 719 if (wait != ffrt::future_status in RegisterEnableAbilityListsObserver() [all...] |
/foundation/communication/dsoftbus/tests/core/connection/wifi_direct_cpp/processor/ |
H A D | p2p_v1_processor_test.cpp | 514 ASSERT_EQ(status, std::future_status::ready); in HWTEST_F() 581 ASSERT_EQ(status, std::future_status::ready); in HWTEST_F() 629 ASSERT_EQ(status, std::future_status::ready); in HWTEST_F() 671 ASSERT_EQ(status, std::future_status::ready); in HWTEST_F() 713 ASSERT_EQ(status, std::future_status::ready); in HWTEST_F() 764 ASSERT_EQ(status, std::future_status::ready); in HWTEST_F() 808 ASSERT_EQ(status, std::future_status::ready); in HWTEST_F() 989 ASSERT_EQ(status, std::future_status::ready); in HWTEST_F() 1079 ASSERT_EQ(status, std::future_status::ready); in HWTEST_F() 1454 ASSERT_EQ(status, std::future_status in HWTEST_F() [all...] |
/foundation/CastEngine/castengine_wifi_display/services/event/ |
H A D | event_manager.cpp | 129 if (future.wait_for(timeoutInterval_) == std::future_status::ready) { in PushSyncEvent()
|
/foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/ |
H A D | ffrt_utils.cpp | 56 return status == ffrt::future_status::ready; in SubmitTimeoutTask()
|
/foundation/communication/nfc/services/src/ |
H A D | nfc_service.cpp | 211 std::future_status result = future.wait_for(std::chrono::milliseconds(TASK_THREAD_WAIT_MS));
in IsNfcTaskReady() 212 if (result != std::future_status::ready) {
in IsNfcTaskReady()
|
/foundation/arkui/ace_engine/frameworks/base/thread/ |
H A D | cancelable_callback.h | 139 if (timeoutMs != 0ms && std::future_status::timeout == future.wait_for(timeoutMs)) { in WaitUntilComplete()
|
/foundation/ability/ability_runtime/services/abilitymgr/src/ |
H A D | free_install_manager.cpp | 124 std::future_status status = future.wait_for(std::chrono::milliseconds(DELAY_LOCAL_FREE_INSTALL_TIMEOUT)); in StartFreeInstall() 125 if (status == std::future_status::timeout) { in StartFreeInstall() 159 std::future_status remoteStatus = remoteFuture.wait_for(std::chrono::milliseconds( in RemoteFreeInstall() 161 if (remoteStatus == std::future_status::timeout) { in RemoteFreeInstall()
|
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/componentmanager/ |
H A D | component_manager.cpp | 463 std::future_status status = iter.second.wait_for(std::chrono::seconds(UNINIT_COMPONENT_TIMEOUT_SECONDS)); in WaitForResult() 464 if (status == std::future_status::ready) { in WaitForResult() 474 if (status == std::future_status::timeout) { in WaitForResult() 481 if (status == std::future_status::deferred) { in WaitForResult()
|
/foundation/resourceschedule/resource_schedule_service/ressched/interfaces/innerkits/ressched_client/src/ |
H A D | res_sched_client.cpp | 93 ffrt::future_status status = fut.wait_for(std::chrono::milliseconds(CHECK_MUTEX_TIMEOUT));
in ReportSyncEvent() 94 if (status == ffrt::future_status::ready) {
in ReportSyncEvent()
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
H A D | distributed_data_storage.cpp | 422 if (future.wait_for(std::chrono::seconds(waittingTime_)) == std::future_status::ready) { in GetResultSatus()
|
/foundation/bundlemanager/bundle_framework/test/systemtest/common/bms/bms_code_signature_test/ |
H A D | bundle_mgr_code_signature_system_test.cpp | 105 if (future.wait_for(timeout) == std::future_status::timeout) {
in GetResultCode()
|
/foundation/bundlemanager/bundle_framework/test/systemtest/common/bms/bms_permission_grant_system_test/ |
H A D | bms_permission_grant_system_test.cpp | 91 if (future.wait_for(timeout) == std::future_status::timeout) { in GetResultMsg()
|