Home
last modified time | relevance | path

Searched refs:taskInfo (Results 1 - 25 of 27) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_syncer_test.h90 CloudTaskInfo taskInfo; in CreateCloudTaskInfoAndCallTryToAddSync() local
91 taskInfo.mode = mode; in CreateCloudTaskInfoAndCallTryToAddSync()
92 taskInfo.table = tables; in CreateCloudTaskInfoAndCallTryToAddSync()
93 taskInfo.callback = onProcess; in CreateCloudTaskInfoAndCallTryToAddSync()
94 taskInfo.timeout = waitTime; in CreateCloudTaskInfoAndCallTryToAddSync()
95 return TryToAddSyncTask(std::move(taskInfo)); in CreateCloudTaskInfoAndCallTryToAddSync()
124 int CallDoSyncInner(const CloudTaskInfo &taskInfo) in CallDoSyncInner() argument
126 return DoSyncInner(taskInfo); in CallDoSyncInner()
190 CloudTaskInfo taskInfo; in SetAndGetCloudTaskInfo() local
191 taskInfo in SetAndGetCloudTaskInfo()
215 CallTryToAddSyncTask(CloudTaskInfo &&taskInfo) CallTryToAddSyncTask() argument
353 CloudTaskInfo taskInfo; CallDoDownloadInNeed() local
363 CloudTaskInfo taskInfo; CallDoUploadInNeed() local
[all...]
H A Dvirtual_cloud_syncer.cpp36 int VirtualCloudSyncer::DoDownloadInNeed(const CloudTaskInfo &taskInfo, const bool needUpload, bool isFirstDownload) in DoDownloadInNeed() argument
45 return CloudSyncer::DoDownloadInNeed(taskInfo, needUpload, isFirstDownload); in DoDownloadInNeed()
89 CloudTaskInfo taskInfo = cloudTaskInfos_[currentContext_.currentTaskId]; in Notify() local
90 currentContext_.notifier->NotifyProcess(taskInfo, {}, notifyIfError); in Notify()
105 CloudTaskInfo taskInfo; in SetCurrentTaskInfo() local
106 taskInfo.callback = callback; in SetCurrentTaskInfo()
107 cloudTaskInfos_[taskId] = taskInfo; in SetCurrentTaskInfo()
H A Dvirtual_cloud_syncer.h27 int DoDownloadInNeed(const CloudTaskInfo &taskInfo, const bool needUpload, bool isFirstDownload) override;
/foundation/resourceschedule/ffrt/src/util/
H A Dworker_monitor.cpp209 TaskTimeoutInfo& taskInfo = workerIter->second; in RecordTimeoutFunctionInfo() local
210 if (taskInfo.task_ == workerTask) { in RecordTimeoutFunctionInfo()
211 if (++taskInfo.sampledTimes_ < SAMPLING_TIMES_PER_SEC) { in RecordTimeoutFunctionInfo()
215 taskInfo.sampledTimes_ = 0; in RecordTimeoutFunctionInfo()
216 if (++taskInfo.executionTime_ % TIMEOUT_RECORD_CYCLE_LIST[taskInfo.recordLevel_] == 0) { in RecordTimeoutFunctionInfo()
218 timeoutFunctions.emplace_back(coWorkerInfo, workerInfo, taskInfo.executionTime_); in RecordTimeoutFunctionInfo()
219 if (taskInfo.recordLevel_ < static_cast<int>(TIMEOUT_RECORD_CYCLE_LIST.size()) - 1) { in RecordTimeoutFunctionInfo()
220 taskInfo.recordLevel_++; in RecordTimeoutFunctionInfo()
227 if (taskInfo in RecordTimeoutFunctionInfo()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dprocess_notifier.cpp74 void ProcessNotifier::NotifyProcess(const ICloudSyncer::CloudTaskInfo &taskInfo, in NotifyProcess() argument
81 if (!notifyWhenError && taskInfo.errCode != E_OK) { in NotifyProcess()
85 syncProcess_.errCode = TransferDBErrno(taskInfo.errCode, true); in NotifyProcess()
86 syncProcess_.process = taskInfo.status; in NotifyProcess()
87 multiSyncProcess_[user_].errCode = TransferDBErrno(taskInfo.errCode, true); in NotifyProcess()
88 multiSyncProcess_[user_].process = taskInfo.status; in NotifyProcess()
98 SyncProcessCallback callback = taskInfo.callback; in NotifyProcess()
H A Dcloud_syncer_extend.cpp482 void CloudSyncer::GenerateCompensatedSync(CloudTaskInfo &taskInfo) in GenerateCompensatedSync() argument
495 taskInfo.users.clear(); in GenerateCompensatedSync()
500 taskInfo.users.push_back(user); in GenerateCompensatedSync()
504 taskInfo.table.push_back(query.GetRelationTableName()); in GenerateCompensatedSync()
505 taskInfo.queryList.push_back(query); in GenerateCompensatedSync()
507 Sync(taskInfo); in GenerateCompensatedSync()
555 int CloudSyncer::PrepareAndDownload(const std::string &table, const CloudTaskInfo &taskInfo, bool isFirstDownload) in PrepareAndDownload() argument
567 errCode = CheckTaskIdValid(taskInfo.taskId); in PrepareAndDownload()
572 errCode = DoDownload(taskInfo.taskId, isFirstDownload); in PrepareAndDownload()
706 int CloudSyncer::DoDownloadInNeed(const CloudTaskInfo &taskInfo, cons argument
760 TryToAddSyncTask(CloudTaskInfo &&taskInfo) TryToAddSyncTask() argument
858 IsTaskCanMerge(const CloudTaskInfo &taskInfo) IsTaskCanMerge() argument
866 const auto &taskInfo = cloudTaskInfos_[taskId]; IsTasksCanMerge() local
886 AdjustTableBasedOnSchema(const std::shared_ptr<DataBaseSchema> &cloudSchema, CloudTaskInfo &taskInfo) AdjustTableBasedOnSchema() argument
1234 GenerateTaskIdIfNeed(CloudTaskInfo &taskInfo) GenerateTaskIdIfNeed() argument
[all...]
H A Dcloud_sync_utils.cpp612 CloudSyncer::CloudTaskInfo taskInfo; in InitCompensatedSyncTaskInfo() local
613 taskInfo.priorityTask = true; in InitCompensatedSyncTaskInfo()
614 taskInfo.timeout = CloudDbConstant::CLOUD_DEFAULT_TIMEOUT; in InitCompensatedSyncTaskInfo()
615 taskInfo.mode = SyncMode::SYNC_MODE_CLOUD_MERGE; in InitCompensatedSyncTaskInfo()
616 taskInfo.callback = nullptr; in InitCompensatedSyncTaskInfo()
617 taskInfo.compensatedTask = true; in InitCompensatedSyncTaskInfo()
618 return taskInfo; in InitCompensatedSyncTaskInfo()
624 CloudSyncer::CloudTaskInfo taskInfo = InitCompensatedSyncTaskInfo(); in InitCompensatedSyncTaskInfo() local
625 taskInfo.callback = onProcess; in InitCompensatedSyncTaskInfo()
626 taskInfo in InitCompensatedSyncTaskInfo()
638 CloudSyncer::CloudTaskInfo taskInfo = InitCompensatedSyncTaskInfo(); InitCompensatedSyncTaskInfo() local
[all...]
H A Dcloud_syncer.cpp56 CloudTaskInfo taskInfo; in Sync() local
57 taskInfo.mode = mode; in Sync()
58 taskInfo.table = tables; in Sync()
59 taskInfo.callback = callback; in Sync()
60 taskInfo.timeout = waitTime; in Sync()
61 taskInfo.devices = devices; in Sync()
65 taskInfo.queryList.push_back(syncObject); in Sync()
67 return Sync(taskInfo); in Sync()
70 int CloudSyncer::Sync(const CloudTaskInfo &taskInfo) in Sync() argument
72 int errCode = CloudSyncUtils::CheckParamValid(taskInfo in Sync()
228 CloudTaskInfo taskInfo; DoSync() local
277 PrepareAndUpload(const CloudTaskInfo &taskInfo, size_t index) PrepareAndUpload() argument
309 DoUploadInNeed(const CloudTaskInfo &taskInfo, const bool needUpload) DoUploadInNeed() argument
355 CloudTaskInfo taskInfo; SyncMachineDoDownload() local
389 CloudTaskInfo taskInfo; SyncMachineDoUpload() local
444 CloudTaskInfo taskInfo; SyncMachineDoFinished() local
459 DoSyncInner(const CloudTaskInfo &taskInfo) DoSyncInner() argument
1105 CloudTaskInfo taskInfo; NotifyInBatchUpload() local
1929 CloudTaskInfo taskInfo = CloudSyncUtils::InitCompensatedSyncTaskInfo(info); ClearContextAndNotify() local
[all...]
H A Dcloud_syncer.h52 int Sync(const CloudTaskInfo &taskInfo);
73 void GenerateCompensatedSync(CloudTaskInfo &taskInfo);
145 int PrepareAndUpload(const CloudTaskInfo &taskInfo, size_t index);
147 int DoSyncInner(const CloudTaskInfo &taskInfo);
149 int DoUploadInNeed(const CloudTaskInfo &taskInfo, const bool needUpload);
158 virtual int DoDownloadInNeed(const CloudTaskInfo &taskInfo, const bool needUpload, bool isFirstDownload);
207 int TryToAddSyncTask(CloudTaskInfo &&taskInfo);
386 int PrepareAndDownload(const std::string &table, const CloudTaskInfo &taskInfo, bool isFirstDownload);
398 bool IsTaskCanMerge(const CloudTaskInfo &taskInfo);
404 void AdjustTableBasedOnSchema(const std::shared_ptr<DataBaseSchema> &cloudSchema, CloudTaskInfo &taskInfo);
[all...]
H A Dprocess_notifier.h30 void NotifyProcess(const ICloudSyncer::CloudTaskInfo &taskInfo, const ICloudSyncer::InnerProcessInfo &process,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dsend_task_scheduler.cpp54 SendTaskInfo taskInfo; in Finalize() local
56 int errCode = ScheduleOutSendTask(task, taskInfo, totalLength); in Finalize()
62 taskInfo.delayFlag, static_cast<int>(taskInfo.taskPrio)); in Finalize()
94 SendTaskInfo taskInfo; in ScheduleOutSendTask() local
95 int errCode = ScheduleOutSendTask(outTask, taskInfo, totalLength); in ScheduleOutSendTask()
98 taskInfo.delayFlag, static_cast<int>(taskInfo.taskPrio)); in ScheduleOutSendTask()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/hidumphelper/
H A Dhidump_helper.cpp230 for (auto taskInfo : taskInfos) { in ShowAllTaskInfos()
232 auto it = DHTypeStrMap.find(taskInfo.taskParm.dhType); in ShowAllTaskInfos()
238 result.append(taskInfo.id); in ShowAllTaskInfos()
240 result.append(g_mapTaskType[taskInfo.taskType]); in ShowAllTaskInfos()
244 result.append(GetAnonyString(taskInfo.taskParm.dhId)); in ShowAllTaskInfos()
246 result.append(g_mapTaskState[taskInfo.taskState]); in ShowAllTaskInfos()
248 std::vector<TaskStep> taskSteps = taskInfo.taskSteps; in ShowAllTaskInfos()
/foundation/communication/wifi/wifi/base/shared_util/
H A Dwifi_watchdog_utils.cpp97 void WifiWatchDogUtils::FfrtCallback(uint64_t taskId, const char *taskInfo, uint32_t delayedTaskCount) in FfrtCallback() argument
100 description += taskInfo; in FfrtCallback()
H A Dwifi_watchdog_utils.h35 static void FfrtCallback(uint64_t taskId, const char *taskInfo, uint32_t delayedTaskCount);
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/task/
H A Dtask_board.cpp94 TaskDump taskInfo = { in DumpAllTasks() local
105 taskInfos.emplace_back(taskInfo); in DumpAllTasks()
/foundation/resourceschedule/background_task_mgr/services/test/unittest/
H A Dbgtask_manager_unit_test.cpp502 auto taskInfo = std::make_shared<TransientTaskAppInfo>(); in HWTEST_F() local
506 bgTransientTaskMgr_->NotifyTransientTaskSuscriber(taskInfo, in HWTEST_F()
508 bgTransientTaskMgr_->NotifyTransientTaskSuscriber(taskInfo, in HWTEST_F()
510 bgTransientTaskMgr_->NotifyTransientTaskSuscriber(taskInfo, in HWTEST_F()
512 bgTransientTaskMgr_->NotifyTransientTaskSuscriber(taskInfo, in HWTEST_F()
/foundation/ability/ability_runtime/services/abilitymgr/include/
H A Dfree_install_manager.h144 * @param taskInfo, the found task info
148 const std::string& startTime, FreeInstallInfo& taskInfo);
154 * @param taskInfo, the found task info
157 bool GetFreeInstallTaskInfo(const std::string& sessionId, FreeInstallInfo& taskInfo);
/foundation/ability/ability_runtime/test/unittest/ability_manager_service_third_test/
H A Dability_manager_service_third_test.cpp2252 FreeInstallInfo taskInfo; in HWTEST_F() local
2253 auto result2 = abilityMs_->StartUIAbilityByPreInstall(taskInfo); in HWTEST_F()
2268 FreeInstallInfo taskInfo; in HWTEST_F() local
2269 auto result = abilityMs_->PreStartInner(taskInfo); in HWTEST_F()
2491 FreeInstallInfo taskInfo = { in HWTEST_F() local
2494 int32_t res = abilityMs->StartUIAbilityByPreInstall(taskInfo); in HWTEST_F()
2507 FreeInstallInfo taskInfo = { in HWTEST_F() local
2510 int32_t res = abilityMs->StartUIAbilityByPreInstall(taskInfo); in HWTEST_F()
2523 FreeInstallInfo taskInfo = { in HWTEST_F() local
2526 int32_t res = abilityMs->StartUIAbilityByPreInstall(taskInfo); in HWTEST_F()
2539 FreeInstallInfo taskInfo = { HWTEST_F() local
2560 FreeInstallInfo taskInfo = { HWTEST_F() local
[all...]
/foundation/ability/ability_runtime/test/unittest/ability_manager_service_sixth_test/
H A Dability_manager_service_sixth_test.cpp1799 FreeInstallInfo taskInfo; in HWTEST_F() local
1800 auto ret = abilityMs->StartUIAbilityByPreInstall(taskInfo); in HWTEST_F()
1802 taskInfo.isFreeInstallFinished = true; in HWTEST_F()
1803 ret = abilityMs->StartUIAbilityByPreInstall(taskInfo); in HWTEST_F()
1805 taskInfo.isInstalled = true; in HWTEST_F()
1806 ret = abilityMs->StartUIAbilityByPreInstall(taskInfo); in HWTEST_F()
1808 taskInfo.isStartUIAbilityBySCBCalled = true; in HWTEST_F()
1809 ret = abilityMs->StartUIAbilityByPreInstall(taskInfo); in HWTEST_F()
1812 taskInfo.want.SetParam(KEY_SESSION_ID, value); in HWTEST_F()
1813 ret = abilityMs->StartUIAbilityByPreInstall(taskInfo); in HWTEST_F()
[all...]
/foundation/resourceschedule/ffrt/src/sync/
H A Dpoller.cpp287 void CopyEventsInfoToConsumer(SyncData& taskInfo, EventVec& cachedEventsVec) in CopyEventsInfoToConsumer() argument
289 epoll_event* eventsPtr = (epoll_event*)taskInfo.eventsPtr; in CopyEventsInfoToConsumer()
290 int* nfdsPtr = taskInfo.nfdsPtr; in CopyEventsInfoToConsumer()
/foundation/ability/ability_runtime/services/abilitymgr/src/
H A Dfree_install_manager.cpp650 const std::string& startTime, FreeInstallInfo& taskInfo) in GetFreeInstallTaskInfo()
657 taskInfo = *it; in GetFreeInstallTaskInfo()
665 bool FreeInstallManager::GetFreeInstallTaskInfo(const std::string& sessionId, FreeInstallInfo& taskInfo) in GetFreeInstallTaskInfo() argument
670 taskInfo = *it; in GetFreeInstallTaskInfo()
649 GetFreeInstallTaskInfo(const std::string& bundleName, const std::string& abilityName, const std::string& startTime, FreeInstallInfo& taskInfo) GetFreeInstallTaskInfo() argument
H A Dability_manager_service.cpp2141 FreeInstallInfo taskInfo; in StartUIAbilityBySCB() local
2142 if (!freeInstallManager_->GetFreeInstallTaskInfo(sessionId, taskInfo)) { in StartUIAbilityBySCB()
2158 if (taskInfo.isFreeInstallFinished) { in StartUIAbilityBySCB()
2160 if (!taskInfo.isInstalled) { in StartUIAbilityBySCB()
2162 taskInfo.resultCode); in StartUIAbilityBySCB()
2163 return taskInfo.resultCode; in StartUIAbilityBySCB()
2166 return StartUIAbilityByPreInstallInner(sessionInfo, taskInfo.specifyTokenId, sceneFlag, isColdStart); in StartUIAbilityBySCB()
3894 FreeInstallInfo taskInfo; in SetMinimizedDuringFreeInstall() local
3895 if (!freeInstallManager_->GetFreeInstallTaskInfo(sessionId, taskInfo)) { in SetMinimizedDuringFreeInstall()
3901 if (taskInfo in SetMinimizedDuringFreeInstall()
11707 FreeInstallInfo taskInfo; PreStartMission() local
11731 PreStartInner(const FreeInstallInfo& taskInfo) PreStartInner() argument
11788 StartUIAbilityByPreInstall(const FreeInstallInfo &taskInfo) StartUIAbilityByPreInstall() argument
[all...]
/foundation/arkui/napi/native_engine/impl/ark/
H A Dark_native_engine.h160 bool InitTaskPoolFunc(napi_env env, napi_value func, void* taskInfo) override;
H A Dark_native_engine.cpp1105 static void ConcurrentCallbackFunc(Local<JSValueRef> result, bool success, void *taskInfo, void *data) in ConcurrentCallbackFunc() argument
1116 concurrentCallbackFunc(env, ArkNativeEngine::ArkValueToNapiValue(env, result), success, taskInfo); in ConcurrentCallbackFunc()
1131 bool ArkNativeEngine::InitTaskPoolFunc(napi_env env, napi_value func, void* taskInfo) in InitTaskPoolFunc() argument
1135 return JSNApi::InitForConcurrentFunction(vm_, function, taskInfo); in InitTaskPoolFunc()
/foundation/arkui/napi/native_engine/
H A Dnative_engine.h137 virtual bool InitTaskPoolFunc(napi_env env, napi_value func, void* taskInfo) = 0;

Completed in 40 milliseconds

12