| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | future.cpp | 28 Future::Future(IRequest *request, long long sequenceId, long long transactionId) in Future() function in OHOS::AI::Future
39 Future::~Future() in ~Future()
48 IResponse *Future::GetResponse(int timeOut) const in GetResponse()
54 void Future::Release() in Release()
61 IRequest *Future::GetRequest() const in GetRequest()
66 FutureStatus Future::Status() const in Status()
71 FutureStatus Future::ConvertPluginStatus(PluginEvent event) in ConvertPluginStatus()
79 void Future
[all...] |
| H A D | future_factory.cpp | 107 Future *future = nullptr; in CreateFuture()
108 AIE_NEW(future, Future(request, sequenceId, request->GetTransactionId())); in CreateFuture()
115 void FutureFactory::AddFuture(long long sequenceId, Future* future) in AddFuture()
160 Future *future = FetchFuture(res); in ProcessResponse()
167 FutureStatus status = Future::ConvertPluginStatus(event); in ProcessResponse()
183 Future *FutureFactory::FetchFuture(Response *response) in FetchFuture()
|
| /foundation/graphic/graphic_3d/lume/metaobject/src/ |
| H A D | future.cpp | 22 Future::StateType Future::GetState() const in GetState()
28 Future::StateType Future::Wait() const in Wait()
37 Future::StateType Future::WaitFor(const TimeSpan& time) const in WaitFor()
48 IAny::Ptr Future::GetResult() const in GetResult()
57 IFuture::Ptr Future::Then(const IFutureContinuation::Ptr& func, const ITaskQueue::Ptr& queue) in Then()
62 BASE_NS::shared_ptr<Future> f(new Future); in Then()
[all...] |
| H A D | future.h | 36 class Future final : public IntroduceInterfaces<IFuture> {
106 BASE_NS::shared_ptr<Future> future_;
|
| /foundation/communication/ipc/interfaces/innerkits/rust/src/ipc_async/ |
| H A D | ipc_ylong.rs | 18 use std::future::Future;
30 Fut: Future<Output = IpcResult<B>>,
in spawn()
69 T: Future<Output = R>,
in spawn()
85 fn block_on<F: Future>(future: F) -> F::Output {
in block_on()
|
| H A D | mod.rs | 18 use std::future::Future;
28 pub type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>;
44 Fut: Future<Output = IpcResult<B>>,
in spawn()
57 T: Future<Output = R>,
in spawn()
70 fn block_on<F: Future>(future: F) -> F::Output;
in spawn()
|
| /foundation/ai/ai_engine/services/server/server_executor/include/ |
| H A D | future_factory.h | 81 void AddFuture(long long sequenceId, Future* future);
85 Future* FetchFuture(Response *response);
97 using Futures = std::map<long long, Future*>;
|
| H A D | future.h | 32 class Future : public IFuture { class
35 Future(IRequest *request, long long sequenceId, long long transactionId);
37 ~Future() override;
49 * @return Future status.
57 * @return Future status.
|
| /foundation/window/window_manager/utils/include/ |
| H A D | future.h | 25 class Future {
class
26 constexpr static HiviewDFX::HiLogLabel LABEL = {LOG_CORE, HILOG_DOMAIN_WINDOW, "Future"};
58 class RunnableFuture : public Future<T> {
62 Future<T>::FutureCall(res);
in SetValue()
71 std::unique_lock <std::mutex> lock(Future<T>::mutex_);
in ResetLock()
|
| H A D | surface_capture_future.h | 25 class SurfaceCaptureFuture : public SurfaceCaptureCallback, public Future<std::shared_ptr<Media::PixelMap>> {
|
| /foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/ |
| H A D | future.h | 77 class Future { class
81 Future(IFuture::Ptr fut) : fut_(BASE_NS::move(fut)) {} in Future() function in Future
102 return Future<decltype(func(nullptr))>(fut_->Then(CreateContinuation(func), queue)); in Then()
108 return Future<ReturnType>(fut_->Then(CreateContinuation([f = BASE_NS::move(func)](const IAny::Ptr& v) { in Then()
150 Type GetResultOr(const Future<Type>& f, NonDeduced_t<Type> def)
|
| H A D | task_queue.h | 36 return Future<PlainType_t<decltype(func())>>(fut); in CreateFutureFromResultFunction()
46 return Future<PlainType_t<decltype(func())>>(queue->AddWaitableTask(CreateWaitableTask(func))); in AddFutureTaskOrRunDirectly()
|
| /foundation/multimodalinput/input/intention/scheduler/task_scheduler/include/ |
| H A D | task_scheduler.h | 43 using Future = std::future<int32_t>;
71 using Future = Task::Future;
|
| /foundation/multimodalinput/input/service/delegate_task/include/ |
| H A D | delegate_tasks.h | 41 using Future = std::future<int32_t>;
69 using Future = Task::Future;
|
| /foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/ |
| H A D | operator.rs | 17 use std::future::Future;
133 impl<'a, 'b, T> Future for DownloadFuture<'a, 'b, T>
152 impl<'a, T> Future for ProgressFuture<'a, T>
|
| /foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/ |
| H A D | operator.rs | 17 use std::future::Future;
64 /// Creates a `Progress` Future.
98 impl<'a, T> Future for ProgressFuture<'a, T>
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/common/src/ |
| H A D | js_uv_queue.cpp | 158 return Future(env, info, false); in Resolved()
163 return Future(env, info, true); in Rejected()
166 napi_value UvQueue::Future(napi_env env, napi_callback_info info, bool exception) in Future() function in OHOS::AppDataMgrJsKit::UvQueue
|
| /foundation/multimodalinput/input/intention/scheduler/task_scheduler/src/ |
| H A D | task_scheduler.cpp | 90 Future future = promise.get_future(); in PostSyncTask()
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/common/include/ |
| H A D | js_uv_queue.h | 72 static napi_value Future(napi_env env, napi_callback_info info, bool exception);
|
| /foundation/multimodalinput/input/service/delegate_task/src/ |
| H A D | delegate_tasks.cpp | 97 Future future = promise.get_future(); in PostSyncTask()
|