Home
last modified time | relevance | path

Searched refs:future (Results 1 – 25 of 233) sorted by relevance

12345678910

/ohos5.0/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dfuture_factory.cpp107 Future *future = nullptr; in CreateFuture() local
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()
168 future->SetResponse(status, response); in ProcessResponse()
176 listener->OnReply(future); in ProcessResponse()
177 future->DetachResponse(); in ProcessResponse()
[all …]
/ohos5.0/base/customization/enterprise_device_management/services/edm_plugin/src/utils/
H A Dinstaller_callback.cpp33 auto future = resultCodeSignal_.get_future(); in GetResultCode() local
34 future.wait(); in GetResultCode()
35 return future.get(); in GetResultCode()
40 auto future = resultMsgSignal_.get_future(); in GetResultMsg() local
41 future.wait(); in GetResultMsg()
42 return future.get(); in GetResultMsg()
/ohos5.0/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()
/ohos5.0/foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/
H A Dfuture.h138 class future : private non_copyable {
150 future() noexcept = default;
152 future(future&& fut) noexcept
156 future& operator=(future&& fut) noexcept
197 void swap(future<R>& rhs) noexcept
234 future<R> get_future() noexcept
236 return future<R> {m_state};
271 future<void> get_future() noexcept
273 return future<void> {m_state};
323 future<R> get_future() noexcept
[all …]
/ohos5.0/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()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Dtimeout.rs14 use std::future::Future;
25 pub(crate) future: T,
29 pub(crate) fn new(future: T, timeout: Duration) -> Self { in new()
32 future: Box::pin(future), in new()
51 match Pin::new(&mut this.future).poll(cx) { in poll()
110 future: future1, in ut_timeout_future()
115 future: future2, in ut_timeout_future()
/ohos5.0/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()
/ohos5.0/foundation/barrierfree/accessibility/services/aams/src/
H A Daccessibility_settings.cpp76 ffrt::future syncFuture = syncPromise->get_future(); in SetShortKeyState()
128 ffrt::future syncFuture = syncPromise->get_future(); in SetMouseAutoClick()
166 ffrt::future syncFuture = syncPromise->get_future(); in SetShortkeyTarget()
202 ffrt::future syncFuture = syncPromise->get_future(); in SetShortkeyMultiTarget()
327 ffrt::future syncFuture = syncPromise->get_future(); in SetDaltonizationColorFilter()
362 ffrt::future syncFuture = syncPromise->get_future(); in SetContentTimeout()
403 ffrt::future syncFuture = syncPromise->get_future(); in SetBrightnessDiscount()
440 ffrt::future syncFuture = syncPromise->get_future(); in SetAudioBalance()
477 ffrt::future syncFuture = syncPromise->get_future(); in SetClickResponseTime()
515 ffrt::future syncFuture = syncPromise->get_future(); in SetIgnoreRepeatClickState()
[all …]
/ohos5.0/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()
/ohos5.0/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()
/ohos5.0/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()
46 IResponse *response = future->GetResponse(0); in OnReply()
/ohos5.0/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()
/ohos5.0/foundation/window/window_manager/wm/test/unittest/
H A Dpattern_detach_callback_test.cpp82 std::future<void> future = std::async(std::launch::async, [this, sleepTime]() -> void { in __anond4858c420202() variable
105 std::future<void> future = std::async(std::launch::async, [this, sleepTime]() -> void { in __anond4858c420302() variable
/ohos5.0/foundation/arkui/ace_engine/frameworks/base/thread/
H A Dcancelable_callback.h138 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()
/ohos5.0/foundation/communication/dsoftbus/tests/core/connection/wifi_direct_cpp/processor/
H A Dp2p_v1_processor_test.cpp512 auto future = result.get_future(); variable
515 auto value = future.get();
582 auto value = future.get();
630 auto value = future.get();
672 auto value = future.get();
714 auto value = future.get();
765 auto value = future.get();
809 auto value = future.get();
990 auto value = future.get();
1080 auto value = future.get();
[all …]
/ohos5.0/base/hiviewdfx/hidumper/frameworks/native/src/executor/memory/
H A Dget_hardware_info.cpp168 std::vector<future<uint64_t>> results; in GetHardwareUsage()
173 std::future<uint64_t> future = promise.get_future(); in GetHardwareUsage() local
177 results.emplace_back(std::move(future)); in GetHardwareUsage()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dblock_on.rs14 use std::future::Future;
103 let mut future = unsafe { Pin::new_unchecked(&mut task) }; in block_on() localVariable
105 if let Poll::Ready(res) = future.as_mut().poll(&mut cx) { in block_on()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dtimer_test.rs16 use std::future::Future;
127 let future = TimeFuture { in sdv_sleep_poll() localVariable
131 let ret = future.await; in sdv_sleep_poll()
/ohos5.0/base/msdp/device_status/test/unittest/frameworks/src/
H A Dinteraction_drag_drawing_test.cpp183 std::future<bool> futureFlag = promiseFlag.get_future();
225 std::future<bool> futureFlag = promiseFlag.get_future();
270 std::future<bool> futureFlag = promiseFlag.get_future();
315 std::future<bool> futureFlag = promiseFlag.get_future();
354 std::future<bool> futureFlag = promiseFlag.get_future();
392 std::future<bool> futureFlag = promiseFlag.get_future();
425 std::future<bool> futureFlag = promiseFlag.get_future();
457 std::future<bool> futureFlag = promiseFlag.get_future();
489 std::future<bool> futureFlag = promiseFlag.get_future();
521 std::future<bool> futureFlag = promiseFlag.get_future();
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/pariter/
H A Dmod.rs87 ) -> Pin<Box<dyn std::future::Future<Output = Result<(), ScheduleError>> + Send + 'a>> in for_each()
99 ) -> Pin<Box<dyn std::future::Future<Output = Result<Self::Item, ScheduleError>> + Send + 'a>> in sum()
112 ) -> Pin<Box<dyn std::future::Future<Output = Result<C::Output, ScheduleError>> + Send + 'a>> in drive()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
H A Dtimeout.rs14 use std::future::Future;
44 pub fn timeout<F>(duration: Duration, future: F) -> Timeout<F> in timeout()
49 Timeout::new(future, sleep) in timeout()

12345678910