Home
last modified time | relevance | path

Searched refs:task_ (Results 1 - 25 of 79) sorted by relevance

1234

/foundation/ability/ability_runtime/frameworks/native/ability/native/
H A Dability_post_event_timeout.cpp31 task_ = str + strId; in AbilityPostEventTimeout()
42 TAG_LOGI(AAFwkTag::ABILITY, "call %{public}s", task_.c_str()); in TimingBegin()
45 task_.c_str()); in TimingBegin()
57 handler_->PostTask(task, task_, delaytime); in TimingBegin()
62 TAG_LOGE(AAFwkTag::ABILITY, "null %{public}s handler_", task_.c_str()); in TimeEnd()
69 handler_->RemoveTask(task_); in TimeEnd()
75 TAG_LOGI(AAFwkTag::ABILITY, "call %{public}s", task_.c_str()); in TimeOutProc()
77 TAG_LOGE(AAFwkTag::ABILITY, "null %{public}s handler_", task_.c_str()); in TimeOutProc()
84 TAG_LOGW(AAFwkTag::ABILITY, "%{public}s TimeOut", task_.c_str()); in TimeOutProc()
85 handler_->RemoveTask(task_); in TimeOutProc()
[all...]
/foundation/arkui/ace_engine/adapter/ohos/entrance/
H A Dace_rosen_sync_task.h27 : Rosen::RSSyncTask(timeoutNS), task_(std::move(task)) in AceRosenSyncTask()
50 if (task_) {
51 task_();
56 std::function<void()> task_; member in OHOS::Ace::Platform::AceRosenSyncTask
/foundation/ability/ability_runtime/services/abilitymgr/src/
H A Dag_convert_callback_impl.cpp26 if (task_) { in OnConvert()
28 task_(resultCode, want); in OnConvert()
36 task_ = nullptr; in Cancel()
/foundation/arkui/ace_engine/frameworks/component_test/
H A Dtest_task_scheduler.cpp42 std::function<void()> task_; in PushTask() local
54 task_ = [data, task = std::move(task), finish = std::move(finish_)]() { in PushTask()
59 task_ = [finish = std::move(finish_)]() { finish(); }; in PushTask()
63 [this, task = std::move(task_), taskType]() { in PushTask()
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/src/
H A Dmessage.cpp43 task_ = nullptr; in Message()
54 this->task_ = func; in SetFunction()
73 this->task_ = msg.task_; in operator =()
86 this->task_ = msg.task_; in Message()
/foundation/CastEngine/castengine_cast_plus_stream/src/utils/src/
H A Dmessage.cpp43 task_ = nullptr; in Message()
54 this->task_ = func; in SetFunction()
73 this->task_ = msg.task_; in operator =()
86 this->task_ = msg.task_; in Message()
/foundation/graphic/graphic_3d/3d_widget_adapter/src/
H A Dgraphics_task.cpp28 : task_(std::move(task)) in Message()
32 : task_(std::move(msg.task_)), pms_(std::move(msg.pms_)), ftr_(std::move(msg.ftr_)) in Message()
37 task_ = std::move(msg.task_); in operator =()
45 task_(); in Execute()
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Ddelay_notify.cpp20 DelayNotify::DelayNotify() : pauseCount_(0), task_(nullptr), pool_(nullptr) in DelayNotify()
32 if (task_ != nullptr && changedData_.tableData.size() > 0) { in ~DelayNotify()
36 auto errCode = task_(changedData_, rdbNotifyConfig); in ~DelayNotify()
72 task_ = std::move(task); in SetTask()
118 task_(changedData, rdbNotifyConfig); in StartTimer()
143 if (task_ != nullptr && (changedData.tableData.size() > 0 || isFull)) { in ExecuteTask()
147 int errCode = task_(changedData, rdbNotifyConfig); in ExecuteTask()
/foundation/arkui/ace_engine/adapter/ohos/entrance/dynamic_component/
H A Duv_task_wrapper_impl.h39 explicit UVWorkWrapper(const TaskExecutor::Task& task) : uv_work_t(), task_(task) in UVWorkWrapper()
45 task_(); in operator ()()
49 TaskExecutor::Task task_; member in OHOS::Ace::NG::UVWorkWrapper
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/common/
H A Drs_thread_handler_generic.cpp32 explicit GenericMessageHandler(const RSTaskMessage::RSTask task) : task_(task) {} in GenericMessageHandler()
38 if (task_) {
39 task_();
44 RSTaskMessage::RSTask task_ = nullptr; member in OHOS::Rosen::final
/foundation/graphic/graphic_2d/rosen/modules/hyper_graphic_manager/core/frame_rate_manager/
H A Dhgm_task_handle_thread.h34 return std::make_pair(t, t->task_.get_future()); in Create()
39 task_(); in Run()
43 explicit ScheduledTask(Task&& task) : task_(std::move(task)) {} in ScheduledTask()
47 std::packaged_task<Return()> task_;
/foundation/ability/ability_runtime/frameworks/native/ability/ability_runtime/
H A Ddialog_request_callback_impl.cpp25 if (task_) { in SendResult()
27 task_(resultCode, want); in SendResult()
H A Dauthorization_result.cpp25 if (task_) { in GrantResultsCallback()
27 task_(permissions, grantResults); in GrantResultsCallback()
/foundation/multimedia/media_foundation/engine/pipeline/filters/demux/
H A Dtype_finder.cpp70 task_(nullptr), in TypeFinder()
81 if (task_) { in ~TypeFinder()
82 task_->Stop(); in ~TypeFinder()
137 task_ = std::make_shared<OSAL::Task>("TypeFinder"); in FindMediaTypeAsync()
138 task_->RegisterHandler([this]() { DoTask(); }); in FindMediaTypeAsync()
139 task_->Start(); in FindMediaTypeAsync()
182 task_->StopAsync(); in DoTask()
/foundation/multimedia/player_framework/services/utils/
H A Dtask_queue.cpp141 std::shared_ptr<ITaskHandler> task = taskList_.front().task_;
175 if (item.task_ == nullptr || item.task_->IsCanceled()) { in TaskProcessor()
183 item.task_->Execute(); in TaskProcessor()
187 if (item.task_->GetAttribute().periodicTimeUs_ == UINT64_MAX) { in TaskProcessor()
190 int32_t res = EnqueueTask(item.task_, false, item.task_->GetAttribute().periodicTimeUs_); in TaskProcessor()
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dpriority_queue.h31 _Tsk task_; member
34 PQMatrix(_Tsk task, _Tid id) : task_(task), id_(id) {} in PQMatrix()
58 auto res = std::move(temp->second.task_); in Pop()
88 return indexes_[id]->second.task_; in Find()
98 auto [repeat, time] = updater(index->second->second.task_); in Update()
108 auto [repeat, time] = updater((*running).second.task_); in Update()
151 auto [repeat, time] = updater_(it->second.task_); in Finish()
/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dpriority_queue.h31 _Tsk task_; member
33 PQMatrix(_Tsk task, _Tid id) : task_(task), id_(id) {} in PQMatrix()
57 auto res = std::move(temp->second.task_); in Pop()
87 return indexes_[id]->second.task_; in Find()
97 auto [updated, time] = updater(index->second->second.task_); in Update()
110 auto [updated, time] = updater((*running).second.task_); in Update()
148 auto [repeat, time] = updater_(it->second.task_); in Finish()
/foundation/ability/ability_runtime/interfaces/kits/native/ability/ability_runtime/
H A Ddialog_request_callback_impl.h26 explicit DialogRequestCallbackImpl(RequestDialogResultTask &&task) : task_(task) {} in DialogRequestCallbackImpl()
32 RequestDialogResultTask task_; member in OHOS::AbilityRuntime::DialogRequestCallbackImpl
H A Dauthorization_result.h26 explicit AuthorizationResult(PermissionRequestTask&& task) : task_(task) {} in AuthorizationResult()
33 PermissionRequestTask task_; member in OHOS::AbilityRuntime::AuthorizationResult
/foundation/arkui/ace_engine/frameworks/core/pipeline_ng/
H A Dui_task_scheduler.h44 explicit UITask(std::function<void()>&& task) : task_(std::move(task)) {} in UITask()
46 UITask(std::function<void()>&& task, TaskThread taskThread) : task_(std::move(task)), taskThread_(taskThread) {} in UITask()
62 if (task_) { in operator ()()
63 task_(); in operator ()()
68 std::function<void()> task_; member in OHOS::Ace::NG::UITask
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_source/monitor/
H A Ddownload_monitor.cpp35 task_ = std::make_shared<OSAL::Task>(std::string("HttpMonitor")); in move()
36 task_->RegisterHandler([this] { HttpMonitorLoop(); }); in move()
37 task_->Start(); in move()
87 task_->Stop(); in Close()
181 task_->StopAsync(); in NeedRetry()
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_source/download/
H A Ddownloader.cpp125 task_ = std::make_shared<OSAL::Task>(std::string(name_ + "Downloader")); in move()
126 task_->RegisterHandler([this] { HttpDownloadLoop(); }); in move()
153 task_->Start(); in Start()
164 task_->Pause(); in Pause()
176 task_->Pause(); in Cancle()
204 task_->StopAsync(); in Stop()
206 task_->Stop(); in Stop()
236 task_->Pause(); in Retry()
251 task_->Start(); in Retry()
303 task_ in HttpDownloadLoop()
[all...]
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/ext/
H A Dtask_queue.h29 : task_(BASE_NS::move(task)), promise_(BASE_NS::move(p)) in PromisedQueueTask()
34 auto res = task_->Invoke();
37 task_.reset();
58 ITaskQueueWaitableTask::Ptr task_; member in PromisedQueueTask
/foundation/multimedia/player_framework/services/engine/histreamer/player/
H A Ddragging_player_agent.cpp116 task_ = std::make_unique<Task>("draggingThread", threadName_, TaskType::GLOBAL, TaskPriority::NORMAL, false); in Init()
117 task_->Start(); in Init()
139 if (task_) { in UpdateSeekPos()
142 task_->SubmitJob([this, seekCnt]() { StopDragging(seekCnt); }, 33333); // 33333 means 33333us, 33ms in UpdateSeekPos()
159 if (task_) { in Release()
160 task_->Stop(); in Release()
/foundation/CastEngine/castengine_cast_plus_stream/src/utils/include/
H A Dmessage.h39 Function task_ = nullptr;
80 return (this->what_ == msg.what_) && (this->task_ != nullptr) && (msg.task_ != nullptr); in operator ==()

Completed in 10 milliseconds

1234