Home
last modified time | relevance | path

Searched defs:taskId (Results 1 – 25 of 73) sorted by relevance

123

/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/
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()
105 int64_t taskId = -1; variable
125 int64_t taskId = 1; variable
145 int64_t taskId = 1; variable
166 int64_t taskId = 1; variable
187 int64_t taskId = 1; variable
208 int64_t taskId = 1; variable
228 int64_t taskId = 1; variable
243 int64_t taskId = 1; variable
[all …]
/foundation/ability/dmsfwk/services/dtbschedmgr/src/
Ddms_callback_task.cpp47 int32_t DmsCallbackTask::PushCallback(int64_t taskId, const sptr<IRemoteObject>& callback, in PushCallback()
92 CallbackTaskItem DmsCallbackTask::PopCallback(int64_t taskId) in PopCallback()
109 void DmsCallbackTask::PopContinuationMissionMap(int64_t taskId) in PopContinuationMissionMap()
118 int64_t DmsCallbackTask::GetContinuaionMissionId(int64_t taskId) in GetContinuaionMissionId()
134 void DmsCallbackTask::SetContinuationMissionMap(int64_t taskId, int32_t missionId) in SetContinuationMissionMap()
150 LaunchType DmsCallbackTask::GetLaunchType(int64_t taskId) in GetLaunchType()
191 int64_t taskId = static_cast<int64_t>(eventId); in ProcessEvent() local
/foundation/distributedhardware/distributed_camera/common/src/utils/
Ddcamera_hitrace_adapter.cpp20 void DcameraStartAsyncTrace(const std::string& str, int32_t taskId) in DcameraStartAsyncTrace()
25 void DcameraFinishAsyncTrace(const std::string& str, int32_t taskId) in DcameraFinishAsyncTrace()
/foundation/distributedhardware/distributed_audio/common/dfx_utils/src/
Ddaudio_hitrace.cpp20 void DaudioStartAsyncTrace(const std::string& str, int32_t taskId) in DaudioStartAsyncTrace()
25 void DaudioFinishAsyncTrace(const std::string& str, int32_t taskId) in DaudioFinishAsyncTrace()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
Dcloud_syncer_test.h41 void InitCloudSyncer(TaskId taskId, SyncMode mode) in InitCloudSyncer()
89 void SetTimeOut(TaskId taskId, int64_t timeout) in SetTimeOut()
113 SyncProcessCallback getCallback(TaskId taskId) in getCallback()
131 int CallDoDownload(TaskId taskId) in CallDoDownload()
151 int32_t GetUploadSuccessCount(TaskId taskId) in GetUploadSuccessCount()
156 int32_t GetUploadFailCount(TaskId taskId) in GetUploadFailCount()
171 void CallDoFinished(TaskId taskId, int errCode, const InnerProcessInfo &processInfo) in CallDoFinished()
209 int CallPrepareSync(TaskId taskId) in CallPrepareSync()
Dvirtual_cloud_syncer.cpp24 int VirtualCloudSyncer::DoDownload(CloudSyncer::TaskId taskId) in DoDownload()
36 int VirtualCloudSyncer::DoUpload(CloudSyncer::TaskId taskId, bool lastTable) in DoUpload()
79 CloudSyncer::TaskId taskId) in SetCurrentTaskInfo()
/foundation/distributedhardware/distributed_screen/services/screenservice/test/unittest/sourceservice/dscreenmgr/1.0/src/
Ddscreen_test.cpp122 std::string taskId = "taskId"; variable
143 std::string taskId = "taskId"; variable
163 std::string taskId = "taskId"; variable
183 std::string taskId = "taskId"; variable
207 std::string taskId = "taskId"; variable
223 std::string taskId = "taskId"; variable
251 std::string taskId = "taskId"; variable
281 std::string taskId = "taskId"; variable
/foundation/multimedia/histreamer/engine/include/foundation/utils/
Dhitrace_utils.h24 #define ASYNC_TRACE_START(title, taskId) argument
25 #define ASYNC_TRACE_END(title, taskId) argument
39 #define ASYNC_TRACE_START(title, taskId) \ argument
41 #define ASYNC_TRACE_END(title, taskId) FinishAsyncTrace(WRAP_TITLE_PREFIX(title), taskId, DEFAULT_H… argument
/foundation/communication/netmanager_base/utils/common_utils/src/
Dnetmanager_hitrace.cpp34 void NetmanagerHiTrace::NetmanagerStartAsyncTrace(const std::string &value, int32_t taskId) in NetmanagerStartAsyncTrace()
40 void NetmanagerHiTrace::NetmanagerFinishAsyncTrace(const std::string &value, int32_t taskId) in NetmanagerFinishAsyncTrace()
/foundation/communication/bluetooth_service/services/bluetooth/server/src/
Dbluetooth_hitrace.cpp35 void BluetoothHiTrace::BluetoothStartAsyncTrace(const std::string& value, int32_t taskId) in BluetoothStartAsyncTrace()
41 void BluetoothHiTrace::BluetoothFinishAsyncTrace(const std::string& value, int32_t taskId) in BluetoothFinishAsyncTrace()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
Ddb_dfx_adapter.cpp112 void DBDfxAdapter::StartAsyncTrace(const std::string &action, int32_t taskId) in StartAsyncTrace()
119 void DBDfxAdapter::FinishAsyncTrace(const std::string &action, int32_t taskId) in FinishAsyncTrace()
140 void DBDfxAdapter::StartAsyncTrace(const std::string &action, int32_t taskId) in StartAsyncTrace()
146 void DBDfxAdapter::FinishAsyncTrace(const std::string &action, int32_t taskId) in FinishAsyncTrace()
/foundation/arkui/ace_engine/adapter/preview/osal/
Dace_trace.cpp33 void AceAsyncTraceBegin(int32_t taskId, const char* name) in AceAsyncTraceBegin()
37 void AceAsyncTraceEnd(int32_t taskId, const char* name) in AceAsyncTraceEnd()
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
Dtask_executor.cpp51 bool TaskExecutor::Remove(TaskExecutor::TaskId taskId, bool wait) in Remove()
59 TaskExecutor::TaskId TaskExecutor::Reset(TaskExecutor::TaskId taskId, Duration interval) in Reset()
Dtask_executor_adapter.cpp43 bool TaskExecutorAdapter::Remove(const TaskExecutorAdapter::TaskId &taskId, bool wait) in Remove()
47 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Reset(const TaskExecutorAdapter::TaskId &taskId, in Reset()
/foundation/arkui/ace_engine/adapter/ohos/osal/
Dace_trace.cpp44 void AceAsyncTraceBegin(int32_t taskId, const char* name) in AceAsyncTraceBegin()
51 void AceAsyncTraceEnd(int32_t taskId, const char* name) in AceAsyncTraceEnd()
/foundation/distributedhardware/distributed_screen/services/screenservice/test/unittest/sourceservice/dscreenmgr/2.0/src/
Ddscreen_test.cpp111 std::string taskId = "taskId"; variable
128 std::string taskId = "taskId"; variable
379 std::string taskId = "taskId"; variable
393 std::string taskId = "taskId"; variable
/foundation/multimedia/av_session/utils/include/
Davsession_trace.h27 #define AVSESSION_TRACE_ASYNC_START(traceName, taskId) AVSessionTrace::TraceBegin(traceName, taskId) argument
28 #define AVSESSION_TRACE_ASYNC_END(traceName, taskId) AVSessionTrace::TraceEnd(traceName, taskId) argument
83 static void TraceBegin(const std::string& traceName, int32_t taskId) in TraceBegin()
93 static void TraceEnd(const std::string& traceName, int32_t taskId) in TraceEnd()
/foundation/resourceschedule/ffrt/src/queue/
Dqueue_monitor.cpp86 void QueueMonitor::UpdateQueueInfo(uint32_t queueId, const uint64_t &taskId) in UpdateQueueInfo()
111 void QueueMonitor::ResetTaskTimestampAfterWarning(uint32_t queueId, const uint64_t &taskId) in ResetTaskTimestampAfterWarning()
127 uint64_t taskId = 0; in CheckQueuesStatus() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
Dcloud_syncer.cpp182 int CloudSyncer::DoSync(TaskId taskId) in DoSync()
285 void CloudSyncer::DoFinished(TaskId taskId, int errCode, const InnerProcessInfo &processInfo) in DoFinished()
917 int CloudSyncer::PreCheck(CloudSyncer::TaskId &taskId, const TableName &tableName) in PreCheck()
982 void CloudSyncer::NotifyInDownload(CloudSyncer::TaskId taskId, SyncParam &param) in NotifyInDownload()
1005 int CloudSyncer::SaveDataInTransaction(CloudSyncer::TaskId taskId, SyncParam &param) in SaveDataInTransaction()
1035 int CloudSyncer::SaveDataNotifyProcess(CloudSyncer::TaskId taskId, SyncParam &param) in SaveDataNotifyProcess()
1078 int CloudSyncer::DoDownload(CloudSyncer::TaskId taskId) in DoDownload()
1110 int CloudSyncer::DoDownloadInner(CloudSyncer::TaskId taskId, SyncParam &param) in DoDownloadInner()
1157 void CloudSyncer::NotifyInEmptyDownload(CloudSyncer::TaskId taskId, InnerProcessInfo &info) in NotifyInEmptyDownload()
1172 int CloudSyncer::PreCheckUpload(CloudSyncer::TaskId &taskId, const TableName &tableName, Timestamp … in PreCheckUpload()
[all …]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
Dtask_manager.cpp46 bool TaskManager::Remove(const TaskId &taskId, bool wait) in Remove()
50 TaskManager::TaskId TaskManager::Reset(const TaskId &taskId, Duration interval) in Reset()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/task/
Dtask_board.cpp69 void TaskBoard::RemoveTask(std::string taskId) in RemoveTask()
79 void TaskBoard::RemoveTaskInner(std::string taskId) in RemoveTaskInner()
/foundation/multimedia/histreamer/engine/foundation/utils/
Dhitrace_utils.cpp30 AsyncTracker::AsyncTracker(const std::string &title, int32_t taskId) in AsyncTracker()
/foundation/distributeddatamgr/kv_store/frameworks/common/test/
Dtask_scheduler_test.cpp170 auto taskId = taskScheduler.Every(times, std::chrono::milliseconds(0), variable
198 auto taskId = taskScheduler.At(expiredTime, [blockData, testData]() { in __anon6ee7f5d50902() variable
222 auto taskId = taskScheduler.At(expiredTime, [blockDataTest, blockDataWait, &testData]() { in __anon6ee7f5d50a02() variable
249 auto taskId = taskScheduler.At(expiredTime, [blockDataTest, blockDataWait, &testData]() { in __anon6ee7f5d50b02() variable
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
Dthread_pool_test_stub.cpp91 bool ThreadPoolTestStub::Remove(const TaskId &taskId, bool wait) in Remove()
96 TaskId ThreadPoolTestStub::Reset(const TaskId &taskId, Duration interval) in Reset()
/foundation/distributeddatamgr/kv_store/frameworks/common/
Dexecutor_pool.h126 TaskId Reset(TaskId taskId, Duration interval) in Reset()
139 TaskId Execute(Task task, TaskId taskId) in Execute()
195 auto taskId = ++taskId_; in GenTaskId() local

123