| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| D | task_manager.cpp | 32 return executors_->Schedule(delay, task); in Execute()
34 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration interval) in Schedule() function in OHOS::DistributedData::TaskManager
36 return executors_->Schedule(task, interval); in Schedule()
38 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration delay, Duration interval) in Schedule() function in OHOS::DistributedData::TaskManager
40 return executors_->Schedule(task, delay, interval); in Schedule()
42 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration delay, Duration interval, uint… in Schedule() function in OHOS::DistributedData::TaskManager
44 return executors_->Schedule(task, delay, interval, times); in Schedule()
|
| D | task_manager.h | 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;
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| D | task_executor_adapter.cpp | 25 return TaskExecutor::GetInstance().Schedule(delay, task); in Execute()
27 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Schedule(const TaskExecutorAdapter::Task &task, in Schedule() function in OHOS::DistributedKv::TaskExecutorAdapter
30 return TaskExecutor::GetInstance().Schedule(TaskExecutor::INVALID_DURATION, task, interval); in Schedule()
32 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Schedule(const TaskExecutorAdapter::Task &task, in Schedule() function in OHOS::DistributedKv::TaskExecutorAdapter
35 return TaskExecutor::GetInstance().Schedule(delay, task, interval); in Schedule()
37 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Schedule(const TaskExecutorAdapter::Task &task, in Schedule() function in OHOS::DistributedKv::TaskExecutorAdapter
40 return TaskExecutor::GetInstance().Schedule(delay, task, interval, times); in Schedule()
|
| D | task_executor.cpp | 43 TaskExecutor::TaskId TaskExecutor::Schedule(Duration delay, const Task &task, Duration interval, ui… in Schedule() function in OHOS::TaskExecutor
48 return pool_->Schedule(task, delay, interval, times); in Schedule()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| D | mock_thread_pool.h | 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));
|
| D | thread_pool_test_stub.h | 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;
|
| D | thread_pool_test_stub.cpp | 42 (void)taskPool_->Schedule([task, id]() { in Execute()
76 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration interval) in Schedule() function in DistributedDB::ThreadPoolTestStub
81 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval) in Schedule() function in DistributedDB::ThreadPoolTestStub
86 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval, uint64_t t… in Schedule() function in DistributedDB::ThreadPoolTestStub
|
| /foundation/distributeddatamgr/kv_store/frameworks/common/test/ |
| D | executor_pool_test.cpp | 60 auto atTaskId1 = executorPool_->Schedule(expiredTime, [blockData]() { in __anon1433fa2c0102()
66 auto atTaskId2 = executorPool_->Schedule(expiredTime, [blockData]() { in __anon1433fa2c0202()
81 HWTEST_F(ExecutorPoolTest, Schedule, TestSize.Level0)
85 auto taskId = executorPool_->Schedule(
111 …auto id = executorPool_->Schedule(task, std::chrono::seconds(0), std::chrono::seconds(LONG_INTERVA…
136 auto temp = executorPool_->Schedule(task, expiredTime * 2);
157 auto temp = executorPool_->Schedule(task, expiredTime * 2);
183 executors->Schedule(std::chrono::milliseconds(SHORT_INTERVAL * 2), delayTask);
|
| /foundation/distributeddatamgr/kv_store/frameworks/common/ |
| D | executor_pool.h | 81 return Schedule(std::move(task), INVALID_DELAY, INVALID_INTERVAL, UNLIMITED_TIMES); in Execute()
87 TaskId Schedule(Duration delay, Task task) in Schedule() function
89 return Schedule(std::move(task), delay, INVALID_INTERVAL, 1); in Schedule()
92 TaskId Schedule(Task task, Duration interval) in Schedule() function
94 return Schedule(std::move(task), INVALID_DELAY, interval, UNLIMITED_TIMES); in Schedule()
97 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule() function
99 return Schedule(std::move(task), delay, interval, UNLIMITED_TIMES); in Schedule()
102 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule() function
109 return Schedule(std::move(innerTask), std::chrono::steady_clock::now() + delay); in Schedule()
161 TaskId Schedule(InnerTask innerTask, Time delay) in Schedule() function
|
| /foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| D | executor_pool.h | 85 return Schedule(std::move(task), INVALID_DELAY, INVALID_INTERVAL, UNLIMITED_TIMES); in Execute()
91 TaskId Schedule(Duration delay, Task task) in Schedule() function
93 return Schedule(std::move(task), delay, INVALID_INTERVAL, 1); in Schedule()
96 TaskId Schedule(Task task, Duration interval) in Schedule() function
98 return Schedule(std::move(task), INVALID_DELAY, interval, UNLIMITED_TIMES); in Schedule()
101 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule() function
103 return Schedule(std::move(task), delay, interval, UNLIMITED_TIMES); in Schedule()
106 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule() function
113 return Schedule(std::move(innerTask), std::chrono::steady_clock::now() + delay); in Schedule()
165 TaskId Schedule(InnerTask innerTask, Time delay) in Schedule() function
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/ |
| D | task_executor.h | 43 TaskId Schedule(Duration delay, Task task) in Schedule() function
48 TaskId Schedule(Task task, Duration interval) in Schedule() function
53 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule() function
58 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule() function
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| D | ithread_pool.h | 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;
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/ |
| D | task_executor_adapter.h | 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;
|
| /foundation/filemanagement/storage_service/services/storage_manager/kits_impl/src/ |
| D | storage_statistics_n_exporter.cpp | 77 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetTotalSizeOfVolume()
80 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetTotalSizeOfVolume()
125 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetFreeSizeOfVolume()
128 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetFreeSizeOfVolume()
175 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetBundleStats()
178 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetBundleStats()
211 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetCurrentBundleStats()
214 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetCurrentBundleStats()
248 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetSystemSize()
251 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetSystemSize()
[all …]
|
| D | volumemanager_n_exporter.cpp | 85 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetAllVolumes()
88 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetAllVolumes()
131 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in Mount()
134 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in Mount()
176 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in Unmount()
179 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in Unmount()
234 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetVolumeByUuid()
237 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetVolumeByUuid()
292 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetVolumeById()
295 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetVolumeById()
[all …]
|
| /foundation/distributeddatamgr/distributedfile/interfaces/kits/js/src/mod_environment/ |
| D | environment_n_exporter.cpp | 56 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetStorageDataDir()
59 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetStorageDataDir()
92 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetUserDataDir()
95 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetUserDataDir()
|
| /foundation/filemanagement/file_api/interfaces/kits/js/src/mod_environment/ |
| D | environment_n_exporter.cpp | 63 return NAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetStorageDataDir()
67 return NAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetStorageDataDir()
103 return NAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetUserDataDir()
107 return NAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetUserDataDir()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| D | task_pool.h | 36 virtual int Schedule(const Task &task) = 0;
39 virtual int Schedule(const std::string &tag, const Task &task) = 0;
|
| /foundation/window/window_manager/interfaces/kits/napi/window_runtime/window_napi/ |
| D | js_window_listener.cpp | 79 AsyncTask::Schedule("JsWindowListener::OnSizeChange", in OnSizeChange()
116 AsyncTask::Schedule("JsWindowListener::OnSystemBarPropertyChange", in OnSystemBarPropertyChange()
156 AsyncTask::Schedule("JsWindowListener::OnAvoidAreaChanged", in OnAvoidAreaChanged()
177 AsyncTask::Schedule("JsWindowListener::LifeCycleCallBack", in LifeCycleCallBack()
233 AsyncTask::Schedule("JsWindowListener::OnSizeChange", in OnSizeChange()
253 AsyncTask::Schedule("JsWindowListener::OnOutsidePressed", in OnTouchOutside()
273 AsyncTask::Schedule("JsWindowListener::OnScreenshot", in OnScreenshot()
292 AsyncTask::Schedule("JsWindowListener::OnDialogTargetTouch", in OnDialogTargetTouch()
311 AsyncTask::Schedule("JsWindowListener::OnDialogDeathRecipient", in OnDialogDeathRecipient()
331 AsyncTask::Schedule("JsWindowListener::OnGestureNavigationEnabledUpdate", in OnGestureNavigationEnabledUpdate()
[all …]
|
| /foundation/distributeddatamgr/distributedfile/interfaces/kits/js/src/mod_statfs/ |
| D | statfs_n_exporter.cpp | 91 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetFrSize()
94 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetFrSize()
159 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetBSize()
162 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetBSize()
227 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetBAvail()
230 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetBAvail()
295 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetBlocks()
298 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetBlocks()
363 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetBFree()
366 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetBFree()
[all …]
|
| /foundation/filemanagement/file_api/interfaces/kits/js/src/mod_statfs/ |
| D | statfs_n_exporter.cpp | 91 return NAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetFrSize()
95 return NAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetFrSize()
160 return NAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetBSize()
164 return NAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetBSize()
229 return NAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetBAvail()
233 return NAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetBAvail()
298 return NAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetBlocks()
302 return NAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetBlocks()
367 return NAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetBFree()
371 return NAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_NAME, cbExec, cbComplete).val_; in GetBFree()
[all …]
|
| /foundation/filemanagement/dfs_service/interfaces/kits/js/cloudsyncmanager/ |
| D | cloud_sync_manager_n_exporter.cpp | 83 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in ChangeAppCloudSwitch()
86 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in ChangeAppCloudSwitch()
135 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in NotifyDataChange()
138 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in NotifyDataChange()
180 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in DisableCloud()
183 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in DisableCloud()
267 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in EnableCloud()
270 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in EnableCloud()
349 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in Clean()
352 … return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in Clean()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| D | task_pool_impl.h | 41 int Schedule(const Task &task) override;
44 int Schedule(const std::string &queueTag, const Task &task) override;
|
| /foundation/filemanagement/app_file_service/interfaces/kits/js/backup/ |
| D | local_capabilities.cpp | 58 …return NAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_LOCALCAPABILITIES_NAME, cbExec, cbCompl)… in Async()
62 …return NAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_LOCALCAPABILITIES_NAME, cbExec, cbC… in Async()
|
| /foundation/window/window_manager/interfaces/kits/napi/display_runtime/ |
| D | js_display_listener.cpp | 109 AsyncTask::Schedule("JsDisplayListener::OnCreate", *engine_, std::make_unique<AsyncTask>( in OnCreate()
135 AsyncTask::Schedule("JsDisplayListener::OnDestroy", *engine_, std::make_unique<AsyncTask>( in OnDestroy()
161 AsyncTask::Schedule("JsDisplayListener::OnChange", *engine_, std::make_unique<AsyncTask>( in OnChange()
187 AsyncTask::Schedule("JsDisplayListener::OnPrivateWindow", *engine_, std::make_unique<AsyncTask>( in OnPrivateWindow()
213 …AsyncTask::Schedule("JsDisplayListener::OnFoldStatusChanged", *engine_, std::make_unique<AsyncTask… in OnFoldStatusChanged()
239 …AsyncTask::Schedule("JsDisplayListener::OnDisplayModeChanged", *engine_, std::make_unique<AsyncTas… in OnDisplayModeChanged()
|