Home
last modified time | relevance | path

Searched refs:Schedule (Results 1 - 25 of 222) sorted by relevance

123456789

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
H A Dtask_manager.cpp32 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, uint64_t times) in Schedule() function in OHOS::DistributedData::TaskManager
44 return executors_->Schedule(task, delay, interval, times); in Schedule()
H A Dtask_manager.h31 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/
H A Dtask_executor_adapter.cpp25 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()
/foundation/distributeddatamgr/kv_store/frameworks/common/test/
H A Dexecutor_pool_test.cpp60 auto atTaskId1 = executorPool_->Schedule(expiredTime, [blockData]() { in HWTEST_F()
66 auto atTaskId2 = executorPool_->Schedule(expiredTime, [blockData]() { in HWTEST_F()
75 * @tc.name: Schedule
81 HWTEST_F(ExecutorPoolTest, Schedule, TestSize.Level0) in HWTEST_F()
85 auto taskId = executorPool_->Schedule( in HWTEST_F()
111 auto id = executorPool_->Schedule(task, std::chrono::seconds(0), std::chrono::seconds(LONG_INTERVAL), 10); in HWTEST_F()
135 auto temp = executorPool_->Schedule(task, expiredTime * 2); in HWTEST_F()
156 auto temp = executorPool_->Schedule(task, expiredTime * 2); in HWTEST_F()
182 executors->Schedule(std::chrono::milliseconds(SHORT_INTERVAL * 2), delayTask); in HWTEST_F()
203 taskId = executors->Schedule( in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Dmock_thread_pool.h25 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));
H A Dthread_pool_test_stub.h34 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;
H A Dthread_pool_test_stub.cpp41 LOGD("Schedule task succeed, ID:%" PRIu64, id); in Execute()
42 (void)taskPool_->Schedule([task, id]() { in Execute()
76 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration interval) in Schedule() function in ThreadPoolTestStub
81 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval) in Schedule() function in ThreadPoolTestStub
86 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) in Schedule() function in ThreadPoolTestStub
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
H A Dithread_pool.h35 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/
H A Dtask_executor_adapter.h30 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/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/
H A Dtask_executor.h43 TaskId Schedule(Duration delay, Task task) in Schedule() function in OHOS::NativeRdb::TaskExecutor::ExecutorPool
48 TaskId Schedule(Task task, Duration interval) in Schedule() function in OHOS::NativeRdb::TaskExecutor::ExecutorPool
53 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule() function in OHOS::NativeRdb::TaskExecutor::ExecutorPool
58 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule() function in OHOS::NativeRdb::TaskExecutor::ExecutorPool
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dexecutor_pool.h81 return Schedule(std::move(task), INVALID_DELAY, INVALID_INTERVAL, UNLIMITED_TIMES); in Execute()
87 TaskId Schedule(Duration delay, Task task) in Schedule() function in OHOS::ExecutorPool
89 return Schedule(std::move(task), delay, INVALID_INTERVAL, 1); in Schedule()
92 TaskId Schedule(Task task, Duration interval) in Schedule() function in OHOS::ExecutorPool
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 in OHOS::ExecutorPool
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 in OHOS::ExecutorPool
109 return Schedule(std::move(innerTask), std::chrono::steady_clock::now() + delay); in Schedule()
161 TaskId Schedule(InnerTas function in OHOS::ExecutorPool
[all...]
/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dexecutor_pool.h85 return Schedule(std::move(task), INVALID_DELAY, INVALID_INTERVAL, UNLIMITED_TIMES); in Execute()
91 TaskId Schedule(Duration delay, Task task) in Schedule() function in OHOS::NativePreferences::ExecutorPool
93 return Schedule(std::move(task), delay, INVALID_INTERVAL, 1); in Schedule()
96 TaskId Schedule(Task task, Duration interval) in Schedule() function in OHOS::NativePreferences::ExecutorPool
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 in OHOS::NativePreferences::ExecutorPool
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 in OHOS::NativePreferences::ExecutorPool
113 return Schedule(std::move(innerTask), std::chrono::steady_clock::now() + delay); in Schedule()
165 TaskId Schedule(InnerTas function in OHOS::NativePreferences::ExecutorPool
[all...]
/foundation/filemanagement/storage_service/services/storage_manager/kits_impl/src/
H A Dstorage_statistics_n_exporter.cpp80 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetTotalSizeOfVolume()
83 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetTotalSizeOfVolume()
128 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetFreeSizeOfVolume()
131 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetFreeSizeOfVolume()
202 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetBundleStats()
205 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetBundleStats()
238 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetCurrentBundleStats()
241 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetCurrentBundleStats()
275 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetSystemSize()
278 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureNam in GetSystemSize()
[all...]
H A Dvolumemanager_n_exporter.cpp95 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetAllVolumes()
98 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetAllVolumes()
149 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in Mount()
152 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in Mount()
189 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in Unmount()
192 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in Unmount()
241 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetVolumeByUuid()
244 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in GetVolumeByUuid()
294 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in GetVolumeById()
297 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureNam in GetVolumeById()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Dtask_pool.h35 // Schedule a task, the task can be ran in any thread.
36 virtual int Schedule(const Task &task) = 0;
38 // Schedule tasks using FIFO policy(tasks with the same 'tag').
39 virtual int Schedule(const std::string &tag, const Task &task) = 0;
/foundation/filemanagement/file_api/interfaces/kits/js/src/mod_statfs/
H A Dstatfs_n_exporter.cpp91 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_NAM in GetBFree()
[all...]
/foundation/bundlemanager/bundle_framework/interfaces/kits/js/zip/napi/class_checksum/
H A Dchecksum_n_exporter.cpp231 return NapiAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_CHECKSUM_NAME, cbExec, cbCompl).val_; in Adler32()
234 return NapiAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_CHECKSUM_NAME, cbExec, cbCompl).val_; in Adler32()
289 return NapiAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_CHECKSUM_NAME, cbExec, cbCompl).val_; in Adler32Combine()
292 return NapiAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_CHECKSUM_NAME, cbExec, cbCompl).val_; in Adler32Combine()
343 return NapiAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_CHECKSUM_NAME, cbExec, cbCompl).val_; in Adler32Combine64()
346 return NapiAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_CHECKSUM_NAME, cbExec, cbCompl).val_; in Adler32Combine64()
397 return NapiAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_CHECKSUM_NAME, cbExec, cbCompl).val_; in Crc32()
400 return NapiAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_CHECKSUM_NAME, cbExec, cbCompl).val_; in Crc32()
456 return NapiAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_CHECKSUM_NAME, cbExec, cbCompl).val_; in Crc32Combine()
459 return NapiAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_CHECKSUM_NAM in Crc32Combine()
[all...]
/foundation/bundlemanager/bundle_framework/interfaces/kits/js/zip/napi/properties/
H A Dcreate_checksum.cpp70 return NapiAsyncWorkPromise(env, thisVar).Schedule(PROCEDURE_CREATE_CHECKSUM_NAME, cbExec, cbCompl).val_; in Async()
73 return NapiAsyncWorkCallback(env, thisVar, cb).Schedule(PROCEDURE_CREATE_CHECKSUM_NAME, cbExec, cbCompl).val_; in Async()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dtask_pool_impl.h40 // Schedule a task, the task can be ran in any thread.
41 int Schedule(const Task &task) override;
43 // Schedule tasks one by one.
44 int Schedule(const std::string &queueTag, const Task &task) override;
/foundation/filemanagement/file_api/interfaces/kits/js/src/mod_fileio/properties/
H A Dfchmod.cpp51 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplCallback).val_; in Async()
54 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplCallback).val_; in Async()
H A Dfchown.cpp50 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplCallback).val_; in Async()
53 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplCallback).val_; in Async()
H A Dchown.cpp51 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbCompl).val_; in Async()
55 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbCompl).val_; in Async()
H A Dchmod.cpp52 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in Async()
55 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in Async()
H A Dlchown.cpp50 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbCompl).val_; in Async()
53 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbCompl).val_; in Async()
/foundation/filemanagement/user_file_service/frameworks/js/napi/file_access_module/
H A Dnapi_fileaccess_helper.cpp237 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in NAPI_GetFileAccessAbilityInfo()
244 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in NAPI_GetFileAccessAbilityInfo()
352 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in NAPI_OpenFile()
358 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in NAPI_OpenFile()
407 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in NAPI_CreateFile()
415 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in NAPI_CreateFile()
464 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in NAPI_Mkdir()
472 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureName, cbExec, cbComplete).val_; in NAPI_Mkdir()
518 return NAsyncWorkPromise(env, thisVar).Schedule(procedureName, cbExec, cbComplete).val_; in NAPI_Delete()
526 return NAsyncWorkCallback(env, thisVar, cb).Schedule(procedureNam in NAPI_Delete()
[all...]

Completed in 9 milliseconds

123456789