Home
last modified time | relevance | path

Searched refs:taskId (Results 1 – 25 of 454) sorted by relevance

12345678910>>...19

/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/
H A Ddms_callback_task.cpp51 if (taskId <= 0) { in PushCallback()
69 auto iterTask = callbackMap_.find(taskId); in PushCallback()
83 .taskId = taskId, in PushCallback()
88 (void)callbackMap_.emplace(taskId, item); in PushCallback()
95 auto iter = callbackMap_.find(taskId); in PopCallback()
120 if (taskId <= 0) { in GetContinuaionMissionId()
137 if (taskId <= 0 || missionId <= 0) { in SetContinuationMissionMap()
152 if (taskId <= 0) { in GetLaunchType()
157 auto iterTask = callbackMap_.find(taskId); in GetLaunchType()
192 if (taskId <= 0) { in ProcessEvent()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_syncer_test.h55 cloudTaskInfos_[taskId].mode = mode; in InitCloudSyncer()
56 cloudTaskInfos_[taskId].taskId = taskId; in InitCloudSyncer()
66 …cloudTaskInfos_[taskId].callback = [this, taskId](const std::map<std::string, SyncProcess> &proces… in InitCloudSyncer()
147 int CallDoDownload(TaskId taskId) in CallDoDownload() argument
225 int CallPrepareSync(TaskId taskId) in CallPrepareSync() argument
227 return PrepareSync(taskId); in CallPrepareSync()
269 void SetCurrentContext(TaskId taskId) in SetCurrentContext() argument
274 void SetLastTaskId(TaskId taskId) in SetLastTaskId() argument
276 lastTaskId_ = taskId; in SetLastTaskId()
321 resumeTaskInfos_.erase(taskId); in ClearResumeTaskInfo()
[all …]
H A Ddistributeddb_cloud_syncer_download_test.cpp262 taskId = 3u;
268 taskId = 4u;
274 taskId = 5u;
311 taskId = 7u;
320 taskId = 8u;
392 taskId = 2u;
405 taskId = 3u;
449 taskId = 5u;
494 taskId = 2u;
538 taskId = 4u;
[all …]
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/
H A Ddms_callback_task_test.cpp56 .taskId = taskId, in PushMockTask()
105 int64_t taskId = -1; variable
125 int64_t taskId = 1; variable
145 int64_t taskId = 1; variable
166 int64_t taskId = 1; variable
187 int64_t taskId = 1; variable
208 int64_t taskId = 1; variable
228 int64_t taskId = 1; variable
243 int64_t taskId = 1; variable
260 int64_t taskId = 1; variable
[all …]
/ohos5.0/base/request/request/frameworks/cj/ffi/src/
H A Dcj_request_ffi.cpp26 void FfiOHOSRequestFreeTask(const char *taskId) in FfiOHOSRequestFreeTask() argument
28 CJRequestImpl::FreeTask(taskId); in FfiOHOSRequestFreeTask()
41 RetError FfiOHOSRequestTaskStart(const char *taskId) in FfiOHOSRequestTaskStart() argument
43 return CJRequestImpl::TaskStart(taskId); in FfiOHOSRequestTaskStart()
46 RetError FfiOHOSRequestTaskPause(const char *taskId) in FfiOHOSRequestTaskPause() argument
48 return CJRequestImpl::TaskPause(taskId); in FfiOHOSRequestTaskPause()
51 RetError FfiOHOSRequestTaskResume(const char *taskId) in FfiOHOSRequestTaskResume() argument
53 return CJRequestImpl::TaskResume(taskId); in FfiOHOSRequestTaskResume()
56 RetError FfiOHOSRequestTaskStop(const char *taskId) in FfiOHOSRequestTaskStop() argument
58 return CJRequestImpl::TaskStop(taskId); in FfiOHOSRequestTaskStop()
[all …]
H A Dcj_request_impl.cpp156 ret.taskId = MallocCString(task->taskId_); in CreateTask()
162 RetError CJRequestImpl::RemoveTask(std::string taskId) in RemoveTask() argument
165 ExceptionError result = CJTask::Remove(taskId); in RemoveTask()
173 void CJRequestImpl::FreeTask(std::string taskId) in FreeTask() argument
176 delete CJTask::ClearTaskMap(taskId); in FreeTask()
183 CJTask *task = CJTask::FindTaskById(taskId); in ProgressOn()
202 CJTask *task = CJTask::FindTaskById(taskId); in ProgressOff()
221 CJTask *task = CJTask::FindTaskById(taskId); in TaskExec()
235 RetError CJRequestImpl::TaskStart(std::string taskId) in TaskStart() argument
240 RetError CJRequestImpl::TaskPause(std::string taskId) in TaskPause() argument
[all …]
/ohos5.0/base/update/updateservice/services/firmware/data/db/src/
H A Dfirmware_task_operator.cpp46 return UpdateByTaskId(taskId, values); in UpdateProgressByTaskId()
54 return UpdateByTaskId(taskId, values); in UpdateErrMsgByTaskId()
61 return UpdateByTaskId(taskId, values); in UpdateDownloadTaskIdByTaskId()
69 return UpdateByTaskId(taskId, values); in UpdateCombinationTypeByTaskId()
76 return UpdateByTaskId(taskId, values); in UpdateDownloadModeByTaskId()
83 return UpdateByTaskId(taskId, values); in UpdateDownloadAllowNetworkByTaskId()
90 return UpdateByTaskId(taskId, values); in UpdateDownloadOrderByTaskId()
100 return UpdateByTaskId(taskId, values); in UpdateDownloadOptionByTaskId()
107 return UpdateByTaskId(taskId, values); in UpdateUpgradeModeByTaskId()
114 return UpdateByTaskId(taskId, values); in UpdateUpgradeOrderByTaskId()
[all …]
H A Dfirmware_task_operator_empty.cpp41 bool FirmwareTaskOperator::UpdateProgressByTaskId(const std::string &taskId, UpgradeStatus status, … in UpdateProgressByTaskId() argument
46 bool FirmwareTaskOperator::UpdateErrMsgByTaskId(const std::string &taskId, int errorCode, const std… in UpdateErrMsgByTaskId() argument
51 bool FirmwareTaskOperator::UpdateDownloadTaskIdByTaskId(const std::string &taskId, const std::strin… in UpdateDownloadTaskIdByTaskId() argument
56 bool FirmwareTaskOperator::UpdateCombinationTypeByTaskId(const std::string &taskId, in UpdateCombinationTypeByTaskId() argument
62 bool FirmwareTaskOperator::UpdateDownloadModeByTaskId(const std::string &taskId, DownloadMode downl… in UpdateDownloadModeByTaskId() argument
67 bool FirmwareTaskOperator::UpdateDownloadAllowNetworkByTaskId(const std::string &taskId, NetType do… in UpdateDownloadAllowNetworkByTaskId() argument
72 bool FirmwareTaskOperator::UpdateDownloadOrderByTaskId(const std::string &taskId, Order downloadOrd… in UpdateDownloadOrderByTaskId() argument
78 …const std::string &taskId, DownloadMode downloadMode, NetType downloadAllowNetwork, Order download… in UpdateDownloadOptionByTaskId() argument
83 bool FirmwareTaskOperator::UpdateUpgradeModeByTaskId(const std::string &taskId, UpgradeMode upgrade… in UpdateUpgradeModeByTaskId() argument
88 bool FirmwareTaskOperator::UpdateUpgradeOrderByTaskId(const std::string &taskId, Order upgradeOrder) in UpdateUpgradeOrderByTaskId() argument
/ohos5.0/foundation/filemanagement/dfs_service/frameworks/native/cloudsync_kit_inner/src/
H A Ddownload_asset_callback_client.cpp26 auto callback = GetDownloadTaskCallback(taskId); in OnFinished()
31 RemoveDownloadTaskCallback(taskId); in OnFinished()
33 taskId, GetAnonyString(uri).c_str(), in OnFinished()
39 LOGD("taskId = %{public}" PRIu64 "", taskId); in AddDownloadTaskCallback()
40 callbackListMap_.EnsureInsert(taskId, std::move(callback)); in AddDownloadTaskCallback()
43 void DownloadAssetCallbackClient::RemoveDownloadTaskCallback(TaskId taskId) in RemoveDownloadTaskCallback() argument
46 if (callbackListMap_.Find(taskId, callback)) { in RemoveDownloadTaskCallback()
47 callbackListMap_.Erase(taskId); in RemoveDownloadTaskCallback()
50 LOGE("not find task callback, taskId = %{public}" PRIu64 "", taskId); in RemoveDownloadTaskCallback()
56 if (callbackListMap_.Find(taskId, callback)) { in GetDownloadTaskCallback()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer.cpp426 TaskId taskId; in SyncMachineDoFinished() local
486 taskQueue_.remove(taskId); in DoFinished()
701 TaskId taskId; in DownloadAssets() local
938 TaskId taskId; in NeedNotifyChangedData() local
943 if (IsModeForcePush(taskId)) { in NeedNotifyChangedData()
1260 if (IsModeForcePush(uploadParam.taskId) || (IsPriorityTask(uploadParam.taskId) && in PutWaterMarkAfterBatchUpload()
1291 IsCompensatedTask(taskId), IsNeedGetLocalWater(taskId), count); in DoUpload()
1305 param.taskId = taskId; in DoUpload()
1508 cloudTaskInfos_[taskId].resume = cloudTaskInfos_[taskId].pause; in PrepareSync()
1847 return LockCloud(taskId); in LockCloudIfNeed()
[all …]
H A Dcloud_syncer.h113 TaskId taskId = 0u; member
143 int DoSync(TaskId taskId);
186 bool IsModeForcePush(TaskId taskId);
190 bool IsPriorityTask(TaskId taskId);
192 bool IsCompensatedTask(TaskId taskId);
203 int CheckTaskIdValid(TaskId taskId);
211 int PrepareSync(TaskId taskId);
213 int LockCloud(TaskId taskId);
307 int LockCloudIfNeed(TaskId taskId);
322 bool IsCurrentTaskResume(TaskId taskId);
[all …]
H A Dcloud_syncer_extend.cpp40 RecordWaterMark(taskId, 0u); in ReloadWaterMarkIfNeed()
659 IsCompensatedTask(taskId), IsNeedGetLocalWater(taskId), count); in GetUploadCountByTable()
737 return !IsModeForcePush(taskId) && (!IsPriorityTask(taskId) || IsQueryListEmpty(taskId)) && in IsNeedGetLocalWater()
762 auto taskId = taskInfo.taskId; in TryToAddSyncTask() local
767 cloudTaskInfos_[taskId].storeId.c_str(), cloudTaskInfos_[taskId].taskId); in TryToAddSyncTask()
773 cloudTaskInfos_[taskId].taskId); in TryToAddSyncTask()
785 TaskId checkTaskId = taskId; in MergeTaskInfo()
800 if (taskId == runningTask || taskId == tryTaskId) { // LCOV_EXCL_BR_LINE in TryMergeTask()
807 beMergeTask = taskId; in TryMergeTask()
814 nextTryTask = taskId; in TryMergeTask()
[all …]
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_manager.h61 void StoreTask(uint64_t taskId, Task* task);
62 void RemoveTask(uint64_t taskId);
63 Task* GetTask(uint64_t taskId);
99 std::string GetTaskName(uint64_t taskId);
106 void IncreaseRefCount(uint64_t taskId);
114 bool IsDependendByTaskId(uint64_t taskId);
133 void RemoveTaskDuration(uint64_t taskId);
135 void RemoveLongTaskInfo(uint64_t taskId);
136 void TerminateTask(uint64_t taskId);
137 Worker* GetLongTaskInfo(uint64_t taskId);
[all …]
H A Dtask_manager.cpp596 Task* task = GetTask(taskId); in CancelTask()
761 Task* task = GetTask(taskId); in EnqueueTaskId()
1138 if (id == taskId) { in CheckCircularDependency()
1175 if (taskId == 0) { in EnqueuePendingTaskInfo()
1190 if (it->first == taskId) { in DequeuePendingTaskInfo()
1313 longTasksMap_.erase(taskId); in RemoveLongTaskInfo()
1331 RemoveLongTaskInfo(taskId); in TerminateTask()
1338 RemoveTask(taskId); in ReleaseTaskData()
1362 RemoveTaskDuration(taskId); in ReleaseTaskData()
1429 tasks_.emplace(taskId, task); in StoreTask()
[all …]
/ohos5.0/base/security/device_auth/services/legacy/authenticators/src/account_related/
H A Daccount_multi_task_manager.c24 static bool IsManagerHasTaskId(int32_t taskId) in IsManagerHasTaskId() argument
27 if (g_taskManager.taskArray[i] != NULL && taskId == g_taskManager.taskArray[i]->taskId) { in IsManagerHasTaskId()
28 LOGD("Task already exists, taskId: %d.", taskId); in IsManagerHasTaskId()
45 static bool CanAddTaskInManager(int32_t taskId) in CanAddTaskInManager() argument
51 if (IsManagerHasTaskId(taskId)) { in CanAddTaskInManager()
65 if (!CanAddTaskInManager(task->taskId)) { in AddTaskToManager()
80 static AccountTask *GetTaskFromManager(int32_t taskId) in GetTaskFromManager() argument
83 … if ((g_taskManager.taskArray[i] != NULL) && (g_taskManager.taskArray[i]->taskId == taskId)) { in GetTaskFromManager()
87 LOGE("Task does not exist, taskId: %d.", taskId); in GetTaskFromManager()
91 static void DeleteTaskFromManager(int32_t taskId) in DeleteTaskFromManager() argument
[all …]
H A Daccount_module.c64 if (taskId == NULL || in == NULL || out == NULL) { in CreateAccountTask()
72 return CreateAuthSession(taskId, in, out); in CreateAccountTask()
83 AccountTask *newTask = CreateAccountTaskT(taskId, in, out); in CreateAccountTask()
99 return ProcessAuthSession(&taskId, in, out, status); in ProcessAccountTask()
106 AccountTask *currentTask = authManager->getTaskFromManager(taskId); in ProcessAccountTask()
108 LOGE("Get task from manager failed, taskId: %d.", taskId); in ProcessAccountTask()
111 LOGD("Begin process account related task, taskId: %d.", taskId); in ProcessAccountTask()
115 static void DestroyAccountTask(int taskId) in DestroyAccountTask() argument
118 (void)DestroyAuthSession(taskId); in DestroyAccountTask()
126 LOGI("Delete taskId:%d from task manager.", taskId); in DestroyAccountTask()
[all …]
/ohos5.0/foundation/arkui/ace_engine/adapter/ohos/osal/
H A Dace_trace.cpp53 void AceAsyncTraceBegin(int32_t taskId, const char* name, bool isAnimationTrace) in AceAsyncTraceBegin() argument
58 StartAsyncTrace(HITRACE_TAG_ANIMATION, nameStr, taskId); in AceAsyncTraceBegin()
60 StartAsyncTrace(HITRACE_TAG_ACE, nameStr, taskId); in AceAsyncTraceBegin()
64 void AceAsyncTraceEnd(int32_t taskId, const char* name, bool isAnimationTrace) in AceAsyncTraceEnd() argument
69 FinishAsyncTrace(HITRACE_TAG_ANIMATION, nameStr, taskId); in AceAsyncTraceEnd()
71 FinishAsyncTrace(HITRACE_TAG_ACE, nameStr, taskId); in AceAsyncTraceEnd()
80 StartAsyncTrace(ANIMATION_TRACE_COMMERCIAL, nameStr, taskId); in AceAsyncTraceBeginCommercial()
82 StartAsyncTrace(ACE_TRACE_COMMERCIAL, nameStr, taskId); in AceAsyncTraceBeginCommercial()
86 void AceAsyncTraceEndCommercial(int32_t taskId, const char* name, bool isAnimationTrace) in AceAsyncTraceEndCommercial() argument
91 FinishAsyncTrace(ANIMATION_TRACE_COMMERCIAL, nameStr, taskId); in AceAsyncTraceEndCommercial()
[all …]
/ohos5.0/base/update/updateservice/services/firmware/data/db/include/
H A Dfirmware_task_operator.h49 bool UpdateProgressByTaskId(const std::string &taskId, UpgradeStatus status, int32_t progress);
50 … bool UpdateErrMsgByTaskId(const std::string &taskId, int errorCode, const std::string &errorMsg);
51 bool UpdateDownloadTaskIdByTaskId(const std::string &taskId, const std::string &downloadTaskId);
52 bool UpdateCombinationTypeByTaskId(const std::string &taskId,
55 bool UpdateDownloadModeByTaskId(const std::string &taskId, DownloadMode downloadMode);
56 … bool UpdateDownloadAllowNetworkByTaskId(const std::string &taskId, NetType downloadAllowNetwork);
57 bool UpdateDownloadOrderByTaskId(const std::string &taskId, Order downloadOrder);
58 bool UpdateDownloadOptionByTaskId(const std::string &taskId,
61 bool UpdateUpgradeModeByTaskId(const std::string &taskId, UpgradeMode upgradeMode);
62 bool UpdateUpgradeOrderByTaskId(const std::string &taskId, Order upgradeOrder);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/test/
H A Dpriority_queue_test.cpp94 auto id = testTask.taskId;
108 auto id = testTask.taskId;
130 auto id = ++(testTask.taskId);
137 EXPECT_EQ(retPop.taskId, id);
161 EXPECT_EQ(retPop.taskId, 1);
215 auto id = ++(testTask.taskId);
222 EXPECT_EQ(retPop.taskId, id);
241 auto id = testTask.taskId;
268 EXPECT_EQ(retFind.taskId, 5);
286 auto id = testTask.taskId;
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/
H A Dtask_scheduler.h71 innerTask.taskId = GenTaskId();
78 indexes_[innerTask.taskId] = it;
79 return innerTask.taskId;
84 if (running_.taskId == taskId && running_.interval != INVALID_INTERVAL) { in Reset()
86 return running_.taskId; in Reset()
101 indexes_[taskId] = it; in Reset()
102 return taskId; in Reset()
120 return (!wait || running_.taskId != taskId);
146 TaskId taskId = INVALID_TASK_ID; member
189 auto taskId = ++taskId_; in GenTaskId() local
[all …]
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dexecutor_pool.h112 innerTask.taskId = GenTaskId(); in Schedule()
123 delayTasks_.Remove(taskId, wait);
147 innerTask.taskId = taskId; in Execute()
151 return taskId; in Execute()
162 return taskId; in Execute()
167 auto id = innerTask.taskId; in Schedule()
194 return innerTask.taskId; in Schedule()
199 auto taskId = ++taskId_; in GenTaskId() local
200 if (taskId == INVALID_TASK_ID) { in GenTaskId()
201 taskId = ++taskId_; in GenTaskId()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor_pool.h108 innerTask.taskId = GenTaskId(); in Schedule()
119 delayTasks_.Remove(taskId, wait);
143 innerTask.taskId = taskId; in Execute()
147 return taskId; in Execute()
158 return taskId; in Execute()
163 auto id = innerTask.taskId; in Schedule()
190 return innerTask.taskId; in Schedule()
195 auto taskId = ++taskId_; in GenTaskId() local
196 if (taskId == INVALID_TASK_ID) { in GenTaskId()
197 taskId = ++taskId_; in GenTaskId()
[all …]
/ohos5.0/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/
H A Dfile_transfer_manager.cpp43 const uint64_t taskId, in DownloadFileFromRemoteDevice() argument
53 .taskId = taskId}; in DownloadFileFromRemoteDevice()
65 AddTransTask(uri, userId, taskId); in DownloadFileFromRemoteDevice()
90 auto taskId = msgHandler.GetTaskId(); in HandleDownloadFileRequest() local
97 .taskId = taskId}; in HandleDownloadFileRequest()
118 auto taskId = msgHandler.GetTaskId(); in HandleDownloadFileResponse() local
121 RemoveTransTask(taskId); in HandleDownloadFileResponse()
223 TaskInfo info = {uri, relativePath, taskId}; in AddTransTask()
227 void FileTransferManager::RemoveTransTask(uint64_t taskId) in RemoveTransTask() argument
229 LOGI("remove task:%{public}" PRIu64 "", taskId); in RemoveTransTask()
[all …]
/ohos5.0/foundation/multimedia/av_session/utils/include/
H A Davsession_trace.h27 #define AVSESSION_TRACE_ASYNC_START(traceName, taskId) AVSessionTrace::TraceBegin(traceName, taskId) argument
28 #define AVSESSION_TRACE_ASYNC_END(traceName, taskId) AVSessionTrace::TraceEnd(traceName, taskId) argument
89 static void TraceBegin(const std::string& traceName, int32_t taskId) in TraceBegin() argument
91 if (taskId <= INVALID_TASK_ID) { in TraceBegin()
96 StartAsyncTrace(HITRACE_TAG_ZMEDIA, traceBegin, taskId); in TraceBegin()
99 static void TraceEnd(const std::string& traceName, int32_t taskId) in TraceEnd() argument
101 if (taskId <= INVALID_TASK_ID) { in TraceEnd()
106 FinishAsyncTrace(HITRACE_TAG_ZMEDIA, traceEnd, taskId); in TraceEnd()
/ohos5.0/base/request/request/frameworks/cj/ffi/include/
H A Dcj_request_impl.h38 static RetError RemoveTask(std::string taskId);
39 static void FreeTask(std::string taskId);
40 … static RetError ProgressOn(char *event, std::string taskId, void (*callback)(CProgress progress));
41 static RetError ProgressOff(char *event, std::string taskId, void *callback);
42 static RetError TaskStart(std::string taskId);
43 static RetError TaskPause(std::string taskId);
44 static RetError TaskResume(std::string taskId);
45 static RetError TaskStop(std::string taskId);
52 static RetError TaskExec(std::string execType, std::string taskId);

12345678910>>...19