Home
last modified time | relevance | path

Searched refs:taskInfo (Results 1 – 25 of 89) sorted by relevance

1234

/ohos5.0/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()
94 taskInfo.timeout = waitTime; in CreateCloudTaskInfoAndCallTryToAddSync()
190 CloudTaskInfo taskInfo; in SetAndGetCloudTaskInfo() local
191 taskInfo.mode = mode; in SetAndGetCloudTaskInfo()
192 taskInfo.table = table; in SetAndGetCloudTaskInfo()
194 taskInfo.timeout = timeout; in SetAndGetCloudTaskInfo()
195 return taskInfo; in SetAndGetCloudTaskInfo()
358 CloudTaskInfo taskInfo; in CallDoDownloadInNeed() local
[all …]
H A Dvirtual_cloud_syncer.cpp36 int VirtualCloudSyncer::DoDownloadInNeed(const CloudTaskInfo &taskInfo, const bool needUpload, bool… 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()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer_extend.cpp468 taskInfo.users.clear(); in GenerateCompensatedSync()
480 Sync(taskInfo); in GenerateCompensatedSync()
695 taskInfo.table[i])) { in DoDownloadInNeed()
725 errCode = SaveCloudWaterMark(taskInfo.table[i], taskInfo.taskId); in DoDownloadInNeed()
762 auto taskId = taskInfo.taskId; in TryToAddSyncTask()
841 return !taskInfo.compensatedTask && !taskInfo.priorityTask && in IsTaskCanMerge()
842 taskInfo.merge && taskInfo.mode == SYNC_MODE_CLOUD_MERGE; in IsTaskCanMerge()
868 CloudTaskInfo &taskInfo) in AdjustTableBasedOnSchema() argument
871 taskInfo.table.clear(); in AdjustTableBasedOnSchema()
872 taskInfo.queryList.clear(); in AdjustTableBasedOnSchema()
[all …]
H A Dcloud_sync_utils.cpp613 taskInfo.priorityTask = true; in InitCompensatedSyncTaskInfo()
616 taskInfo.callback = nullptr; in InitCompensatedSyncTaskInfo()
617 taskInfo.compensatedTask = true; in InitCompensatedSyncTaskInfo()
618 return taskInfo; in InitCompensatedSyncTaskInfo()
625 taskInfo.callback = onProcess; in InitCompensatedSyncTaskInfo()
626 taskInfo.devices = option.devices; in InitCompensatedSyncTaskInfo()
629 taskInfo.users.push_back(""); in InitCompensatedSyncTaskInfo()
631 taskInfo.users = option.users; in InitCompensatedSyncTaskInfo()
634 return taskInfo; in InitCompensatedSyncTaskInfo()
641 taskInfo.users = oriTaskInfo.users; in InitCompensatedSyncTaskInfo()
[all …]
H A Dcloud_syncer.cpp56 CloudTaskInfo taskInfo; in Sync() local
57 taskInfo.mode = mode; in Sync()
58 taskInfo.table = tables; in Sync()
60 taskInfo.timeout = waitTime; in Sync()
61 taskInfo.devices = devices; in Sync()
67 return Sync(taskInfo); in Sync()
72 int errCode = CloudSyncUtils::CheckParamValid(taskInfo.devices, taskInfo.mode); in Sync()
228 CloudTaskInfo taskInfo; in DoSync() local
292 errCode = DoUpload(taskInfo.taskId, index == (taskInfo.table.size() - 1u), taskInfo.lockAction); in PrepareAndUpload()
355 CloudTaskInfo taskInfo; in SyncMachineDoDownload() local
[all …]
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.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 isFirstDow…
207 int TryToAddSyncTask(CloudTaskInfo &&taskInfo);
385 …int PrepareAndDownload(const std::string &table, const CloudTaskInfo &taskInfo, bool isFirstDownlo…
397 bool IsTaskCanMerge(const CloudTaskInfo &taskInfo);
403 …ustTableBasedOnSchema(const std::shared_ptr<DataBaseSchema> &cloudSchema, CloudTaskInfo &taskInfo);
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/util/
H A Dworker_monitor.cpp202 TaskTimeoutInfo& taskInfo = workerIter->second; in RecordTimeoutFunctionInfo() local
203 if (taskInfo.task_ == workerTask) { in RecordTimeoutFunctionInfo()
204 if (++taskInfo.sampledTimes_ < SAMPLING_TIMES_PER_SEC) { in RecordTimeoutFunctionInfo()
208 taskInfo.sampledTimes_ = 0; in RecordTimeoutFunctionInfo()
209 if (++taskInfo.executionTime_ % TIMEOUT_RECORD_CYCLE_LIST[taskInfo.recordLevel_] == 0) { in RecordTimeoutFunctionInfo()
211 timeoutFunctions.emplace_back(coWorkerInfo, workerInfo, taskInfo.executionTime_); in RecordTimeoutFunctionInfo()
212 if (taskInfo.recordLevel_ < static_cast<int>(TIMEOUT_RECORD_CYCLE_LIST.size()) - 1) { in RecordTimeoutFunctionInfo()
213 taskInfo.recordLevel_++; in RecordTimeoutFunctionInfo()
220 if (taskInfo.executionTime_ > 0) { in RecordTimeoutFunctionInfo()
222 worker->Id(), taskInfo.executionTime_); in RecordTimeoutFunctionInfo()
/ohos5.0/base/request/request/frameworks/js/napi/src/
H A Dnapi_utils.cpp389 napi_value Convert2JSValue(napi_env env, TaskInfo &taskInfo) in Convert2JSValue() argument
393 if (taskInfo.withSystem) { in Convert2JSValue()
396 taskInfo.url = ""; in Convert2JSValue()
397 taskInfo.data = ""; in Convert2JSValue()
398 if (taskInfo.action == Action::UPLOAD) { in Convert2JSValue()
399 taskInfo.files.clear(); in Convert2JSValue()
400 taskInfo.forms.clear(); in Convert2JSValue()
404 …d_property(env, value, "saveas", Convert2JSValue(env, GetSaveas(taskInfo.files, taskInfo.action))); in Convert2JSValue()
405 if (taskInfo.action == Action::DOWNLOAD) { in Convert2JSValue()
408 … napi_set_named_property(env, value, "data", Convert2JSValue(env, taskInfo.files, taskInfo.forms)); in Convert2JSValue()
[all …]
/ohos5.0/base/request/request/services/src/cxx/
H A Dc_request_database.cpp793 if (!WriteUpdateData(insertValues, taskInfo)) { in WriteMutableData()
875 CTaskInfo *BuildCTaskInfo(const TaskInfo &taskInfo) in BuildCTaskInfo() argument
877 uint32_t formItemsLen = taskInfo.formItems.size(); in BuildCTaskInfo()
884 uint32_t fileSpecsLen = taskInfo.fileSpecs.size(); in BuildCTaskInfo()
900 cTaskInfo->url = WrapperCString(taskInfo.url); in BuildCTaskInfo()
901 cTaskInfo->data = WrapperCString(taskInfo.data); in BuildCTaskInfo()
913 cTaskInfo->commonData = taskInfo.commonData; in BuildCTaskInfo()
1095 FillCommonTaskInfo(resultSet, taskInfo); in GetTaskInfoInner()
1096 FillOtherTaskInfo(resultSet, taskInfo); in GetTaskInfoInner()
1106 TaskInfo taskInfo; in GetTaskInfo() local
[all …]
/ohos5.0/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()
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/hidumphelper/
H A Dhidump_helper.cpp230 for (auto taskInfo : taskInfos) { in ShowAllTaskInfos() local
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()
/ohos5.0/base/update/updateservice/services/engine/src/
H A Dupdate_service_impl_firmware.cpp250 int32_t UpdateServiceImplFirmware::GetTaskInfo(const UpgradeInfo &info, TaskInfo &taskInfo, in GetTaskInfo() argument
258 taskInfo.existTask = true; in GetTaskInfo()
259 taskInfo.taskBody.status = static_cast<UpgradeStatus>(task.status); in GetTaskInfo()
260 taskInfo.taskBody.progress = task.progress; in GetTaskInfo()
261 taskInfo.taskBody.versionDigestInfo.versionDigest = task.taskId; in GetTaskInfo()
264 StringUtils::GetBoolStr(taskInfo.existTask).c_str(), CAST_INT(taskInfo.taskBody.status), in GetTaskInfo()
265 taskInfo.taskBody.progress); in GetTaskInfo()
H A Dupdate_service.cpp204 int32_t UpdateService::GetTaskInfo(const UpgradeInfo &info, TaskInfo &taskInfo, BusinessError &busi… in GetTaskInfo() argument
211 return onlineUpdater->GetTaskInfo(info, taskInfo, businessError); in GetTaskInfo()
378 TaskInfo taskInfo; in BuildTaskInfoDump() local
381 service->GetTaskInfo(upgradeInfo, taskInfo, businessError); in BuildTaskInfoDump()
382 if (!taskInfo.existTask) { in BuildTaskInfoDump()
388 dprintf(fd, "Progress: %d\n", taskInfo.taskBody.progress); in BuildTaskInfoDump()
389 dprintf(fd, "UpgradeStatus: %d\n", taskInfo.taskBody.status); in BuildTaskInfoDump()
390 dprintf(fd, "SubStatus: %d\n", taskInfo.taskBody.subStatus); in BuildTaskInfoDump()
391 for (auto &iter : taskInfo.taskBody.errorMessages) { in BuildTaskInfoDump()
/ohos5.0/docs/zh-cn/application-dev/reference/apis-basic-services-kit/
H A Djs-apis-request-sys.md76 request.agent.query("123456", (err: BusinessError, taskInfo: request.agent.TaskInfo) => {
81 console.info(`Succeeded in querying a upload task. result: ${taskInfo.uid}`);
126 request.agent.query("123456").then((taskInfo: request.agent.TaskInfo) => {
127 console.info(`Succeeded in querying a upload task. result: ${taskInfo.uid}`);
/ohos5.0/foundation/multimedia/media_library/frameworks/js/src/
H A Dcloud_media_asset_status_napi.cpp108 void CloudMediaAssetStatusNapi::SetTaskInfo(const std::string &taskInfo) in SetTaskInfo() argument
110 this->taskInfo_ = taskInfo; in SetTaskInfo()
204 std::string taskInfo = obj->GetTaskInfo(); in JSGetTaskInfo() local
205 napi_create_string_utf8(env, taskInfo.c_str(), NAPI_AUTO_LENGTH, &result); in JSGetTaskInfo()
/ohos5.0/docs/en/application-dev/reference/apis-basic-services-kit/
H A Djs-apis-request-sys.md77 request.agent.query("123456", (err: BusinessError, taskInfo: request.agent.TaskInfo) => {
82 console.info(`Succeeded in querying the upload task. Result: ${taskInfo.uid}`);
127 request.agent.query("123456").then((taskInfo: request.agent.TaskInfo) => {
128 console.info(`Succeeded in querying the upload task. Result: ${taskInfo.uid}`);
/ohos5.0/foundation/ability/ability_runtime/test/unittest/ability_manager_service_third_test/
H A Dability_manager_service_third_test.cpp1248 FreeInstallInfo taskInfo; variable
1264 FreeInstallInfo taskInfo; variable
1265 auto result = abilityMs_->PreStartInner(taskInfo);
1489 FreeInstallInfo taskInfo = { variable
1492 int32_t res = abilityMs->StartUIAbilityByPreInstall(taskInfo);
1505 FreeInstallInfo taskInfo = { variable
1508 int32_t res = abilityMs->StartUIAbilityByPreInstall(taskInfo);
1521 FreeInstallInfo taskInfo = { variable
1524 int32_t res = abilityMs->StartUIAbilityByPreInstall(taskInfo);
1537 FreeInstallInfo taskInfo = { variable
[all …]
/ohos5.0/base/useriam/user_auth_framework/services/context/src/
H A Dwidget_context.cpp317 TaskInfo taskInfo { in ExecuteAuthList() local
321 runTaskInfoList_.push_back(taskInfo); in ExecuteAuthList()
414 runTaskInfoList_.end(), [authType] (const TaskInfo &taskInfo) { in StopAuthList() argument
415 return (taskInfo.authType == authType); in StopAuthList()
539 for (auto &taskInfo : runTaskInfoList_) { in StopAllRunTask() local
541 if (taskInfo.task == nullptr) { in StopAllRunTask()
545 taskInfo.task->Stop(); in StopAllRunTask()
/ohos5.0/foundation/communication/wifi/wifi/base/shared_util/
H A Dwifi_watchdog_utils.cpp97 void WifiWatchDogUtils::FfrtCallback(uint64_t taskId, const char *taskInfo, uint32_t delayedTaskCou… in FfrtCallback() argument
100 description += taskInfo; in FfrtCallback()
/ohos5.0/base/request/request/test/unittest/cpp_test/fwkTest/src/
H A Druncount_notify_stub_test.cpp84 TaskInfo taskInfo; variable
85 RunCountNotifyStub::GetInstance()->Done(taskInfo);
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dworker.cpp375 auto taskInfo = TaskManager::GetInstance().DequeueTaskId(); in PerformTask() local
376 if (taskInfo.first == 0) { in PerformTask()
381 PriorityScope priorityScope(worker, taskInfo.second); in PerformTask()
382 Task* task = TaskManager::GetInstance().GetTask(taskInfo.first); in PerformTask()
407 + ", priority : " + std::to_string(taskInfo.second); in PerformTask()
430 if (!task->CheckStartExecution(taskInfo.second)) { in PerformTask()
/ohos5.0/foundation/multimedia/media_library/frameworks/services/media_backup_extension/src/report/
H A Dupgrade_restore_gallery_media_task.cpp26 …ector<MediaRestoreResultInfo> UpgradeRestoreGalleryMediaTask::LoadTask(const std::string &taskInfo) in LoadTask() argument
28 CallbackResultData resultData = this->ParseFromJsonStr(taskInfo); in LoadTask()
/ohos5.0/base/hiviewdfx/hicollie/frameworks/native/
H A Dwatchdog_inner.cpp902 void WatchdogInner::FfrtCallback(uint64_t taskId, const char *taskInfo, uint32_t delayedTaskCount) in FfrtCallback() argument
905 description += taskInfo; in FfrtCallback()
907 std::string info(taskInfo); in FfrtCallback()
909 WatchdogInner::SendFfrtEvent(description, "SERVICE_WARNING", taskInfo, false); in FfrtCallback()
911 WatchdogInner::SendFfrtEvent(description, "SERVICE_BLOCK", taskInfo); in FfrtCallback()
929 WatchdogInner::SendFfrtEvent(description, "SERVICE_BLOCK", taskInfo); in FfrtCallback()
933 WatchdogInner::SendFfrtEvent(description, "SERVICE_WARNING", taskInfo); in FfrtCallback()
946 …ogInner::SendFfrtEvent(const std::string &msg, const std::string &eventName, const char * taskInfo, in SendFfrtEvent() argument
967 …"PID", pid, "TID", tid, "TGID", gid, "UID", uid, "MODULE_NAME", taskInfo, "PROCESS_NAME", GetSelfP… in SendFfrtEvent()
/ohos5.0/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()

1234