Home
last modified time | relevance | path

Searched refs:future (Results 1 - 25 of 168) sorted by relevance

1234567

/foundation/bundlemanager/bundle_framework/interfaces/kits/js/bundlemgr/
H A Dinstaller_callback.cpp37 auto future = resultCodeSignal_.get_future(); in GetResultCode() local
38 future.wait(); in GetResultCode()
39 return future.get(); in GetResultCode()
44 auto future = resultMsgSignal_.get_future(); in GetResultMsg() local
45 future.wait(); in GetResultMsg()
46 return future.get(); in GetResultMsg()
/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dfuture_factory.cpp22 #include "server_executor/include/future.h"
107 Future *future = nullptr; in CreateFuture() local
108 AIE_NEW(future, Future(request, sequenceId, request->GetTransactionId())); in CreateFuture()
109 CHK_RET(future == nullptr, RETCODE_OUT_OF_MEMORY); in CreateFuture()
111 AddFuture(sequenceId, future); in CreateFuture()
115 void FutureFactory::AddFuture(long long sequenceId, Future* future) in AddFuture() argument
119 futures_[sequenceId] = future; in AddFuture()
160 Future *future = FetchFuture(res); in ProcessResponse() local
161 if (!future) { in ProcessResponse()
162 HILOGE("[FutureFactory][transactionId:%lld]No matched future foun in ProcessResponse()
[all...]
/foundation/bundlemanager/bundle_tool/frameworks/src/
H A Dstatus_receiver_impl.cpp61 auto future = resultCodeSignal_.get_future(); in GetResultCode() local
62 if (future.wait_for(std::chrono::seconds(waittingTime_)) == std::future_status::ready) { in GetResultCode()
63 int32_t resultCode = future.get(); in GetResultCode()
71 auto future = resultMsgSignal_.get_future(); in GetResultMsg() local
72 if (future.wait_for(std::chrono::seconds(waittingTime_)) == std::future_status::ready) { in GetResultMsg()
73 std::string resultMsg = future.get(); in GetResultMsg()
H A Dquick_fix_status_callback_host_impl.cpp56 auto future = quickFixPromise_.get_future(); in GetResultCode() local
57 if (future.wait_for(std::chrono::seconds(WAITTING_TIME)) == std::future_status::ready) { in GetResultCode()
58 quickFixRes = future.get(); in GetResultCode()
/foundation/bundlemanager/bundle_framework/services/bundlemgr/test/mock/src/
H A Dmock_clean_cache.cpp32 auto future = signal_.get_future(); in GetResultCode() local
33 future.wait(); in GetResultCode()
34 return future.get(); in GetResultCode()
H A Dmock_bundle_status.cpp33 auto future = signal_.get_future(); in GetResultCode() local
34 std::future_status status = future.wait_for(std::chrono::seconds(1)); in GetResultCode()
38 return future.get(); in GetResultCode()
H A Dmock_quick_fix_callback.cpp37 auto future = promise_.get_future(); in GetResCode() local
38 future.wait(); in GetResCode()
39 auto quickFixRes = future.get(); in GetResCode()
H A Dmock_status_receiver.cpp47 auto future = signal_.get_future(); in GetResultCode() local
48 if (future.wait_for(std::chrono::seconds(WAIT_TIME)) == std::future_status::ready) { in GetResultCode()
49 int32_t resultCode = future.get(); in GetResultCode()
/foundation/ai/ai_engine/services/server/communication_adapter/source/
H A Dfuture_listener.cpp32 void FutureListener::OnReply(const IFuture *future) in OnReply() argument
41 if (future == nullptr) { in OnReply()
42 HILOGE("[FutureListener]The future is nullptr."); in OnReply()
46 IResponse *response = future->GetResponse(0); in OnReply()
/foundation/ability/ability_runtime/test/moduletest/mock/src/appmgr/
H A Dmock_status_receiver.cpp37 auto future = signal_.get_future(); in GetResultCode() local
38 future.wait(); in GetResultCode()
39 return future.get(); in GetResultCode()
/foundation/bundlemanager/bundle_framework/services/test/mock/src/
H A Dmock_status_receiver.cpp37 auto future = signal_.get_future(); in GetResultCode() local
38 future.wait(); in GetResultCode()
39 return future.get(); in GetResultCode()
/foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/
H A Dfuture.h138 class future : private non_copyable {
146 explicit future(const std::shared_ptr<detail::shared_state<R>>& state) noexcept : m_state(state)
150 future() noexcept = default;
152 future(future&& fut) noexcept
156 future& operator=(future&& fut) noexcept
159 future tmp(std::move(fut));
197 void swap(future<R>& rhs) noexcept
234 future<
[all...]
/foundation/communication/ipc/interfaces/innerkits/rust/src/ipc_async/
H A Dipc_ylong.rs18 use std::future::Future;
85 fn block_on<F: Future>(future: F) -> F::Output { in block_on()
86 ylong_runtime::block_on(future) in block_on()
/foundation/barrierfree/accessibility/services/aams/src/
H A Daccessibility_settings.cpp78 ffrt::future syncFuture = syncPromise.get_future(); in SetShortKeyState()
120 ffrt::future syncFuture = syncPromise.get_future(); in SetMouseAutoClick()
149 ffrt::future syncFuture = syncPromise.get_future(); in SetShortkeyTarget()
177 ffrt::future syncFuture = syncPromise.get_future(); in SetShortkeyMultiTarget()
302 ffrt::future syncFuture = syncPromise.get_future(); in SetDaltonizationColorFilter()
327 ffrt::future syncFuture = syncPromise.get_future(); in SetContentTimeout()
358 ffrt::future syncFuture = syncPromise.get_future(); in SetBrightnessDiscount()
387 ffrt::future syncFuture = syncPromise.get_future(); in SetAudioBalance()
416 ffrt::future syncFuture = syncPromise.get_future(); in SetClickResponseTime()
446 ffrt::future syncFutur in SetIgnoreRepeatClickState()
[all...]
/foundation/window/window_manager/wm/test/unittest/
H A Dpattern_detach_callback_test.cpp18 #include <future>
82 std::future<void> future = std::async(std::launch::async, [this, sleepTime]() -> void { in HWTEST_F() local
105 std::future<void> future = std::async(std::launch::async, [this, sleepTime]() -> void { in HWTEST_F() local
/foundation/arkui/ace_engine/frameworks/base/thread/
H A Dcancelable_callback.h21 #include <future>
138 std::shared_future<int32_t> future(impl->future_); in WaitUntilComplete()
139 if (timeoutMs != 0ms && std::future_status::timeout == future.wait_for(timeoutMs)) { in WaitUntilComplete()
145 return future.get() == COMPLETED; in WaitUntilComplete()
172 std::shared_future<int32_t> future(impl->future_); in Cancel()
174 status = future.get(); in Cancel()
/foundation/bundlemanager/bundle_framework/services/bundlemgr/include/
H A Dbundle_promise.h20 #include <future>
66 std::future<void> future_ = promise_.get_future();
/foundation/arkui/ace_engine/frameworks/bridge/common/utils/
H A Dpipeline_context_holder.h19 #include <future>
66 std::future<RefPtr<PipelineBase>> future_ = promise_.get_future();
/foundation/communication/nfc/services/include/
H A Dnfc_service.h17 #include <future>
79 bool IsNfcTaskReady(std::future<int>& future) const;
134 std::future<int> future_ {};
/foundation/graphic/graphic_3d/3d_widget_adapter/include/
H A Dgraphics_task.h20 #include <future>
43 std::future<void> ftr_ = pms_.get_future();
/foundation/multimodalinput/input/intention/scheduler/task_scheduler/src/
H A Dtask_scheduler.cpp90 Future future = promise.get_future(); in PostSyncTask() local
96 auto res = future.wait_for(span); in PostSyncTask()
105 return future.get(); in PostSyncTask()
/foundation/communication/dsoftbus/tests/core/connection/wifi_direct_cpp/processor/
H A Dp2p_v1_processor_test.cpp22 #include <future>
512 auto future = result.get_future(); in HWTEST_F() local
513 auto status = future.wait_for(std::chrono::milliseconds(P2pV1Processor::P2P_V1_WAITING_RESPONSE_TIME_MS + 1000)); in HWTEST_F()
515 auto value = future.get(); in HWTEST_F()
579 auto future = result.get_future(); in HWTEST_F() local
580 auto status = future.wait_for(std::chrono::milliseconds(1000)); in HWTEST_F()
582 auto value = future.get(); in HWTEST_F()
627 auto future = result.get_future(); in HWTEST_F() local
628 auto status = future.wait_for(std::chrono::milliseconds(1000)); in HWTEST_F()
630 auto value = future in HWTEST_F()
669 auto future = result.get_future(); HWTEST_F() local
711 auto future = result.get_future(); HWTEST_F() local
762 auto future = result.get_future(); HWTEST_F() local
805 auto future = result.get_future(); HWTEST_F() local
987 auto future = result.get_future(); HWTEST_F() local
1077 auto future = result.get_future(); HWTEST_F() local
1452 auto future = result.get_future(); HWTEST_F() local
[all...]
/foundation/bundlemanager/app_domain_verify/frameworks/common/src/httpsession/
H A Dapp_domain_verify_task_mgr.cpp20 #include <future>
131 std::future future = promise.get_future(); in GetTaskWrapper() local
160 future.wait(); in GetTaskWrapper()
/foundation/graphic/graphic_2d/rosen/modules/hyper_graphic_manager/core/frame_rate_manager/
H A Dhgm_task_handle_thread.h19 #include <future>
61 std::future<Return> ScheduleTask(Task&& task) in ScheduleTask()
/foundation/multimodalinput/input/intention/scheduler/task_scheduler/include/
H A Dtask_scheduler.h21 #include <future>
43 using Future = std::future<int32_t>;

Completed in 9 milliseconds

1234567