/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()
|
/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/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/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/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
|
/test/xts/acts/arkui/ace_c_arkui_test/entry/src/main/cpp/stack/ |
H A D | stack_transition_test.cpp | 93 int32_t delay = 500; in TestStackTransition006() local 99 {.i32 = delay}, {.i32 = iterations}, {.i32 = playMode}, in TestStackTransition006() 109 ASSERT_NE(nodeAPI->getAttribute(stack, NODE_OPACITY_TRANSITION)->value[PARAM_3].i32, delay); in TestStackTransition006() 123 int32_t delay = 0; in TestStackTransition007() local 129 {.i32 = delay}, {.i32 = iterations}, {.i32 = playMode}, in TestStackTransition007() 138 ASSERT_EQ(nodeAPI->getAttribute(stack, NODE_OPACITY_TRANSITION)->value[PARAM_3].i32, delay); in TestStackTransition007() 151 int32_t delay = 0; in TestStackTransition008() local 157 {.i32 = delay}, {.i32 = iterations}, {.i32 = playMode}, in TestStackTransition008() 166 ASSERT_EQ(nodeAPI->getAttribute(stack, NODE_OPACITY_TRANSITION)->value[PARAM_3].i32, delay); in TestStackTransition008() 179 int32_t delay in TestStackTransition009() local 207 int32_t delay = 0; TestStackTransition010() local 235 int32_t delay = 0; TestStackTransition011() local 263 int32_t delay = 0; TestStackTransition012() local 291 int32_t delay = 0; TestStackTransition013() local 319 int32_t delay = 0; TestStackTransition014() local 347 int32_t delay = 0; TestStackTransition015() local 375 int32_t delay = 300; TestStackTransition016() local 403 int32_t delay = -300; TestStackTransition017() local 431 int32_t delay = -1300; TestStackTransition018() local 459 int32_t delay = 0; TestStackTransition019() local 489 int32_t delay = 0; TestStackTransition020() local 523 int32_t delay = 500; TestStackTransition021() local 561 int32_t delay = 0; TestStackTransition022() local 597 int32_t delay = 0; TestStackTransition023() local 633 int32_t delay = 0; TestStackTransition024() local 669 int32_t delay = 0; TestStackTransition025() local 705 int32_t delay = 0; TestStackTransition026() local 741 int32_t delay = 0; TestStackTransition027() local 777 int32_t delay = 0; TestStackTransition028() local 813 int32_t delay = 0; TestStackTransition029() local 849 int32_t delay = 0; TestStackTransition030() local 885 int32_t delay = 300; TestStackTransition031() local 921 int32_t delay = -300; TestStackTransition032() local 957 int32_t delay = -1300; TestStackTransition033() local 993 int32_t delay = 0; TestStackTransition034() local 1031 int32_t delay = 0; TestStackTransition035() local 1067 int32_t delay = 500; TestStackTransition036() local 1101 int32_t delay = 0; TestStackTransition037() local 1133 int32_t delay = 0; TestStackTransition038() local 1165 int32_t delay = 0; TestStackTransition039() local 1197 int32_t delay = 0; TestStackTransition040() local 1229 int32_t delay = 0; TestStackTransition041() local 1261 int32_t delay = 0; TestStackTransition042() local 1293 int32_t delay = 0; TestStackTransition043() local 1325 int32_t delay = 0; TestStackTransition044() local 1357 int32_t delay = 0; TestStackTransition045() local 1389 int32_t delay = 300; TestStackTransition046() local 1421 int32_t delay = -300; TestStackTransition047() local 1453 int32_t delay = -1300; TestStackTransition048() local 1485 int32_t delay = 0; TestStackTransition049() local 1519 int32_t delay = 0; TestStackTransition050() local 1553 int32_t delay = 500; TestStackTransition051() local 1587 int32_t delay = 0; TestStackTransition052() local 1619 int32_t delay = 0; TestStackTransition053() local 1651 int32_t delay = 0; TestStackTransition054() local 1683 int32_t delay = 0; TestStackTransition055() local 1715 int32_t delay = 0; TestStackTransition056() local 1747 int32_t delay = 0; TestStackTransition057() local 1779 int32_t delay = 0; TestStackTransition058() local 1811 int32_t delay = 0; TestStackTransition059() local 1843 int32_t delay = 0; TestStackTransition060() local 1875 int32_t delay = 300; TestStackTransition061() local 1907 int32_t delay = -300; TestStackTransition062() local 1939 int32_t delay = -1300; TestStackTransition063() local 1971 int32_t delay = 0; TestStackTransition064() local 2005 int32_t delay = 0; TestStackTransition065() local [all...] |
/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
|
/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;
|
/base/hiviewdfx/hicollie/frameworks/native/ |
H A D | watchdog.cpp | 41 void Watchdog::RunOneShotTask(const std::string& name, Task&& task, uint64_t delay) in RunOneShotTask() argument 43 return WatchdogInner::GetInstance().RunOneShotTask(name, std::move(task), delay); in RunOneShotTask() 46 void Watchdog::RunPeriodicalTask(const std::string& name, Task&& task, uint64_t interval, uint64_t delay) in RunPeriodicalTask() argument 48 return WatchdogInner::GetInstance().RunPeriodicalTask(name, std::move(task), interval, delay); in RunPeriodicalTask()
|
/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...] |
/base/hiviewdfx/hiview/base/ |
H A D | plugin.cpp | 86 void Plugin::DelayProcessEvent(std::shared_ptr<Event> event, uint64_t delay)
in DelayProcessEvent() argument 92 UpdateTimeByDelay(delay);
in DelayProcessEvent() 95 workLoop_->AddTimerEvent(nullptr, nullptr, task, delay, false);
in DelayProcessEvent() 154 void Plugin::UpdateTimeByDelay(time_t delay)
in UpdateTimeByDelay() argument 156 lastActiveTime_ = time(nullptr) + delay;
in UpdateTimeByDelay()
|
/base/powermgr/power_manager/services/native/src/suspend/ |
H A D | suspend_controller.cpp | 158 monitor->RegisterListener([this](SuspendDeviceType reason, uint32_t action, uint32_t delay) { in Init() 159 this->ControlListener(reason, action, delay); in Init() 224 monitor->RegisterListener([this](SuspendDeviceType reason, uint32_t action, uint32_t delay) { in UpdateSuspendSources() 225 this->ControlListener(reason, action, delay); in UpdateSuspendSources() 377 void SuspendController::SuspendWhenScreenOff(SuspendDeviceType reason, uint32_t action, uint32_t delay) in RegisterSettingsObserver() argument 389 "delay=%{public}u, state=%{public}d, type=%{public}u", in RegisterSettingsObserver() 390 reason, action, delay, stateMachine_->GetState(), sleepType_); in RegisterSettingsObserver() 394 StartSleepTimer(reason, action, delay); in RegisterSettingsObserver() 419 void SuspendController::ControlListener(SuspendDeviceType reason, uint32_t action, uint32_t delay) in RegisterSettingsObserver() argument 436 SuspendWhenScreenOff(reason, action, delay); in RegisterSettingsObserver() 517 StartSleepTimer(SuspendDeviceType reason, uint32_t action, uint32_t delay) RegisterSettingsObserver() argument [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()
|