Home
last modified time | relevance | path

Searched full:taskid (Results 1 – 25 of 135) sorted by relevance

123456

/foundation/ability/dmsfwk/services/dtbschedmgr/src/
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 = taskId, in PushCallback()
88 (void)callbackMap_.emplace(taskId, item); in PushCallback()
92 CallbackTaskItem DmsCallbackTask::PopCallback(int64_t taskId) in PopCallback() argument
[all …]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
Dcloud_syncer.h96 TaskId currentTaskId = 0u;
109 TaskId taskId = 0u; member
126 int DoSync(TaskId taskId);
132 void DoFinished(TaskId taskId, int errCode, const InnerProcessInfo &processInfo);
134 virtual int DoDownload(CloudSyncer::TaskId taskId);
136 int DoDownloadInner(CloudSyncer::TaskId taskId, SyncParam &param);
138 void NotifyInEmptyDownload(CloudSyncer::TaskId taskId, InnerProcessInfo &info);
140 int PreCheckUpload(TaskId &taskId, const TableName &tableName, Timestamp &localMark);
142 int PreCheck(TaskId &taskId, const TableName &tableName);
147 TaskId &taskId);
[all …]
Dcloud_syncer.cpp37 const TaskId INVALID_TASK_ID = 0u;
99 CloudSyncer::TaskId currentTask; in Close()
133 LOGI("[CloudSyncer] finished taskId %" PRIu64 " errCode %d", info.taskId, info.errCode); in Close()
161 // get taskId from queue in DoSyncIfNeed()
162 TaskId triggerTaskId; in DoSyncIfNeed()
170 // pop taskId in queue in DoSyncIfNeed()
182 int CloudSyncer::DoSync(TaskId taskId) in DoSync() argument
188 taskInfo = cloudTaskInfos_[taskId]; in DoSync()
190 int errCode = LockCloud(taskId); in DoSync()
219 errCode = CheckTaskIdValid(taskInfo.taskId); in DoUploadInNeed()
[all …]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
Dcloud_syncer_test.h41 void InitCloudSyncer(TaskId taskId, SyncMode mode) in InitCloudSyncer() argument
43 cloudTaskInfos_.insert(std::pair<TaskId, CloudTaskInfo>{taskId, CloudTaskInfo()}); in InitCloudSyncer()
44 cloudTaskInfos_[taskId].mode = mode; in InitCloudSyncer()
45 cloudTaskInfos_[taskId].taskId = taskId; in InitCloudSyncer()
46 currentContext_.currentTaskId = taskId; in InitCloudSyncer()
47 currentContext_.tableName = "TestTable" + std::to_string(taskId); in InitCloudSyncer()
52 …cloudTaskInfos_[taskId].callback = [this, taskId](const std::map<std::string, SyncProcess> &proces… in InitCloudSyncer()
54 process_[taskId] = process.begin()->second; in InitCloudSyncer()
57 process_[taskId] = tmpProcess; in InitCloudSyncer()
89 void SetTimeOut(TaskId taskId, int64_t timeout) in SetTimeOut() argument
[all …]
Dvirtual_cloud_syncer.cpp24 int VirtualCloudSyncer::DoDownload(CloudSyncer::TaskId taskId) in DoDownload() argument
33 return CloudSyncer::DoDownload(taskId); in DoDownload()
36 int VirtualCloudSyncer::DoUpload(CloudSyncer::TaskId taskId, bool lastTable) in DoUpload() argument
42 return CloudSyncer::DoUpload(taskId, lastTable); in DoUpload()
58 TaskId currentTaskId; in Notify()
79 CloudSyncer::TaskId taskId) in SetCurrentTaskInfo() argument
83 currentContext_.currentTaskId = taskId; in SetCurrentTaskInfo()
89 cloudTaskInfos_[taskId] = taskInfo; in SetCurrentTaskInfo()
Ddistributeddb_cloud_syncer_download_test.cpp223 TaskId taskId = 1u; variable
239 g_cloudSyncer->InitCloudSyncer(taskId, SYNC_MODE_CLOUD_MERGE);
243 int errCode = g_cloudSyncer->CallDoDownload(taskId);
247 taskId = 3u;
248 g_cloudSyncer->InitCloudSyncer(taskId, SYNC_MODE_CLOUD_FORCE_PUSH);
250 errCode = g_cloudSyncer->CallDoDownload(taskId);
253 taskId = 4u;
254 g_cloudSyncer->InitCloudSyncer(taskId, SYNC_MODE_CLOUD_FORCE_PUSH);
256 errCode = g_cloudSyncer->CallDoDownload(taskId);
259 taskId = 5u;
[all …]
Dvirtual_cloud_syncer.h25 int DoDownload(TaskId taskId) override;
27 int DoUpload(TaskId taskId, bool lastTable) override;
37 void SetCurrentTaskInfo(const SyncProcessCallback &callback, CloudSyncer::TaskId taskId);
/foundation/distributeddatamgr/preferences/frameworks/native/include/
Dexecutor_pool.h33 using TaskId = Executor::TaskId;
39 using TaskQueue = PriorityQueue<InnerTask, Time, TaskId>;
44 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l);
77 TaskId Execute(Task task) in Execute()
91 TaskId Schedule(Duration delay, Task task) in Schedule()
96 TaskId Schedule(Task task, Duration interval) in Schedule()
101 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule()
106 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule()
112 innerTask.taskId = GenTaskId(); in Schedule()
116 bool Remove(TaskId taskId, bool wait = false)
[all …]
/foundation/distributeddatamgr/kv_store/frameworks/common/
Dexecutor_pool.h30 using TaskId = Executor::TaskId;
36 using TaskQueue = PriorityQueue<InnerTask, Time, TaskId>;
41 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l);
74 TaskId Execute(Task task) in Execute()
87 TaskId Schedule(Duration delay, Task task) in Schedule()
92 TaskId Schedule(Task task, Duration interval) in Schedule()
97 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule()
102 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule()
108 innerTask.taskId = GenTaskId(); in Schedule()
112 bool Remove(TaskId taskId, bool wait = false)
[all …]
Dtask_scheduler.h33 using TaskId = uint64_t;
38 inline static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l);
63 …TaskId At(const Time &begin, Task task, Duration interval = INVALID_INTERVAL, uint64_t times = UNL…
71 innerTask.taskId = GenTaskId();
78 indexes_[innerTask.taskId] = it;
79 return innerTask.taskId;
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()
[all …]
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/
Ddms_callback_task_test.cpp43 DmsCallbackTaskInitCallbackFunc mockCallback = [this] (int64_t taskId) {}; in SetUp() argument
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; variable
110 int32_t result = dmsCallbackTask_->PushCallback(taskId, callback, deviceId,
125 int64_t taskId = 1; variable
130 int32_t result = dmsCallbackTask_->PushCallback(taskId, callback, deviceId,
145 int64_t taskId = 1; variable
[all …]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
Dtask_executor_adapter.h23 using TaskId = DistributedDB::TaskId;
28 TaskId Execute(const Task &task) override;
29 TaskId Execute(const Task &task, Duration delay) override;
30 TaskId Schedule(const Task &task, Duration interval) override;
31 TaskId Schedule(const Task &task, Duration delay, Duration interval) override;
32 TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) override;
33 bool Remove(const TaskId &taskId, bool wait) override;
34 TaskId Reset(const TaskId &taskId, Duration interval) override;
Dtask_executor.h21 using TaskId = ExecutorPool::TaskId;
25 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l);
29 TaskId Execute(const Task &task);
30 TaskId Schedule(Duration delay, const Task &task, Duration interval = INVALID_DURATION,
32 bool Remove(TaskId taskId, bool wait = false);
33 TaskId Reset(TaskId taskId, Duration interval);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
Dtask_manager.cpp26 TaskManager::TaskId TaskManager::Execute(const Task &task) in Execute()
30 TaskManager::TaskId TaskManager::Execute(const Task &task, Duration delay) in Execute()
34 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration interval) in Schedule()
38 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration delay, Duration interval) in Schedule()
42 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration delay, Duration interval, uint… in Schedule()
46 bool TaskManager::Remove(const TaskId &taskId, bool wait) in Remove() argument
48 return executors_->Remove(taskId, wait); in Remove()
50 TaskManager::TaskId TaskManager::Reset(const TaskId &taskId, Duration interval) in Reset() argument
52 return executors_->Reset(taskId, interval); in Reset()
Dtask_manager.h23 using TaskId = uint64_t;
29 TaskId Execute(const Task &task) override;
30 TaskId Execute(const Task &task, Duration delay) override;
31 TaskId Schedule(const Task &task, Duration interval) override;
32 TaskId Schedule(const Task &task, Duration delay, Duration interval) override;
33 TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) override;
34 bool Remove(const TaskId &taskId, bool wait) override;
35 TaskId Reset(const TaskId &taskId, Duration interval) override;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
Dithread_pool.h24 using TaskId = uint64_t; variable
31 virtual TaskId Execute(const Task &task) = 0;
33 virtual TaskId Execute(const Task &task, Duration delay) = 0;
35 virtual TaskId Schedule(const Task &task, Duration interval) = 0;
37 virtual TaskId Schedule(const Task &task, Duration delay, Duration interval) = 0;
39 … virtual TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) = 0;
41 virtual bool Remove(const TaskId &taskId, bool wait) = 0;
43 virtual TaskId Reset(const TaskId &taskId, Duration interval) = 0;
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/
Dtask_executor.h23 using TaskId = uint64_t;
27 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l);
38 TaskId Execute(Task task) in Execute()
43 TaskId Schedule(Duration delay, Task task) in Schedule()
48 TaskId Schedule(Task task, Duration interval) in Schedule()
53 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule()
58 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule()
63 bool Remove(TaskId taskId, bool wait = false)
68 TaskId Reset(TaskId taskId, Duration interval) in Reset() argument
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
Dtask_executor_adapter.cpp18 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Execute(const TaskExecutorAdapter::Task &task) in Execute()
22 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Execute(const TaskExecutorAdapter::Task &task, in Execute()
27 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Schedule(const TaskExecutorAdapter::Task &task, in Schedule()
32 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Schedule(const TaskExecutorAdapter::Task &task, in Schedule()
37 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Schedule(const TaskExecutorAdapter::Task &task, in Schedule()
43 bool TaskExecutorAdapter::Remove(const TaskExecutorAdapter::TaskId &taskId, bool wait) in Remove() argument
45 return TaskExecutor::GetInstance().Remove(taskId, wait); in Remove()
47 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Reset(const TaskExecutorAdapter::TaskId &taskId, in Reset() argument
50 return TaskExecutor::GetInstance().Reset(taskId, interval); in Reset()
Dtask_executor.cpp35 TaskExecutor::TaskId TaskExecutor::Execute(const Task &task) in Execute()
43 TaskExecutor::TaskId TaskExecutor::Schedule(Duration delay, const Task &task, Duration interval, ui… in Schedule()
51 bool TaskExecutor::Remove(TaskExecutor::TaskId taskId, bool wait) in Remove() argument
56 return pool_->Remove(taskId, wait); in Remove()
59 TaskExecutor::TaskId TaskExecutor::Reset(TaskExecutor::TaskId taskId, Duration interval) in Reset() argument
64 return pool_->Reset(taskId, interval); in Reset()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
Dthread_pool_test_stub.h30 TaskId Execute(const Task &task) override;
32 TaskId Execute(const Task &task, Duration delay) override;
34 TaskId Schedule(const Task &task, Duration interval) override;
36 TaskId Schedule(const Task &task, Duration delay, Duration interval) override;
38 TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) override;
40 bool Remove(const TaskId &taskId, bool wait) override;
42 TaskId Reset(const TaskId &taskId, Duration interval) override;
Dmock_thread_pool.h23 MOCK_METHOD1(Execute, TaskId(const Task &));
24 MOCK_METHOD2(Execute, TaskId(const Task &, Duration));
25 MOCK_METHOD2(Schedule, TaskId(const Task &, Duration));
26 MOCK_METHOD3(Schedule, TaskId(const Task &, Duration, Duration));
27 MOCK_METHOD4(Schedule, TaskId(const Task &, Duration, Duration, uint64_t));
28 MOCK_METHOD2(Remove, bool(const TaskId &, bool));
29 MOCK_METHOD2(Reset, TaskId(const TaskId &, Duration));
Dthread_pool_test_stub.cpp20 const TaskId INVALID_ID = 0u;
32 TaskId ThreadPoolTestStub::Execute(const Task &task) in Execute()
68 TaskId ThreadPoolTestStub::Execute(const Task &task, Duration delay) in Execute()
76 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration interval) in Schedule()
81 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval) in Schedule()
86 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval, uint64_t t… in Schedule()
91 bool ThreadPoolTestStub::Remove(const TaskId &taskId, bool wait) in Remove() argument
96 TaskId ThreadPoolTestStub::Reset(const TaskId &taskId, Duration interval) in Reset() argument
/foundation/communication/netmanager_base/utils/common_utils/src/
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 …TMGR_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 …MGR_LOG_I("NetmanagerFinishAsyncTrace value:%{public}s, taskId:%{public}d", value.c_str(), 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() 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/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() argument
85 if (taskId <= INVALID_TASK_ID) { in TraceBegin()
90 StartAsyncTrace(HITRACE_TAG_ZMEDIA, traceBegin, taskId); in TraceBegin()
93 static void TraceEnd(const std::string& traceName, int32_t taskId) in TraceEnd() argument
95 if (taskId <= INVALID_TASK_ID) { in TraceEnd()
100 FinishAsyncTrace(HITRACE_TAG_ZMEDIA, traceEnd, taskId); in TraceEnd()

123456