Home
last modified time | relevance | path

Searched defs:taskId (Results 226 - 237 of 237) sorted by relevance

12345678910

/base/print/print_fwk/test/fuzztest/scanhelper_fuzzer/
H A Dscanhelper_fuzzer.cpp637 std::string taskId = dataProvider->ConsumeRandomLengthString(MAX_STRING_LENGTH); in TestGetTaskEventId() local
/foundation/ability/dmsfwk/services/dtbschedmgr/src/
H A Ddistributed_sched_stub.cpp1555 int64_t taskId = 0; in StartFreeInstallFromRemoteInner() local
1595 int64_t taskId = 0; in NotifyCompleteFreeInstallFromRemoteInner() local
1511 ReadDataForFreeInstall(MessageParcel& data, CallerInfo &callerInfo, AccountInfo &accountInfo, int64_t &taskId) ReadDataForFreeInstall() argument
H A Ddistributed_sched_service.cpp3152 int64_t taskId = dmsCallbackTask_->GenerateTaskId(); in StartRemoteFreeInstall() local
3187 int32_t DistributedSchedService::StartFreeInstallFromRemote(const FreeInstallInfo& info, int64_t taskId) in StartFreeInstallFromRemote() argument
3218 NotifyCompleteFreeInstall( const FreeInstallInfo& info, int64_t taskId, int32_t resultCode) NotifyCompleteFreeInstall() argument
3234 StartLocalAbility(const FreeInstallInfo& info, int64_t taskId, int32_t resultCode) StartLocalAbility() argument
3290 HandleRemoteNotify(const FreeInstallInfo& info, int64_t taskId, int32_t resultCode) HandleRemoteNotify() argument
3305 NotifyCompleteFreeInstallFromRemote(int64_t taskId, int32_t resultCode) NotifyCompleteFreeInstallFromRemote() argument
[all...]
/foundation/multimedia/image_effect/frameworks/native/effect/base/
H A Dimage_effect_inner.cpp349 StartPipelineInner(std::shared_ptr<PipelineCore> &pipeline, const EffectParameters &effectParameters, unsigned long int taskId, RenderThread<> *thread) StartPipelineInner() argument
397 StartPipeline(std::shared_ptr<PipelineCore> &pipeline, const EffectParameters &effectParameters, unsigned long int taskId, RenderThread<> *thread) StartPipeline() argument
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer.cpp224 int CloudSyncer::DoSync(TaskId taskId) in DoSync() argument
426 TaskId taskId; SyncMachineDoFinished() local
467 DoFinished(TaskId taskId, int errCode) DoFinished() argument
640 CloudDbDownloadAssets(TaskId taskId, InnerProcessInfo &info, const DownloadList &downloadList, const std::set<Key> &dupHashKeySet, ChangedData &changedAssets) CloudDbDownloadAssets() argument
701 TaskId taskId; DownloadAssets() local
853 SaveData(CloudSyncer::TaskId taskId, SyncParam &param) SaveData() argument
910 PreCheck(CloudSyncer::TaskId &taskId, const TableName &tableName) PreCheck() argument
938 TaskId taskId; NeedNotifyChangedData() local
983 NotifyInDownload(CloudSyncer::TaskId taskId, SyncParam &param, bool isFirstDownload) NotifyInDownload() argument
1004 SaveDataInTransaction(CloudSyncer::TaskId taskId, SyncParam &param) SaveDataInTransaction() argument
1066 SaveDataNotifyProcess(CloudSyncer::TaskId taskId, SyncParam &param) SaveDataNotifyProcess() argument
1118 DoDownload(CloudSyncer::TaskId taskId, bool isFirstDownload) DoDownload() argument
1141 DoDownloadInner(CloudSyncer::TaskId taskId, SyncParam &param, bool isFirstDownload) DoDownloadInner() argument
1157 NotifyInEmptyDownload(CloudSyncer::TaskId taskId, InnerProcessInfo &info) NotifyInEmptyDownload() argument
1172 PreCheckUpload(CloudSyncer::TaskId &taskId, const TableName &tableName, Timestamp &localMark) PreCheckUpload() argument
1271 DoUpload(CloudSyncer::TaskId taskId, bool lastTable, LockAction lockAction) DoUpload() argument
1335 SaveCloudWaterMark(const TableName &tableName, const TaskId taskId) SaveCloudWaterMark() argument
1362 SetUploadDataFlag(const TaskId taskId, CloudSyncData& uploadData) SetUploadDataFlag() argument
1369 IsModeForcePush(TaskId taskId) IsModeForcePush() argument
1375 IsModeForcePull(const TaskId taskId) IsModeForcePull() argument
1381 IsPriorityTask(TaskId taskId) IsPriorityTask() argument
1424 QueryCloudData(TaskId taskId, const std::string &tableName, std::string &cloudWaterMark, DownloadData &downloadData) QueryCloudData() argument
1452 CheckTaskIdValid(TaskId taskId) CheckTaskIdValid() argument
1496 PrepareSync(TaskId taskId) PrepareSync() argument
1527 LockCloud(TaskId taskId) LockCloud() argument
1550 StartHeartBeatTimer(int period, TaskId taskId) StartHeartBeatTimer() argument
1579 HeartBeat(TimerId timerId, TaskId taskId) HeartBeat() argument
1626 HeartBeatFailed(TaskId taskId, int errCode) HeartBeatFailed() argument
1637 SetTaskFailed(TaskId taskId, int errCode) SetTaskFailed() argument
1709 UpdateCloudWaterMark(TaskId taskId, const SyncParam &param) UpdateCloudWaterMark() argument
1836 LockCloudIfNeed(TaskId taskId) LockCloudIfNeed() argument
1894 ClearContextAndNotify(TaskId taskId, int errCode) ClearContextAndNotify() argument
1934 DownloadOneBatch(TaskId taskId, SyncParam &param, bool isFirstDownload) DownloadOneBatch() argument
2009 GetSyncParamForDownload(TaskId taskId, SyncParam &param) GetSyncParamForDownload() argument
2053 IsCurrentTableResume(TaskId taskId, bool upload) IsCurrentTableResume() argument
2065 DownloadDataFromCloud(TaskId taskId, SyncParam &param, bool &abort, bool isFirstDownload) DownloadDataFromCloud() argument
2097 GetDownloadAssetIndex(TaskId taskId) GetDownloadAssetIndex() argument
2120 RecordWaterMark(TaskId taskId, Timestamp waterMark) RecordWaterMark() argument
2126 GetResumeWaterMark(TaskId taskId) GetResumeWaterMark() argument
[all...]
H A Dcloud_syncer_extend.cpp36 void CloudSyncer::ReloadWaterMarkIfNeed(TaskId taskId, WaterMark &waterMark) in ReloadWaterMarkIfNeed() argument
50 void CloudSyncer::ReloadUploadInfoIfNeed(TaskId taskId, const UploadParam &param, InnerProcessInfo &info) in ReloadUploadInfoIfNeed() argument
71 int CloudSyncer::FillDownloadExtend(TaskId taskId, const std::string &tableName, const std::string &cloudWaterMark, in FillDownloadExtend() argument
101 int CloudSyncer::GetCloudGid(TaskId taskId, const std::string &tableName, QuerySyncObject &obj) in GetCloudGid() argument
617 IsCompensatedTask(TaskId taskId) IsCompensatedTask() argument
644 DoNotifyInNeed(const CloudSyncer::TaskId &taskId, const std::vector<std::string> &needNotifyTables, const bool isFirstDownload) DoNotifyInNeed() argument
662 GetUploadCountByTable(const CloudSyncer::TaskId &taskId, int64_t &count) GetUploadCountByTable() argument
688 UpdateProcessInfoWithoutUpload(CloudSyncer::TaskId taskId, const std::string &tableName, bool needNotify) UpdateProcessInfoWithoutUpload() argument
754 IsNeedGetLocalWater(TaskId taskId) IsNeedGetLocalWater() argument
781 auto taskId = taskInfo.taskId; TryToAddSyncTask() local
797 MergeTaskInfo(const std::shared_ptr<DataBaseSchema> &cloudSchema, TaskId taskId) MergeTaskInfo() argument
864 IsTasksCanMerge(TaskId taskId, TaskId tryMergeTaskId) IsTasksCanMerge() argument
913 IsQueryListEmpty(TaskId taskId) IsQueryListEmpty() argument
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/
H A Dobject_manager.cpp502 auto taskId = executors_->Schedule(std::chrono::seconds(WAIT_TIME), [this, objectKey, data, saveInfo]() { in WaitAssets() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_store.cpp1083 int SQLiteRelationalStore::Sync(const CloudSyncOption &option, const SyncProcessCallback &onProcess, uint64_t taskId) in Sync() argument
1582 SyncProcess SQLiteRelationalStore::GetCloudTaskStatus(uint64_t taskId) in GetCloudTaskStatus() argument
/base/print/print_fwk/services/print_service/src/
H A Dprint_service_ability.cpp319 int32_t PrintServiceAbility::StopPrint(const std::string &taskId) in StopPrint() argument
278 StartPrint(const std::vector<std::string> &fileList, const std::vector<uint32_t> &fdList, std::string &taskId) StartPrint() argument
284 CallSpooler(const std::vector<std::string> &fileList, const std::vector<uint32_t> &fdList, std::string &taskId) CallSpooler() argument
2156 On(const std::string taskId, const std::string &type, const sptr<IPrintCallback> &listener) On() argument
2203 Off(const std::string taskId, const std::string &type) Off() argument
2420 PrintByAdapter(const std::string jobName, const PrintAttributes &printAttributes, std::string &taskId) PrintByAdapter() argument
[all...]
/foundation/multimedia/player_framework/services/services/screen_capture/server/
H A Dscreen_capture_server.cpp1993 int32_t taskId = taskIDListTemp.front(); in GetMissionIds() local
/test/xts/acts/resourceschedule/resourceschedule_standard/ffrt/entry/src/main/cpp/
H A Dffrtndk.cpp3716 uint64_t taskId = SUCCESS; in FfrtThisTaskGetId() local
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/
H A Drs_main_thread.cpp3274 void RSMainThread::SendClientDumpNodeTreeCommands(uint32_t taskId) in SendClientDumpNodeTreeCommands() argument
3325 void RSMainThread::CollectClientNodeTreeResult(uint32_t taskId, st argument
3355 OnCommitDumpClientNodeTree(NodeId nodeId, pid_t pid, uint32_t taskId, const std::string& result) OnCommitDumpClientNodeTree() argument
[all...]

Completed in 40 milliseconds

12345678910