Home
last modified time | relevance | path

Searched refs:taskId (Results 1 - 25 of 221) sorted by relevance

123456789

/foundation/ability/dmsfwk/services/dtbschedmgr/src/
H A Ddms_callback_task.cpp47 int32_t DmsCallbackTask::PushCallback(int64_t taskId, const sptr<IRemoteObject>& callback, in PushCallback() argument
50 HILOGI("PushCallback taskId:%{public}" PRId64, taskId); in PushCallback()
51 if (taskId <= 0) { in PushCallback()
52 HILOGE("PushCallback taskId invalid!"); in PushCallback()
69 auto iterTask = callbackMap_.find(taskId); in PushCallback()
71 HILOGE("PushCallback taskId:%{public}" PRId64 " exist!", taskId); in PushCallback()
75 bool ret = dmsCallbackHandler_->SendEvent(taskId, 0, CALLBACK_DELAY_TIME); in PushCallback()
83 .taskId in PushCallback()
92 PopCallback(int64_t taskId) PopCallback() argument
109 PopContinuationMissionMap(int64_t taskId) PopContinuationMissionMap() argument
118 GetContinuaionMissionId(int64_t taskId) GetContinuaionMissionId() argument
134 SetContinuationMissionMap(int64_t taskId, int32_t missionId) SetContinuationMissionMap() argument
150 GetLaunchType(int64_t taskId) GetLaunchType() argument
191 int64_t taskId = static_cast<int64_t>(eventId); ProcessEvent() local
[all...]
/foundation/filemanagement/dfs_service/frameworks/native/cloudsync_kit_inner/src/
H A Ddownload_asset_callback_client.cpp24 void DownloadAssetCallbackClient::OnFinished(const TaskId taskId, const std::string &uri, const int32_t result) in OnFinished() argument
26 auto callback = GetDownloadTaskCallback(taskId); in OnFinished()
31 RemoveDownloadTaskCallback(taskId); in OnFinished()
32 LOGD("On Download finished, taskId:%{public}" PRIu64 ", uri:%{public}s, ret:%{public}d", in OnFinished()
33 taskId, GetAnonyString(uri).c_str(), in OnFinished()
37 void DownloadAssetCallbackClient::AddDownloadTaskCallback(TaskId taskId, CloudSyncAssetManager::ResultCallback callback) in AddDownloadTaskCallback() argument
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
53 GetDownloadTaskCallback(TaskId taskId) GetDownloadTaskCallback() argument
[all...]
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/
H A Ddms_callback_task_test.cpp43 DmsCallbackTaskInitCallbackFunc mockCallback = [this] (int64_t taskId) {}; in SetUp()
49 void DmsCallbackTaskTest::PushMockTask(int64_t taskId, std::string& deviceId) in PushMockTask() argument
56 .taskId = taskId, in PushMockTask()
61 dmsCallbackTask_->callbackMap_.emplace(taskId, item); in PushMockTask()
98 * @tc.desc: invalid taskId
105 int64_t taskId = -1; in HWTEST_F() local
110 int32_t result = dmsCallbackTask_->PushCallback(taskId, callback, deviceId, in HWTEST_F()
125 int64_t taskId = 1; in HWTEST_F() local
130 int32_t result = dmsCallbackTask_->PushCallback(taskId, callbac in HWTEST_F()
145 int64_t taskId = 1; HWTEST_F() local
166 int64_t taskId = 1; HWTEST_F() local
187 int64_t taskId = 1; HWTEST_F() local
208 int64_t taskId = 1; HWTEST_F() local
228 int64_t taskId = 1; HWTEST_F() local
243 int64_t taskId = 1; HWTEST_F() local
260 int64_t taskId = 1; HWTEST_F() local
277 int64_t taskId = 1; HWTEST_F() local
295 int64_t taskId = -1; HWTEST_F() local
310 int64_t taskId = 1; HWTEST_F() local
325 int64_t taskId = 1; HWTEST_F() local
342 int64_t taskId = -1; HWTEST_F() local
358 int64_t taskId = 1; HWTEST_F() local
374 int64_t taskId = -1; HWTEST_F() local
390 int64_t taskId = -1; HWTEST_F() local
406 int64_t taskId = 1; HWTEST_F() local
423 int64_t taskId = 1; HWTEST_F() local
439 int64_t taskId = -1; HWTEST_F() local
454 int64_t taskId = -1; HWTEST_F() local
469 int64_t taskId = 1; HWTEST_F() local
484 int64_t taskId = 1; HWTEST_F() local
501 int64_t taskId = 1; HWTEST_F() local
536 int64_t taskId = 1; HWTEST_F() local
[all...]
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/network/softbus/
H A Dsoftbus_asset_send_listener.cpp59 auto taskId = assetObj->srcBundleName_ + assetObj->sessionId_; in OnSendAssetFinished() local
60 AssetCallbackManager::GetInstance().NotifyAssetSendResult(taskId, assetObj, FileManagement::E_OK); in OnSendAssetFinished()
62 AssetCallbackManager::GetInstance().RemoveSendCallback(taskId); in OnSendAssetFinished()
63 SoftBusHandlerAsset::GetInstance().RemoveFile(fileList[0], GetIsZipFile(taskId)); in OnSendAssetFinished()
64 RemoveFileMap(taskId); in OnSendAssetFinished()
82 auto taskId = assetObj->srcBundleName_ + assetObj->sessionId_; in OnSendAssetError() local
83 AssetCallbackManager::GetInstance().NotifyAssetSendResult(taskId, assetObj, FileManagement::E_SEND_FILE); in OnSendAssetError()
85 AssetCallbackManager::GetInstance().RemoveSendCallback(taskId); in OnSendAssetError()
86 SoftBusHandlerAsset::GetInstance().RemoveFile(fileList[0], GetIsZipFile(taskId)); in OnSendAssetError()
87 RemoveFileMap(taskId); in OnSendAssetError()
94 AddFileMap(const std::string &taskId, bool isSingleFile) AddFileMap() argument
105 GetIsZipFile(const std::string &taskId) GetIsZipFile() argument
116 RemoveFileMap(const std::string &taskId) RemoveFileMap() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_syncer_test.h52 void InitCloudSyncer(TaskId taskId, SyncMode mode) in InitCloudSyncer() argument
54 cloudTaskInfos_.insert(std::pair<TaskId, CloudTaskInfo>{taskId, CloudTaskInfo()}); in InitCloudSyncer()
55 cloudTaskInfos_[taskId].mode = mode; in InitCloudSyncer()
56 cloudTaskInfos_[taskId].taskId = taskId; in InitCloudSyncer()
57 currentContext_.tableName = "TestTable" + std::to_string(taskId); in InitCloudSyncer()
58 cloudTaskInfos_[taskId].table.push_back(currentContext_.tableName); in InitCloudSyncer()
59 currentContext_.currentTaskId = taskId; in InitCloudSyncer()
62 currentContext_.notifier->Init({currentContext_.tableName}, { "cloud" }, cloudTaskInfos_[taskId] in InitCloudSyncer()
105 SetTimeOut(TaskId taskId, int64_t timeout) SetTimeOut() argument
129 getCallback(TaskId taskId) getCallback() argument
139 CallDoUpload(TaskId taskId, bool lastTable = false, LockAction lockAction = LockAction::INSERT) CallDoUpload() argument
147 CallDoDownload(TaskId taskId) CallDoDownload() argument
167 GetUploadSuccessCount(TaskId taskId) GetUploadSuccessCount() argument
172 GetUploadFailCount(TaskId taskId) GetUploadFailCount() argument
225 CallPrepareSync(TaskId taskId) CallPrepareSync() argument
269 SetCurrentContext(TaskId taskId) SetCurrentContext() argument
274 SetLastTaskId(TaskId taskId) SetLastTaskId() argument
291 SetQuerySyncObject(TaskId taskId, const QuerySyncObject &query) SetQuerySyncObject() argument
303 CallReloadWaterMarkIfNeed(TaskId taskId, WaterMark &waterMark) CallReloadWaterMarkIfNeed() argument
308 CallRecordWaterMark(TaskId taskId, Timestamp waterMark) CallRecordWaterMark() argument
313 SetResumeSyncParam(TaskId taskId, const SyncParam &syncParam) SetResumeSyncParam() argument
319 ClearResumeTaskInfo(TaskId taskId) ClearResumeTaskInfo() argument
324 SetTaskResume(TaskId taskId, bool resume) SetTaskResume() argument
329 CallGetSyncParamForDownload(TaskId taskId, SyncParam &param) CallGetSyncParamForDownload() argument
334 IsResumeTaskUpload(TaskId taskId) IsResumeTaskUpload() argument
[all...]
H A Ddistributeddb_cloud_syncer_download_test.cpp238 TaskId taskId = 1u; in HWTEST_F() local
254 g_cloudSyncer->InitCloudSyncer(taskId, SYNC_MODE_CLOUD_MERGE); in HWTEST_F()
258 int errCode = g_cloudSyncer->CallDoDownload(taskId); in HWTEST_F()
262 taskId = 3u; in HWTEST_F()
263 g_cloudSyncer->InitCloudSyncer(taskId, SYNC_MODE_CLOUD_FORCE_PUSH); in HWTEST_F()
265 errCode = g_cloudSyncer->CallDoDownload(taskId); in HWTEST_F()
268 taskId = 4u; in HWTEST_F()
269 g_cloudSyncer->InitCloudSyncer(taskId, SYNC_MODE_CLOUD_FORCE_PUSH); in HWTEST_F()
271 errCode = g_cloudSyncer->CallDoDownload(taskId); in HWTEST_F()
274 taskId in HWTEST_F()
290 TaskId taskId = 6u; HWTEST_F() local
336 TaskId taskId = 1u; HWTEST_F() local
369 TaskId taskId = 1u; HWTEST_F() local
427 TaskId taskId = 4u; HWTEST_F() local
471 TaskId taskId = 1u; HWTEST_F() local
516 TaskId taskId = 3u; HWTEST_F() local
572 TaskId taskId = 1u; HWTEST_F() local
604 TaskId taskId = 1u; HWTEST_F() local
722 TaskId taskId = 1u; HWTEST_F() local
763 TaskId taskId = 1u; HWTEST_F() local
[all...]
/foundation/arkui/ace_engine/adapter/ohos/osal/
H A Dace_trace.cpp50 void AceAsyncTraceBegin(int32_t taskId, const char* name, bool isAnimationTrace) in AceAsyncTraceBegin() argument
55 StartAsyncTrace(HITRACE_TAG_ANIMATION, nameStr, taskId); in AceAsyncTraceBegin()
57 StartAsyncTrace(HITRACE_TAG_ACE, nameStr, taskId); in AceAsyncTraceBegin()
61 void AceAsyncTraceEnd(int32_t taskId, const char* name, bool isAnimationTrace) in AceAsyncTraceEnd() argument
66 FinishAsyncTrace(HITRACE_TAG_ANIMATION, nameStr, taskId); in AceAsyncTraceEnd()
68 FinishAsyncTrace(HITRACE_TAG_ACE, nameStr, taskId); in AceAsyncTraceEnd()
72 void AceAsyncTraceBeginCommercial(int32_t taskId, const char* name, bool isAnimationTrace) in AceAsyncTraceBeginCommercial() argument
77 StartAsyncTrace(ANIMATION_TRACE_COMMERCIAL, nameStr, taskId); in AceAsyncTraceBeginCommercial()
79 StartAsyncTrace(ACE_TRACE_COMMERCIAL, nameStr, taskId); in AceAsyncTraceBeginCommercial()
83 void AceAsyncTraceEndCommercial(int32_t taskId, cons argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer.cpp131 LOGI("[CloudSyncer] finished taskId %" PRIu64 " with db closed.", info.taskId); in Close()
150 LOGI("[CloudSyncer] finished taskId %" PRIu64 " with user changed.", info.taskId); in StopAllTasks()
192 // get taskId from queue in DoSyncIfNeed()
198 // pop taskId in queue in DoSyncIfNeed()
224 int CloudSyncer::DoSync(TaskId taskId) in DoSync() argument
231 taskInfo = cloudTaskInfos_[taskId]; in DoSync()
233 LOGD("[CloudSyncer] DoSync get taskInfo, taskId is: %llu, prepareTraceId is:%s.", in DoSync()
234 static_cast<unsigned long long>(taskInfo.taskId), taskInf in DoSync()
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.h89 SyncProcess GetCloudTaskStatus(uint64_t taskId) const;
113 TaskId taskId = 0u; member
143 int DoSync(TaskId taskId);
151 void DoNotifyInNeed(const CloudSyncer::TaskId &taskId, const std::vector<std::string> &needNotifyTables,
154 int GetUploadCountByTable(const CloudSyncer::TaskId &taskId, int64_t &count);
156 void UpdateProcessInfoWithoutUpload(CloudSyncer::TaskId taskId, const std::string &tableName, bool needNotify);
160 void DoFinished(TaskId taskId, int errCode);
162 virtual int DoDownload(CloudSyncer::TaskId taskId, bool isFirstDownload);
164 int DoDownloadInner(CloudSyncer::TaskId taskId, SyncParam &param, bool isFirstDownload);
166 void NotifyInEmptyDownload(CloudSyncer::TaskId taskId, InnerProcessInf
[all...]
/foundation/multimedia/av_session/utils/include/
H A Davsession_trace.h27 #define AVSESSION_TRACE_ASYNC_START(traceName, taskId) AVSessionTrace::TraceBegin(traceName, taskId)
28 #define AVSESSION_TRACE_ASYNC_END(traceName, taskId) AVSessionTrace::TraceEnd(traceName, taskId)
88 static void TraceBegin(const std::string& traceName, int32_t taskId) in TraceBegin() argument
90 if (taskId <= INVALID_TASK_ID) { in TraceBegin()
95 StartAsyncTrace(HITRACE_TAG_ZMEDIA, traceBegin, taskId); in TraceBegin()
98 static void TraceEnd(const std::string& traceName, int32_t taskId) in TraceEnd() argument
100 if (taskId <= INVALID_TASK_ID) { in TraceEnd()
105 FinishAsyncTrace(HITRACE_TAG_ZMEDIA, traceEnd, taskId); in TraceEnd()
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/server/src/
H A Dbluetooth_hitrace.cpp35 void BluetoothHiTrace::BluetoothStartAsyncTrace(const std::string& value, int32_t taskId) in BluetoothStartAsyncTrace() argument
37 StartAsyncTrace(BLUETOOTH_BYTRACE_LABEL, value, taskId); in BluetoothStartAsyncTrace()
38 HILOGI("value:%{public}s, taskId:%{public}d", value.c_str(), taskId); in BluetoothStartAsyncTrace()
41 void BluetoothHiTrace::BluetoothFinishAsyncTrace(const std::string& value, int32_t taskId) in BluetoothFinishAsyncTrace() argument
43 FinishAsyncTrace(BLUETOOTH_BYTRACE_LABEL, value, taskId); in BluetoothFinishAsyncTrace()
44 HILOGI("value:%{public}s, taskId:%{public}d", value.c_str(), taskId); in BluetoothFinishAsyncTrace()
/foundation/communication/netmanager_base/utils/common_utils/src/
H A Dnetmanager_hitrace.cpp34 void NetmanagerHiTrace::NetmanagerStartAsyncTrace(const std::string &value, int32_t taskId) in NetmanagerStartAsyncTrace() argument
36 StartAsyncTrace(HITRACE_TAG_NET, value, taskId); in NetmanagerStartAsyncTrace()
37 NETMGR_LOG_I("NetmanagerStartAsyncTrace value:%{public}s, taskId:%{public}d", value.c_str(), taskId); in NetmanagerStartAsyncTrace()
40 void NetmanagerHiTrace::NetmanagerFinishAsyncTrace(const std::string &value, int32_t taskId) in NetmanagerFinishAsyncTrace() argument
42 FinishAsyncTrace(HITRACE_TAG_NET, value, taskId); in NetmanagerFinishAsyncTrace()
43 NETMGR_LOG_I("NetmanagerFinishAsyncTrace value:%{public}s, taskId:%{public}d", value.c_str(), taskId); in NetmanagerFinishAsyncTrace()
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/ipc/
H A Dasset_callback_manager.cpp62 void AssetCallbackManager::AddSendCallback(const std::string &taskId, const sptr<IAssetSendCallback> &sendCallback) in AddSendCallback() argument
64 if (taskId.empty()) { in AddSendCallback()
65 LOGI("taskId is empty"); in AddSendCallback()
69 auto iter = sendCallbackMap_.find(taskId); in AddSendCallback()
71 LOGI("taskId exist, taskId %{public}s", taskId.c_str()); in AddSendCallback()
74 sendCallbackMap_.insert(std::pair<std::string, sptr<IAssetSendCallback>>(taskId, sendCallback)); in AddSendCallback()
77 void AssetCallbackManager::RemoveSendCallback(const std::string &taskId) in RemoveSendCallback() argument
80 auto iter = sendCallbackMap_.find(taskId); in RemoveSendCallback()
121 NotifyAssetSendResult(const std::string &taskId, const sptr<AssetObj> &assetObj, int32_t result) NotifyAssetSendResult() argument
[all...]
/foundation/multimedia/media_foundation/engine/include/foundation/utils/
H A Dhitrace_utils.h24 #define ASYNC_TRACE_START(title, taskId)
25 #define ASYNC_TRACE_END(title, taskId)
39 #define ASYNC_TRACE_START(title, taskId) \
40 StartAsyncTrace(DEFAULT_HITRACE_TAG, WRAP_TITLE_PREFIX(title), taskId, DEFAULT_HITRACE_LIMIT)
41 #define ASYNC_TRACE_END(title, taskId) FinishAsyncTrace(WRAP_TITLE_PREFIX(title), taskId, DEFAULT_HITRACE_TAG)
54 AsyncTracker(const std::string &title, int32_t taskId);
/foundation/multimedia/media_foundation/interface/inner_api/osal/utils/
H A Dhitrace_utils.h24 #define ASYNC_TRACE_START(title, taskId)
25 #define ASYNC_TRACE_END(title, taskId)
39 #define ASYNC_TRACE_START(title, taskId) \
40 StartAsyncTrace(DEFAULT_HITRACE_TAG, WRAP_TITLE_PREFIX(title), taskId, DEFAULT_HITRACE_LIMIT)
41 #define ASYNC_TRACE_END(title, taskId) FinishAsyncTrace(WRAP_TITLE_PREFIX(title), taskId, DEFAULT_HITRACE_TAG)
54 AsyncTracker(const std::string &title, int32_t taskId);
/foundation/distributeddatamgr/kv_store/frameworks/common/
H A Dtask_scheduler.h71 innerTask.taskId = GenTaskId(); in At()
78 indexes_[innerTask.taskId] = it; in At()
79 return innerTask.taskId; in At()
81 TaskId Reset(TaskId taskId, const Duration &interval) in Reset() argument
84 if (running_.taskId == taskId && running_.interval != INVALID_INTERVAL) { in Reset()
86 return running_.taskId; in Reset()
88 auto index = indexes_.find(taskId); in Reset()
101 indexes_[taskId] = it; in Reset()
102 return taskId; in Reset()
116 Remove(TaskId taskId, bool wait = false) Remove() argument
146 TaskId taskId = INVALID_TASK_ID; global() member
189 auto taskId = ++taskId_; GenTaskId() local
[all...]
/foundation/ability/dmsfwk/services/dtbschedmgr/include/
H A Ddms_callback_task.h31 using DmsCallbackTaskInitCallbackFunc = std::function<void(int64_t taskId)>;
40 int64_t taskId = -1; member
50 int32_t PushCallback(int64_t taskId, const sptr<IRemoteObject>& callback, const std::string& deviceId,
52 CallbackTaskItem PopCallback(int64_t taskId);
53 void SetContinuationMissionMap(int64_t taskId, int32_t missionId);
54 LaunchType GetLaunchType(int64_t taskId);
55 void PopContinuationMissionMap(int64_t taskId);
56 int64_t GetContinuaionMissionId(int64_t taskId);
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor_pool.h108 innerTask.taskId = GenTaskId(); in Schedule()
112 bool Remove(TaskId taskId, bool wait = false) in Remove() argument
115 auto delay = delayTasks_.Find(taskId); in Remove()
119 delayTasks_.Remove(taskId, wait); in Remove()
121 execs_->Remove(taskId, wait); in Remove()
126 TaskId Reset(TaskId taskId, Duration interval) in Reset() argument
128 auto updated = delayTasks_.Update(taskId, [interval](InnerTask &task) -> std::pair<bool, Time> { in Reset()
135 return updated ? taskId : INVALID_TASK_ID; in Reset()
139 TaskId Execute(Task task, TaskId taskId) in Execute() argument
143 innerTask.taskId in Execute()
144 execs_->Push(std::move(innerTask), taskId, INVALID_TIME); Execute() local
195 auto taskId = ++taskId_; GenTaskId() local
[all...]
/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dexecutor_pool.h112 innerTask.taskId = GenTaskId(); in Schedule()
116 bool Remove(TaskId taskId, bool wait = false) in Remove() argument
119 auto delay = delayTasks_.Find(taskId); in Remove()
123 delayTasks_.Remove(taskId, wait); in Remove()
125 execs_->Remove(taskId, wait); in Remove()
130 TaskId Reset(TaskId taskId, Duration interval) in Reset() argument
132 auto updated = delayTasks_.Update(taskId, [interval](InnerTask &task) -> std::pair<bool, Time> { in Reset()
139 return updated ? taskId : INVALID_TASK_ID; in Reset()
143 TaskId Execute(Task task, TaskId taskId) in Execute() argument
147 innerTask.taskId in Execute()
148 execs_->Push(std::move(innerTask), taskId, INVALID_TIME); Execute() local
199 auto taskId = ++taskId_; GenTaskId() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/common/test/
H A Dpriority_queue_test.cpp45 TaskId taskId = INVALID_TASK_ID; member
50 return taskId != INVALID_TASK_ID; in Valid()
94 auto id = testTask.taskId; in HWTEST_F()
108 auto id = testTask.taskId; in HWTEST_F()
115 EXPECT_EQ(retPop.taskId, INVALID_TASK_ID); in HWTEST_F()
130 auto id = ++(testTask.taskId); in HWTEST_F()
137 EXPECT_EQ(retPop.taskId, id); in HWTEST_F()
154 auto id = ++(testTask.taskId); in HWTEST_F()
161 EXPECT_EQ(retPop.taskId, 1); in HWTEST_F()
179 auto id = ++(testTask.taskId); in HWTEST_F()
[all...]
/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/
H A Dfile_transfer_manager.cpp43 const uint64_t taskId, in DownloadFileFromRemoteDevice()
53 .taskId = taskId}; in DownloadFileFromRemoteDevice()
58 LOGI("send data, dataLen:%{public}d, taskId: %{public}" PRIu64 "", dataLen, taskId); in DownloadFileFromRemoteDevice()
62 DownloadAssetCallbackManager::GetInstance().OnDownloadFinshed(taskId, uri, ret); in DownloadFileFromRemoteDevice()
65 AddTransTask(uri, userId, taskId); in DownloadFileFromRemoteDevice()
90 auto taskId = msgHandler.GetTaskId(); in HandleDownloadFileRequest() local
97 .taskId = taskId}; in HandleDownloadFileRequest()
41 DownloadFileFromRemoteDevice(const std::string &networkId, const int32_t userId, const uint64_t taskId, const std::string &uri) DownloadFileFromRemoteDevice() argument
118 auto taskId = msgHandler.GetTaskId(); HandleDownloadFileResponse() local
219 AddTransTask(const std::string &uri, const int32_t userId, uint64_t taskId) AddTransTask() argument
227 RemoveTransTask(uint64_t taskId) RemoveTransTask() argument
[all...]
/foundation/distributedhardware/distributed_camera/common/src/utils/
H A Ddcamera_hitrace_adapter.cpp20 void DcameraStartAsyncTrace(const std::string& str, int32_t taskId) in DcameraStartAsyncTrace() argument
22 StartAsyncTrace(DCAMERA_HITRACE_LABEL, str, taskId, -1); in DcameraStartAsyncTrace()
25 void DcameraFinishAsyncTrace(const std::string& str, int32_t taskId) in DcameraFinishAsyncTrace() argument
27 FinishAsyncTrace(DCAMERA_HITRACE_LABEL, str, taskId); in DcameraFinishAsyncTrace()
/foundation/arkui/ace_engine/adapter/preview/osal/
H A Dace_trace.cpp23 void AceAsyncTraceBegin(int32_t taskId, const char* name, bool isAnimationTrace) {} in AceAsyncTraceBegin() argument
24 void AceAsyncTraceEnd(int32_t taskId, const char* name, bool isAnimationTrace) {} in AceAsyncTraceEnd() argument
25 void AceAsyncTraceBeginCommercial(int32_t taskId, const char* name, bool isAnimationTrace) {} in AceAsyncTraceBeginCommercial() argument
26 void AceAsyncTraceEndCommercial(int32_t taskId, const char* name, bool isAnimationTrace) {} in AceAsyncTraceEndCommercial() argument
/foundation/arkui/napi/interfaces/inner_api/cjffi/ark_interop/
H A Dark_interop_hitrace.cpp22 void ARKTS_HiTraceStartTrace(const char* name, int32_t taskId) in ARKTS_HiTraceStartTrace() argument
24 StartAsyncTrace(HITRACE_TAG_APP, name, taskId); in ARKTS_HiTraceStartTrace()
27 void ARKTS_HiTraceFinishTrace(const char* name, int32_t taskId) in ARKTS_HiTraceFinishTrace() argument
29 FinishAsyncTrace(HITRACE_TAG_APP, name, taskId); in ARKTS_HiTraceFinishTrace()
39 void ARKTS_HiTraceStartTrace(const char* /* name */, int32_t /* taskId */) {}
40 void ARKTS_HiTraceFinishTrace(const char* /* name */, int32_t /* taskId */) {}
41 void ARKTS_HiTraceCountTrace(const char* /* name */, int64_t /* taskId */) {}
/foundation/multimedia/media_library/frameworks/services/media_cloud_enhancement/src/enhancement_service/
H A Denhancement_service_callback.cpp186 string taskId = string(photoId); in OnSuccess() local
187 MEDIA_INFO_LOG("callback OnSuccess start, photo_id: %{public}s", taskId.c_str()); in OnSuccess()
188 CHECK_AND_RETURN_LOG(!taskId.empty(), "enhancement callback error: taskId is empty"); in OnSuccess()
190 CloudEnhancementThreadTask task(taskId, 0, nullptr, 0, true); in OnSuccess()
199 string taskId = string(photoId); in OnFailed() local
200 CHECK_AND_RETURN_LOG(!taskId.empty(), "enhancement callback error: taskId is empty"); in OnFailed()
204 MEDIA_INFO_LOG("callback start, photo_id: %{public}s enter, status code: %{public}d", taskId.c_str(), statusCode); in OnFailed()
206 "status code is invalid, task id:%{public}s, statusCode: %{public}d", taskId in OnFailed()
220 string taskId = task.taskId; DealWithSuccessedTask() local
266 string taskId = task.taskId; DealWithFailedTask() local
[all...]

Completed in 14 milliseconds

123456789