/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
H A D | task_manager.cpp | 30 TaskManager::TaskId TaskManager::Execute(const Task &task, Duration delay) in Execute() argument 32 return executors_->Schedule(delay, task); in Execute() 38 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration delay, Duration interval) in Schedule() argument 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() argument 44 return executors_->Schedule(task, delay, interval, times); in Schedule()
|
H A D | task_manager.h | 30 TaskId Execute(const Task &task, Duration delay) 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/arkui/ace_engine_lite/frameworks/tools/qt/simulator/jsfwk/targets/simulator/mock/timerthread/ |
H A D | timer_thread.cpp | 31 const unsigned int delay, in StartTimerTask() 40 return g_timerInstance->StartTimerTaskInner(isPeriodic, delay, userCallback, userData, timerHandle); in StartTimerTask() 84 info->remain = info->delay; in Traverse() 95 const unsigned int delay, in StartTimerTaskInner() 104 info->delay = delay; in StartTimerTaskInner() 105 info->remain = delay; in StartTimerTaskInner() 30 StartTimerTask(bool isPeriodic, const unsigned int delay, void *userCallback, void *userData, timerHandle_t *timerHandle) StartTimerTask() argument 94 StartTimerTaskInner(bool isPeriodic, const unsigned int delay, void *userCallback, void *userData, timerHandle_t *timerHandle) StartTimerTaskInner() argument
|
/foundation/arkui/ace_engine/frameworks/core/components_ng/render/ |
H A D | snapshot_param.h | 38 int32_t delay; member 41 explicit SnapshotParam(int32_t delay = DEFAULT_DELAY_TIME, bool checkImageStatus = false, in SnapshotParam() 42 SnapshotOptions options = SnapshotOptions()) : delay(delay), checkImageStatus(checkImageStatus), in SnapshotParam() 46 return "{" + std::to_string(delay) + ", " + (checkImageStatus ? "true" : "false") + ", " + in ToString()
|
/foundation/communication/dsoftbus/adapter/common/dfx/ |
H A D | softbus_adapter_xcollie_virtual.cpp | 32 void SoftBusRunOneShotTask(const char *name, void(*task)(void), uint64_t delay) in SoftBusRunOneShotTask() argument 36 (void)delay; in SoftBusRunOneShotTask() 39 void SoftBusRunPeriodicalTask(const char *name, void(*task)(void), uint64_t interval, uint64_t delay) in SoftBusRunPeriodicalTask() argument 44 (void)delay; in SoftBusRunPeriodicalTask()
|
H A D | softbus_adapter_xcollie.cpp | 38 void SoftBusRunOneShotTask(const char *name, void (*task)(void), uint64_t delay) in SoftBusRunOneShotTask() argument 44 OHOS::HiviewDFX::Watchdog::GetInstance().RunOneShotTask(name, task, delay); in SoftBusRunOneShotTask() 47 void SoftBusRunPeriodicalTask(const char *name, void (*task)(void), uint64_t interval, uint64_t delay) in SoftBusRunPeriodicalTask() argument 53 OHOS::HiviewDFX::Watchdog::GetInstance().RunPeriodicalTask(name, task, interval, delay); in SoftBusRunPeriodicalTask()
|
/foundation/graphic/graphic_3d/lume/metaobject/src/ |
H A D | task_queue.h | 80 Token AddTaskImpl(ITaskQueueTask::Ptr p, const TimeSpan& delay, const TimeSpan& excTime) in AddTaskImpl() argument 90 tasks_.emplace_back(delay, excTime, BASE_NS::move(p)); in AddTaskImpl() 93 tasks_.emplace_back(delay, excTime, BASE_NS::move(p)); in AddTaskImpl() 95 tasks_.insert(tasks_.begin(), { delay, excTime, BASE_NS::move(p) }); in AddTaskImpl() 102 tasks_.insert(it + 1, { delay, excTime, BASE_NS::move(p) }); in AddTaskImpl() 109 tasks_.insert(tasks_.begin(), { delay, excTime, BASE_NS::move(p) }); in AddTaskImpl() 115 Token AddTask(ITaskQueueTask::Ptr p, const TimeSpan& delay, const TimeSpan& excTime) in AddTask() argument 119 return AddTaskImpl(BASE_NS::move(p), delay, excTime); in AddTask() 154 if (task.delay > TimeSpan()) { in ProcessTasks() 156 uint64_t dt = task.delay in ProcessTasks() 188 TimeSpan delay; global() member [all...] |
/foundation/multimodalinput/input/service/event_handler/test/ |
H A D | key_auto_repeat_test.cpp | 179 int32_t delay = 500; in HWTEST_F() local 181 int32_t result = keyAutoRepeat.SetKeyboardRepeatDelay(delay); in HWTEST_F() 183 delay = 100; in HWTEST_F() 184 result = keyAutoRepeat.SetKeyboardRepeatDelay(delay); in HWTEST_F() 186 delay = 2000; in HWTEST_F() 187 result = keyAutoRepeat.SetKeyboardRepeatDelay(delay); in HWTEST_F() 226 int32_t delay = 0; in HWTEST_F() local 228 EXPECT_EQ(keyAutoRepeat.GetKeyboardRepeatDelay(delay), RET_OK); in HWTEST_F() 229 EXPECT_EQ(delay, expectedDelay); in HWTEST_F() 230 delay in HWTEST_F() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
H A D | task_executor_adapter.cpp | 23 TaskExecutorAdapter::Duration delay) in Execute() 25 return TaskExecutor::GetInstance().Schedule(delay, task); in Execute() 33 TaskExecutorAdapter::Duration delay, TaskExecutorAdapter::Duration interval) in Schedule() 35 return TaskExecutor::GetInstance().Schedule(delay, task, interval); in Schedule() 38 TaskExecutorAdapter::Duration delay, TaskExecutorAdapter::Duration interval, uint64_t times) in Schedule() 40 return TaskExecutor::GetInstance().Schedule(delay, task, interval, times); in Schedule() 22 Execute(const TaskExecutorAdapter::Task &task, TaskExecutorAdapter::Duration delay) Execute() argument 32 Schedule(const TaskExecutorAdapter::Task &task, TaskExecutorAdapter::Duration delay, TaskExecutorAdapter::Duration interval) Schedule() argument 37 Schedule(const TaskExecutorAdapter::Task &task, TaskExecutorAdapter::Duration delay, TaskExecutorAdapter::Duration interval, uint64_t times) Schedule() argument
|
/foundation/distributeddatamgr/kv_store/frameworks/common/test/ |
H A D | priority_queue_test.cpp | 168 * @tc.desc: Test the delay task.
178 auto delay = std::chrono::milliseconds(SHORT_INTERVAL);
in HWTEST_F() local 180 auto ret = priorityqueue_.Push(testTask, id, std::chrono::steady_clock::now() + delay);
in HWTEST_F() 205 * @tc.desc: Test the delay task.
214 auto delay = std::chrono::milliseconds(SHORT_INTERVAL);
in HWTEST_F() local 216 auto ret = priorityqueue_.Push(testTask, id, std::chrono::steady_clock::now() + delay);
in HWTEST_F() 225 auto delayms = std::chrono::duration_cast<std::chrono::milliseconds>(delay).count();
in HWTEST_F() 283 auto delay = std::chrono::milliseconds(SHORT_INTERVAL);
in HWTEST_F() local 287 auto ret = priorityqueue_.Push(testTask, id, std::chrono::steady_clock::now() + delay);
in HWTEST_F() 303 auto delay in HWTEST_F() local 323 auto delay = std::chrono::milliseconds(SHORT_INTERVAL); HWTEST_F() local 344 auto delay = std::chrono::milliseconds(SHORT_INTERVAL); HWTEST_F() local 365 auto delay = std::chrono::milliseconds(SHORT_INTERVAL); HWTEST_F() local 387 auto delay = std::chrono::milliseconds(SHORT_INTERVAL); HWTEST_F() local 410 auto delay = std::chrono::milliseconds(SHORT_INTERVAL); HWTEST_F() local 430 auto delay = std::chrono::milliseconds(SHORT_INTERVAL); HWTEST_F() local 452 auto delay = std::chrono::milliseconds(SHORT_INTERVAL); HWTEST_F() local 519 auto delay = std::chrono::milliseconds(SHORT_INTERVAL); HWTEST_F() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
H A D | thread_pool_test_stub.cpp | 68 TaskId ThreadPoolTestStub::Execute(const Task &task, Duration delay) in Execute() argument 70 return Execute([task, delay]() { in Execute() 71 std::this_thread::sleep_for(delay); in Execute() 81 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval) in Schedule() argument 86 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) in Schedule() argument
|
H A D | thread_pool_test_stub.h | 32 TaskId Execute(const Task &task, Duration delay) 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;
|
/foundation/arkui/ace_engine/frameworks/component_test/ |
H A D | component_test_proxy.cpp | 31 std::function<void(void*)>&& task, std::function<void(void*)>&& onFinish, void* data, uint32_t delay) in PostUITask() 33 return GetCurrentComponentTestManager()->PostUITask(std::move(task), std::move(onFinish), data, delay); in PostUITask() 37 std::function<void(void*)>&& task, std::function<void(void*)>&& onFinish, void* data, uint32_t delay) in PostJSTask() 39 return GetCurrentComponentTestManager()->PostJSTask(std::move(task), std::move(onFinish), data, delay); in PostJSTask() 30 PostUITask( std::function<void(void*)>&& task, std::function<void(void*)>&& onFinish, void* data, uint32_t delay) PostUITask() argument 36 PostJSTask( std::function<void(void*)>&& task, std::function<void(void*)>&& onFinish, void* data, uint32_t delay) PostJSTask() argument
|
H A D | component_test_manager_impl.cpp | 76 std::function<void(void*)>&& task, std::function<void(void*)>&& onFinish, void* data, uint32_t delay) in PostUITask() 78 return testTaskScheduler_.PushTask(std::move(task), std::move(onFinish), TaskExecutor::TaskType::UI, data, delay); in PostUITask() 82 std::function<void(void*)>&& task, std::function<void(void*)>&& onFinish, void* data, uint32_t delay) in PostJSTask() 84 return testTaskScheduler_.PushTask(std::move(task), std::move(onFinish), TaskExecutor::TaskType::JS, data, delay); in PostJSTask() 75 PostUITask( std::function<void(void*)>&& task, std::function<void(void*)>&& onFinish, void* data, uint32_t delay) PostUITask() argument 81 PostJSTask( std::function<void(void*)>&& task, std::function<void(void*)>&& onFinish, void* data, uint32_t delay) PostJSTask() argument
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
H A D | ithread_pool.h | 33 virtual TaskId Execute(const Task &task, Duration delay) = 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 D | task_executor_adapter.h | 29 TaskId Execute(const Task &task, Duration delay) 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/kv_store/test/fuzztest/taskscheduler_fuzzer/ |
H A D | taskscheduler_fuzzer.cpp | 39 std::chrono::duration<int> delay(time % MAX_DELAY_TIME); in EveryFUZZ() 41 taskScheduler.Every(delay, interval, []() { }); in EveryFUZZ() 43 taskScheduler.Every(0, delay, interval, []() { }); in EveryFUZZ() 44 taskScheduler.Every(1, delay, interval, []() { }); in EveryFUZZ()
|
/foundation/multimodalinput/input/service/event_handler/src/ |
H A D | key_auto_repeat.cpp | 234 int32_t KeyAutoRepeat::SetKeyboardRepeatDelay(int32_t delay) in SetKeyboardRepeatDelay() argument 237 int32_t repeatDelayTime = delay; in SetKeyboardRepeatDelay() 238 if (delay < MIN_KEY_REPEAT_DELAY) { in SetKeyboardRepeatDelay() 241 if (delay > MAX_KEY_REPEAT_DELAY) { in SetKeyboardRepeatDelay() 246 MMI_HILOGE("Failed to set keyboard repeat delay"); in SetKeyboardRepeatDelay() 249 MMI_HILOGD("Set keyboard repeat delay:%{public}d", repeatDelayTime); in SetKeyboardRepeatDelay() 272 int32_t KeyAutoRepeat::GetKeyboardRepeatDelay(int32_t &delay) in GetKeyboardRepeatDelay() argument 276 if (GetConfigDataFromDatabase(name, delay) != RET_OK) { in GetKeyboardRepeatDelay() 277 MMI_HILOGE("Failed to get keyboard repeat delay"); in GetKeyboardRepeatDelay() 280 if (delay in GetKeyboardRepeatDelay() [all...] |
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
H A D | executor_pool.h | 87 TaskId Schedule(Duration delay, Task task) in Schedule() argument 89 return Schedule(std::move(task), delay, INVALID_INTERVAL, 1); in Schedule() 97 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule() argument 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() argument 109 return Schedule(std::move(innerTask), std::chrono::steady_clock::now() + delay); in Schedule() 115 auto delay = delayTasks_.Find(taskId); in Remove() local 116 if (!delay.Valid()) { in Remove() 161 TaskId Schedule(InnerTask innerTask, Time delay) in Schedule() argument 171 delayTasks_.Push(std::move(innerTask), id, delay); in Schedule() local [all...] |
/foundation/distributeddatamgr/preferences/frameworks/native/include/ |
H A D | executor_pool.h | 91 TaskId Schedule(Duration delay, Task task) in Schedule() argument 93 return Schedule(std::move(task), delay, INVALID_INTERVAL, 1); in Schedule() 101 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule() argument 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() argument 113 return Schedule(std::move(innerTask), std::chrono::steady_clock::now() + delay); in Schedule() 119 auto delay = delayTasks_.Find(taskId); in Remove() local 120 if (!delay.Valid()) { in Remove() 165 TaskId Schedule(InnerTask innerTask, Time delay) in Schedule() argument 175 delayTasks_.Push(std::move(innerTask), id, delay); in Schedule() local [all...] |
/foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/tabs/ |
H A D | tabs_controller.h | 23 using StartShowTabBarFunc = std::function<void(int32_t delay)>; 41 void StartShowTabBar(int32_t delay = 0) in StartShowTabBar() 44 startShowTabBarImpl_(delay); in StartShowTabBar()
|
/foundation/multimodalinput/input/test/fuzztest/setkeydownduration_fuzzer/ |
H A D | setkeydownduration_fuzzer.cpp | 59 int32_t delay; in SetKeyDownDurationFuzzTest() local 61 startPos += GetObject<int32_t>(delay, data + startPos, size - startPos); in SetKeyDownDurationFuzzTest() 62 InputManager::GetInstance()->SetKeyDownDuration(businessId, delay); in SetKeyDownDurationFuzzTest()
|
/foundation/resourceschedule/ffrt/test/ut/testcase/ |
H A D | ut_execute_unit.cpp | 58 ffrt::submit([&]() { x.fetch_add(2); }, {}, {}, ffrt::task_attr().delay(1)); in HWTEST_F() 60 auto h2 = ffrt::submit_h([&]() { x.fetch_add(4); }, {}, {}, ffrt::task_attr().delay(2)); in HWTEST_F() 72 auto h2 = ffrt::submit_h([&]() { x += 2; }, {&x}, {&x}, ffrt::task_attr().delay(1)); in HWTEST_F()
|
/foundation/communication/dsoftbus/adapter/common/include/ |
H A D | softbus_adapter_xcollie.h | 54 * @param delay Indicates delay a few millisecond to run the task. 59 void SoftBusRunOneShotTask(const char *name, void(*task)(void), uint64_t delay); 66 * @param delay Indicates delay a few millisecond to first run the task. 71 void SoftBusRunPeriodicalTask(const char *name, void(*task)(void), uint64_t interval, uint64_t delay);
|
/foundation/arkui/ace_engine/frameworks/bridge/cj_frontend/interfaces/cj_ffi/ |
H A D | cj_page_transition_ffi.cpp | 26 void FfiPageTransitionEnterCreate(int type, int duration, char* curve, int delay) in FfiPageTransitionEnterCreate() argument 28 PageTransitionOption option = {(RouteType)type, duration, delay, Framework::CreateCurve(std::string(curve))}; in FfiPageTransitionEnterCreate() 32 void FfiPageTransitionExitCreate(int type, int duration, char* curve, int delay) in FfiPageTransitionExitCreate() argument 35 static_cast<RouteType>(type), duration, delay, Framework::CreateCurve(std::string(curve))}; in FfiPageTransitionExitCreate()
|