Home
last modified time | relevance | path

Searched refs:taskId_ (Results 1 – 25 of 98) sorted by relevance

1234

/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp387 taskManager.EnqueueTaskId(task->taskId_); in EnqueueTaskId()
411 std::set<uint64_t> set{task->taskId_}; in GetTaskByPriority()
510 uint64_t id1 = task->taskId_; in StoreTaskDependency()
512 uint64_t id3 = task1->taskId_; in StoreTaskDependency()
514 uint64_t id5 = task2->taskId_; in StoreTaskDependency()
547 taskManager.RemoveTaskDependency(task->taskId_, task1->taskId_); in RemoveTaskDependency()
556 …taskManager.taskDurationInfos_.emplace(task->taskId_, std::make_pair(UINT64_ZERO_, task1->taskId_)… in RemoveTaskDependency()
574 std::set<uint64_t> set{ task->taskId_ }; in ReleaseTaskData()
605 taskManager.CheckTask(task1->taskId_); in CheckTask()
859 task->cpuTime_ = task->taskId_; in TaskResultCallback()
[all …]
/ohos5.0/foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/
H A Dffrt_utils.cpp88 taskId_.clear(); in Clear()
110 ++taskId_[timerId]; in SetTimer()
112 taskId_[timerId]); in SetTimer()
125 ++taskId_[timerId]; in SetTimer()
127 timerId.c_str(), taskId_[timerId], delayMs); in SetTimer()
135 uint32_t id = taskId_[timerId]; in GetTaskId()
146 taskId_[p.first]); in CancelAllTimerInner()
156 taskId_[timerId]); in CancelTimerInner()
/ohos5.0/foundation/multimedia/media_library/frameworks/services/media_backup_extension/src/report/
H A Dupgrade_restore_task_report.cpp35 …UpgradeRestoreGalleryMediaTask().SetSceneCode(this->sceneCode_).SetTaskId(this->taskId_).LoadTask(… in ReportTask()
49 .SetTaskId(this->taskId_) in Report()
63 .SetTaskId(this->taskId_) in ReportError()
76 .SetTaskId(this->taskId_) in ReportProgress()
111 int64_t startTime = std::atoll(this->taskId_.c_str()); in ReportTimeCost()
153 …BackupHiAuditHelper().SetSceneCode(this->sceneCode_).SetTaskId(this->taskId_).WriteReportAuditLog(… in PostInfoAuditLog()
159 …BackupHiAuditHelper().SetSceneCode(this->sceneCode_).SetTaskId(this->taskId_).WriteErrorAuditLog(i… in PostErrorInfoAuditLog()
167 .SetTaskId(this->taskId_) in PostProgressInfoAuditLog()
H A Ddatabase_report.cpp39 .SetTaskId(this->taskId_) in LoadGallery()
51 .SetTaskId(this->taskId_) in LoadExternal()
61 .SetTaskId(this->taskId_) in LoadMedia()
135 …BackupHiAuditHelper().SetSceneCode(this->sceneCode_).SetTaskId(this->taskId_).WriteReportAuditLog(… in PostInfoAuditLog()
H A Dgallery_media_count_statistic.cpp449 info.taskId = this->taskId_; in GetAllStatInfo()
482 info.taskId = this->taskId_; in GetAllImageStatInfo()
521 info.taskId = this->taskId_; in GetAllVideoStatInfo()
558 info.taskId = this->taskId_; in GetAllRestoreStatInfo()
593 info.taskId = this->taskId_; in GetAllRestoreImageStatInfo()
632 info.taskId = this->taskId_; in GetAllRestoreVideoStatInfo()
669 info.taskId = this->taskId_; in GetSdCardStatInfo()
705 info.taskId = this->taskId_; in GetDuplicateStatInfo()
730 info.taskId = this->taskId_; in GetAppTwinStatInfo()
755 info.taskId = this->taskId_; in GetImageAlbumInfo()
[all …]
H A Dphotos_count_statistic.cpp266 info.taskId = this->taskId_; in GetAllStatInfo()
299 info.taskId = this->taskId_; in GetAllImageStatInfo()
337 info.taskId = this->taskId_; in GetAllVideoStatInfo()
374 info.taskId = this->taskId_; in GetAllRestoreStatInfo()
407 info.taskId = this->taskId_; in GetAllRestoreImageStatInfo()
446 info.taskId = this->taskId_; in GetAllRestoreVideoStatInfo()
483 info.taskId = this->taskId_; in GetImageAlbumInfo()
525 info.taskId = this->taskId_; in GetVideoAlbumInfo()
605 info.taskId = this->taskId_; in GetFavoriteAlbumStatInfo()
645 info.taskId = this->taskId_; in GetTrashedAlbumStatInfo()
[all …]
H A Dexternal_files_count_statistic.cpp39 info.taskId = this->taskId_; in GetMediaStatInfo()
51 info.taskId = this->taskId_; in GetAudioStatInfo()
61 info.taskId = this->taskId_; in GetGalleryNotSyncMediaStatInfo()
/ohos5.0/base/powermgr/power_manager/utils/ffrt/src/
H A Dffrt_utils.cpp104 taskId_.clear(); in Clear()
126 ++taskId_[timerId]; in SetTimer()
127 POWER_HILOGD(FEATURE_UTIL, "Timer[%{public}u] Add Task[%{public}u]", timerId, taskId_[timerId]); in SetTimer()
140 ++taskId_[timerId]; in SetTimer()
142 timerId, taskId_[timerId], delayMs); in SetTimer()
150 uint32_t id = taskId_[timerId]; in GetTaskId()
160 …POWER_HILOGD(FEATURE_UTIL, "Timer[%{public}u] Cancel Task[%{public}u]", p.first, taskId_[p.first]); in CancelAllTimerInner()
170 …POWER_HILOGD(FEATURE_UTIL, "Timer[%{public}u] Cancel Task[%{public}u]", timerId, taskId_[timerId]); in CancelTimerInner()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
H A Ddb_delegate.cpp23 ExecutorPool::TaskId DBDelegate::taskId_ = ExecutorPool::INVALID_TASK_ID; member in OHOS::DataShare::DBDelegate
78 if (executor_ == nullptr || taskId_ != Executor::INVALID_TASK_ID) { in StartTimer()
81 taskId_ = executor_->Schedule( in StartTimer()
85 if (executor_ == nullptr || taskId_ == Executor::INVALID_TASK_ID) { in StartTimer()
88 executor_->Remove(taskId_); in StartTimer()
89 ZLOGD("remove timer, taskId: %{public}" PRIu64, taskId_); in StartTimer()
90 taskId_ = Executor::INVALID_TASK_ID; in StartTimer()
94 ZLOGD("start timer, taskId: %{public}" PRIu64, taskId_); in StartTimer()
/ohos5.0/base/useriam/user_auth_framework/frameworks/native/common/dfx/src/
H A Diam_hitrace_helper.cpp26 : taskId_(GetHiTraceTaskId()), in IamHitraceHelper()
29 StartAsyncTrace(HITRACE_TAG_USERIAM, value_, taskId_); in IamHitraceHelper()
34 FinishAsyncTrace(HITRACE_TAG_USERIAM, value_, taskId_); in ~IamHitraceHelper()
/ohos5.0/foundation/communication/netstack/frameworks/native/http/http_client/
H A Dhttp_client_task.cpp70 taskId_(nextTaskId_++), in HttpClientTask()
75 NETSTACK_LOGD("id=%{public}d", taskId_); in HttpClientTask()
93 taskId_(nextTaskId_++), in HttpClientTask()
113 NETSTACK_LOGD("Destroy: taskId_=%{public}d", taskId_); in ~HttpClientTask()
378 NETSTACK_LOGD("task is running, taskId_=%{public}d", taskId_); in Start()
396 NETSTACK_LOGD("taskId_=%{public}d", taskId_); in Start()
433 return taskId_; in GetTaskId()
495 task->taskId_, dltotal, dlnow, ultotal, ulnow); in ProgressCallback()
556 NETSTACK_LOGD("id=%{public}d, code=%{public}d", taskId_, resultCode); in ProcessResponseCode()
626 … taskId_, GetSizeFromCurl(curlHandle_), dnsTime, connectTime == 0 ? 0 : connectTime - dnsTime, in DumpHttpPerformance()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/
H A Dstore_cache.cpp65 if (taskId_ == ExecutorPool::INVALID_TASK_ID && executorPool_ != nullptr) { in GetStore()
66 …taskId_ = executorPool_->Schedule(std::chrono::minutes(INTERVAL), std::bind(&StoreCache::GarbageCo… in GetStore()
84 …taskId_ = executorPool_->Schedule(std::chrono::minutes(INTERVAL), std::bind(&StoreCache::GarbageCo… in GarbageCollect()
86 taskId_ = ExecutorPool::INVALID_TASK_ID; in GarbageCollect()
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask.cpp85 TaskManager::GetInstance().StoreTask(task->taskId_, task); in TaskConstructor()
167 task->taskId_ = reinterpret_cast<uint64_t>(task); in GenerateTask()
216 task->taskId_ = reinterpret_cast<uint64_t>(task); in GenerateFunctionTask()
560 if (dependentTask->taskId_ == task->taskId_) { in AddDependency()
582 idSet.emplace(dependentTask->taskId_); in AddDependency()
661 … if (!TaskManager::GetInstance().RemoveTaskDependency(task->taskId_, dependentTask->taskId_)) { in RemoveDependency()
1073 TaskManager::GetInstance().NotifyDependencyTaskInfo(taskId_); in NotifyPendingTask()
1079 std::to_string(taskId_).c_str()); in NotifyPendingTask()
1411 uint64_t taskId = taskId_; in VerifyAndPostResult()
1454 TaskManager::GetInstance().RemoveTask(taskId_); in ShouldDeleteTask()
[all …]
H A Dtaskpool.cpp275 TaskManager::GetInstance().StoreTask(task->taskId_, task); in Execute()
354 taskMessage->taskId = task->taskId_; in ExecuteDelayed()
358 std::string strTrace = "ExecuteDelayed: taskId: " + std::to_string(task->taskId_); in ExecuteDelayed()
511 TaskManager::GetInstance().DecreaseRefCount(task->env_, task->taskId_); in TriggerTask()
529 TaskManager::GetInstance().RemoveTask(task->taskId_); in TriggerTask()
536 TaskManager::GetInstance().DecreaseRefCount(task->env_, task->taskId_); in UpdateGroupInfoByResult()
549 uint32_t index = taskGroup->GetTaskIndex(task->taskId_); in UpdateGroupInfoByResult()
596 std::string strTrace = "Task Allocation: taskId : " + std::to_string(task->taskId_) in ExecuteTask()
602 TaskManager::GetInstance().IncreaseRefCount(task->taskId_); in ExecuteTask()
606 TaskManager::GetInstance().EnqueueTaskId(task->taskId_, priority); in ExecuteTask()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/
H A Dauto_cache.cpp43 if (executor == nullptr || taskId_ != Executor::INVALID_TASK_ID) { in Bind()
57 executor_->Remove(taskId_, true); in ~AutoCache()
126 if (executor_ == nullptr || taskId_ != Executor::INVALID_TASK_ID) { in StartTimer()
129 taskId_ = executor_->Schedule( in StartTimer()
133 if (executor_ == nullptr || taskId_ == Executor::INVALID_TASK_ID) { in StartTimer()
136 executor_->Remove(taskId_); in StartTimer()
137 ZLOGD("remove timer,taskId: %{public}" PRIu64, taskId_); in StartTimer()
138 taskId_ = Executor::INVALID_TASK_ID; in StartTimer()
142 ZLOGD("start timer,taskId: %{public}" PRIu64, taskId_); in StartTimer()
/ohos5.0/base/print/print_fwk/interfaces/kits/napi/print_napi/src/
H A Dprint_task.cpp49 : taskId_("") in PrintTask()
78 : taskId_("") in PrintTask()
124 taskId_ = jobId; in Start()
135 return PrintManagerClient::GetInstance()->StartPrint(fileList_, fdList_, taskId_); in Start()
153 taskId_ = jobId; in StartPrintAdapter()
159 printJobName_, printAdapterCallback_, *printAttributes_, taskId_, callerToken_); in StartPrintAdapter()
365 PrintManagerClient::GetInstance()->StopPrint(taskId_); in Stop()
366 taskId_ = ""; in Stop()
371 return taskId_; in GetId()
407 int32_t ret = PrintManagerClient::GetInstance()->On(task->taskId_, type, callback); in On()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/permission/
H A Duri_permission_manager.cpp69 if (taskId_ == ExecutorPool::INVALID_TASK_ID && executorPool_ != nullptr) { in GrantUriPermission()
70 taskId_ = executorPool_->Schedule( in GrantUriPermission()
107 taskId_ = executorPool_->Schedule( in RevokeUriPermission()
110 taskId_ = ExecutorPool::INVALID_TASK_ID; in RevokeUriPermission()
/ohos5.0/foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/1.0/include/
H A Ddscreen.h56 taskId_(taskId), taskParam_(taskParam) {}; in Task()
58 taskId_(""), taskParam_(taskParam) {}; in Task()
67 return taskId_; in GetTaskId()
76 std::string taskId_; variable
/ohos5.0/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/
H A Dmessage_handler.cpp33 taskId_(info.taskId) in MessageHandler()
72 userData->taskId = htole64(taskId_); in PackData()
123 taskId_ = le64toh(userData->taskId); in UnPackData()
145 return taskId_; in GetTaskId()
/ohos5.0/foundation/bundlemanager/app_domain_verify/frameworks/common/src/httpsession/
H A Di_http_task.cpp21 taskId_ = idGen_++; in IHttpTask()
25 return taskId_; in GetTaskId()
/ohos5.0/foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/2.0/include/
H A Ddscreen.h54 taskId_(taskId), taskParam_(taskParam) {}; in Task()
56 taskId_(""), taskParam_(taskParam) {}; in Task()
65 return taskId_; in GetTaskId()
74 std::string taskId_; variable
/ohos5.0/base/request/request/frameworks/cj/ffi/include/
H A Dcj_response_listener.h30 explicit CJResponseListener(const std::string &taskId) : taskId_(taskId) {} in CJResponseListener()
33 const std::string taskId_;
/ohos5.0/foundation/arkui/ace_engine/frameworks/base/log/
H A Dace_trace.cpp138 taskId_ = id_++; in AceAsyncScopedTrace()
141 name_ = AceAsyncTraceBeginWithArgv(taskId_, format, args); in AceAsyncScopedTrace()
148 AceAsyncTraceEnd(taskId_, name_.c_str()); in ~AceAsyncScopedTrace()
/ohos5.0/foundation/multimedia/media_foundation/engine/foundation/utils/
H A Dhitrace_utils.cpp31 :title_(title), taskId_(taskId) in AsyncTracker()
38 FinishAsyncTrace(DEFAULT_HITRACE_TAG, title_, taskId_); in ~AsyncTracker()
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/
H A Ddms_free_install_callback.cpp28 : taskId_(taskId), info_(info) in DmsFreeInstallCallback()
38 DistributedSchedService::GetInstance().NotifyCompleteFreeInstall(info_, taskId_, resultCode); in OnInstallFinished()

1234