| /base/print/print_fwk/test/fuzztest/scanhelper_fuzzer/ |
| H A D | scanhelper_fuzzer.cpp | 637 std::string taskId = dataProvider->ConsumeRandomLengthString(MAX_STRING_LENGTH); in TestGetTaskEventId() local
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/ |
| H A D | distributed_sched_stub.cpp | 1555 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 D | distributed_sched_service.cpp | 3152 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 D | image_effect_inner.cpp | 349 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 D | cloud_syncer.cpp | 224 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 ¶m) SaveData() argument
910 PreCheck(CloudSyncer::TaskId &taskId, const TableName &tableName) PreCheck() argument
938 TaskId taskId; NeedNotifyChangedData() local
983 NotifyInDownload(CloudSyncer::TaskId taskId, SyncParam ¶m, bool isFirstDownload) NotifyInDownload() argument
1004 SaveDataInTransaction(CloudSyncer::TaskId taskId, SyncParam ¶m) SaveDataInTransaction() argument
1066 SaveDataNotifyProcess(CloudSyncer::TaskId taskId, SyncParam ¶m) SaveDataNotifyProcess() argument
1118 DoDownload(CloudSyncer::TaskId taskId, bool isFirstDownload) DoDownload() argument
1141 DoDownloadInner(CloudSyncer::TaskId taskId, SyncParam ¶m, 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 ¶m) UpdateCloudWaterMark() argument
1836 LockCloudIfNeed(TaskId taskId) LockCloudIfNeed() argument
1894 ClearContextAndNotify(TaskId taskId, int errCode) ClearContextAndNotify() argument
1934 DownloadOneBatch(TaskId taskId, SyncParam ¶m, bool isFirstDownload) DownloadOneBatch() argument
2009 GetSyncParamForDownload(TaskId taskId, SyncParam ¶m) GetSyncParamForDownload() argument
2053 IsCurrentTableResume(TaskId taskId, bool upload) IsCurrentTableResume() argument
2065 DownloadDataFromCloud(TaskId taskId, SyncParam ¶m, 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 D | cloud_syncer_extend.cpp | 36 void CloudSyncer::ReloadWaterMarkIfNeed(TaskId taskId, WaterMark &waterMark) in ReloadWaterMarkIfNeed() argument
50 void CloudSyncer::ReloadUploadInfoIfNeed(TaskId taskId, const UploadParam ¶m, 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 D | object_manager.cpp | 502 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 D | sqlite_relational_store.cpp | 1083 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 D | print_service_ability.cpp | 319 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 D | screen_capture_server.cpp | 1993 int32_t taskId = taskIDListTemp.front(); in GetMissionIds() local
|
| /test/xts/acts/resourceschedule/resourceschedule_standard/ffrt/entry/src/main/cpp/ |
| H A D | ffrtndk.cpp | 3716 uint64_t taskId = SUCCESS; in FfrtThisTaskGetId() local
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/ |
| H A D | rs_main_thread.cpp | 3274 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...] |