Home
last modified time | relevance | path

Searched refs:TaskId (Results 1 – 25 of 70) sorted by relevance

123

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer.h92 TaskId currentTaskId = 0u;
113 TaskId taskId = 0u;
143 int DoSync(TaskId taskId);
211 int PrepareSync(TaskId taskId);
213 int LockCloud(TaskId taskId);
301 TaskId GetNextTaskId();
399 bool IsTasksCanMerge(TaskId taskId, TaskId tryMergeTaskId);
401 bool MergeTaskTablesIfConsistent(TaskId sourceId, TaskId targetId);
405 std::pair<TaskId, TaskId> SwapTwoTaskAndCopyTable(TaskId source, TaskId target);
439 TaskId lastTaskId_;
[all …]
H A Dcloud_syncer.cpp117 CloudSyncer::TaskId currentTask; in Close()
138 CloudSyncer::TaskId currentTask; in StopAllTasks()
193 TaskId triggerTaskId = GetNextTaskId(); in DoSyncIfNeed()
224 int CloudSyncer::DoSync(TaskId taskId) in DoSync()
426 TaskId taskId; in SyncMachineDoFinished()
701 TaskId taskId; in DownloadAssets()
938 TaskId taskId; in NeedNotifyChangedData()
1381 bool CloudSyncer::IsPriorityTask(TaskId taskId) in IsPriorityTask()
1496 int CloudSyncer::PrepareSync(TaskId taskId) in PrepareSync()
1527 int CloudSyncer::LockCloud(TaskId taskId) in LockCloud()
[all …]
H A Dcloud_syncer_extend.cpp598 bool CloudSyncer::IsCompensatedTask(TaskId taskId) in IsCompensatedTask()
735 bool CloudSyncer::IsNeedGetLocalWater(TaskId taskId) in IsNeedGetLocalWater()
785 TaskId checkTaskId = taskId; in MergeTaskInfo()
793 std::pair<bool, TaskId> CloudSyncer::TryMergeTask(const std::shared_ptr<DataBaseSchema> &cloudSchem… in TryMergeTask()
795 std::pair<bool, TaskId> res; in TryMergeTask()
797 TaskId beMergeTask = INVALID_TASK_ID; in TryMergeTask()
798 TaskId runningTask = currentContext_.currentTaskId; in TryMergeTask()
845 bool CloudSyncer::IsTasksCanMerge(TaskId taskId, TaskId tryMergeTaskId) in IsTasksCanMerge()
853 bool CloudSyncer::MergeTaskTablesIfConsistent(TaskId sourceId, TaskId targetId) in MergeTaskTablesIfConsistent()
883 std::pair<TaskId, TaskId> CloudSyncer::SwapTwoTaskAndCopyTable(TaskId source, TaskId target) in SwapTwoTaskAndCopyTable()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A 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;
H A 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);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
H A 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;
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/
H A 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()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A 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));
H A 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;
H A 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()
96 TaskId ThreadPoolTestStub::Reset(const TaskId &taskId, Duration interval) in Reset()
H A Ddistributeddb_thread_pool_test.cpp110 …const std::shared_ptr<DistributedDBThreadPoolTest::TimerWatcher> &watcher, std::atomic<TaskId> &ta… in MockSchedule()
122 TaskId currentId = taskId++; in MockSchedule()
129 …EXPECT_CALL(*threadPoolPtr, Remove).WillRepeatedly([removeRes, &removeCount](const TaskId &taskId,… in MockRemove()
217 std::atomic<TaskId> currentId = 1;
232 … EXPECT_CALL(*threadPoolPtr_, Reset).WillOnce([&currentId](const TaskId &id, Duration modifyTime) { in __anonbed5c56d0c02()
260 std::atomic<TaskId> currentId = 1;
293 std::atomic<TaskId> currentId = 1;
320 std::atomic<TaskId> currentId = 1;
360 std::atomic<TaskId> currentId = 1;
403 std::atomic<TaskId> currentId = 1;
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
H A 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;
H A 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()
50 TaskManager::TaskId TaskManager::Reset(const TaskId &taskId, Duration interval) in Reset()
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dexecutor_pool.h33 using TaskId = Executor::TaskId;
39 using TaskQueue = PriorityQueue<InnerTask, Time, TaskId>;
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()
116 bool Remove(TaskId taskId, bool wait = false)
130 TaskId Reset(TaskId taskId, Duration interval) in Reset()
143 TaskId Execute(Task task, TaskId taskId) in Execute()
165 TaskId Schedule(InnerTask innerTask, Time delay) in Schedule()
197 TaskId GenTaskId() in GenTaskId()
[all …]
H A Dexecutor.h30 using TaskId = uint64_t;
38 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l);
49 TaskId taskId = INVALID_TASK_ID;
79 …void Bind(PriorityQueue<InnerTask, Time, TaskId> *queue, std::function<bool(std::shared_ptr<Execut… in Bind()
133 PriorityQueue<InnerTask, Time, TaskId> *waits_ = nullptr;
/ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor_pool.h30 using TaskId = Executor::TaskId;
36 using TaskQueue = PriorityQueue<InnerTask, Time, TaskId>;
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()
112 bool Remove(TaskId taskId, bool wait = false)
126 TaskId Reset(TaskId taskId, Duration interval) in Reset()
139 TaskId Execute(Task task, TaskId taskId) in Execute()
161 TaskId Schedule(InnerTask innerTask, Time delay) in Schedule()
193 TaskId GenTaskId() in GenTaskId()
[all …]
H A Dexecutor.h27 using TaskId = uint64_t;
35 static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l);
46 TaskId taskId = INVALID_TASK_ID;
65 …void Bind(PriorityQueue<InnerTask, Time, TaskId> *queue, std::function<bool(std::shared_ptr<Execut… in Bind()
119 PriorityQueue<InnerTask, Time, TaskId> *waits_ = nullptr;
/ohos5.0/foundation/filemanagement/dfs_service/frameworks/native/cloudsync_kit_inner/include/
H A Ddownload_asset_callback_client.h34 void OnFinished(const TaskId taskId, const std::string &uri, const int32_t result) override;
35 … void AddDownloadTaskCallback(const TaskId taskId, CloudSyncAssetManager::ResultCallback callback);
36 void RemoveDownloadTaskCallback(const TaskId taskId);
37 CloudSyncAssetManager::ResultCallback GetDownloadTaskCallback(const TaskId taskId);
38 TaskId GetTaskId();
41 SafeMap<const TaskId, CloudSyncAssetManager::ResultCallback> callbackListMap_;
42 std::atomic<TaskId> taskId_{0};
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_syncer_test.h129 SyncProcessCallback getCallback(TaskId taskId) in getCallback()
134 TaskId getCurrentTaskId() in getCurrentTaskId()
147 int CallDoDownload(TaskId taskId) in CallDoDownload()
167 int32_t GetUploadSuccessCount(TaskId taskId) in GetUploadSuccessCount()
172 int32_t GetUploadFailCount(TaskId taskId) in GetUploadFailCount()
225 int CallPrepareSync(TaskId taskId) in CallPrepareSync()
269 void SetCurrentContext(TaskId taskId) in SetCurrentContext()
274 void SetLastTaskId(TaskId taskId) in SetLastTaskId()
319 void ClearResumeTaskInfo(TaskId taskId) in ClearResumeTaskInfo()
339 bool IsResumeTaskUpload(TaskId taskId) in IsResumeTaskUpload()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A 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()
47 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Reset(const TaskExecutorAdapter::TaskId &taskId, in Reset()
H A Dtask_executor.cpp30 TaskExecutor::TaskId TaskExecutor::Execute(const Task &task) in Execute()
41 TaskExecutor::TaskId TaskExecutor::Schedule(Duration delay, const Task &task, Duration interval, ui… in Schedule()
52 bool TaskExecutor::Remove(TaskExecutor::TaskId taskId, bool wait) in Remove()
60 TaskExecutor::TaskId TaskExecutor::Reset(TaskExecutor::TaskId taskId, Duration interval) in Reset()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/
H A Dtask_scheduler.h33 using TaskId = uint64_t;
38 inline static constexpr TaskId INVALID_TASK_ID = static_cast<uint64_t>(0l);
81 TaskId Reset(TaskId taskId, const Duration &interval) in Reset()
111 TaskId Every(Duration interval, Task task) in Every()
116 void Remove(TaskId taskId, bool wait = false)
131 TaskId Every(Duration delay, Duration interval, Task task) in Every()
136 TaskId Every(int32_t times, Duration delay, Duration interval, Task task) in Every()
140 TaskId Execute(Task task) in Execute()
146 TaskId taskId = INVALID_TASK_ID;
187 TaskId GenTaskId() in GenTaskId()
[all …]
/ohos5.0/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 int… in OnFinished()
37 void DownloadAssetCallbackClient::AddDownloadTaskCallback(TaskId taskId, CloudSyncAssetManager::Res… in AddDownloadTaskCallback()
43 void DownloadAssetCallbackClient::RemoveDownloadTaskCallback(TaskId taskId) in RemoveDownloadTaskCallback()
53 CloudSyncAssetManager::ResultCallback DownloadAssetCallbackClient::GetDownloadTaskCallback(TaskId t… in GetDownloadTaskCallback()
63 DownloadAssetCallback::TaskId DownloadAssetCallbackClient::GetTaskId() in GetTaskId()
/ohos5.0/base/startup/init/services/loopevent/loop/
H A Dle_loop.c30 TaskId *taskId = (TaskId *)key; in TaskKeyCompare()
42 TaskId *taskId = (TaskId *)key; in TaskGetKeyHasCode()
120 TaskId id = {0, {fd}}; in GetTaskByFd()
134 OH_HashMapRemove(loop->taskMap, (TaskId *)task); in DelTask()
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Dtask_executor.h21 using TaskId = ExecutorPool::TaskId;
24 static constexpr TaskId INVALID_TASK_ID = ExecutorPool::INVALID_TASK_ID;

123