| /foundation/systemabilitymgr/samgr/services/samgr/native/source/collect/ |
| D | device_timed_collect.cpp | 55 int32_t interval = atoi(onDemandEvent.value.c_str()); in SaveTimedEvent() local 56 if (interval >= MIN_INTERVAL) { in SaveTimedEvent() 57 timedSet_.insert(interval); in SaveTimedEvent() 59 HILOGE("DeviceTimedCollect invalid interval %{public}s", onDemandEvent.value.c_str()); in SaveTimedEvent() 64 void DeviceTimedCollect::PostLoopTaskLocked(int32_t interval) in PostLoopTaskLocked() argument 66 if (loopTasks_.count(interval) > 0) { in PostLoopTaskLocked() 67 HILOGE("DeviceTimedCollect interval has been post"); in PostLoopTaskLocked() 70 loopTasks_[interval] = [this, interval] () { in PostLoopTaskLocked() 71 OnDemandEvent event = { TIMED_EVENT, LOOP_EVENT, to_string(interval) }; in PostLoopTaskLocked() 72 HILOGI("DeviceTimedCollect ReportEvent interval: %{public}d", interval); in PostLoopTaskLocked() [all …]
|
| /foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/ |
| D | deadline.h | 20 using interval = ffrt_interval_t; variable 23 @brief app create an anonymous interval, the number is limited. should specify the deadline 25 static inline interval qos_interval_create(uint64_t deadline_us, qos qos_ = static_cast<int>(qos_de… 31 @brief destroy a interval 33 static inline void qos_interval_destroy(interval it) in qos_interval_destroy() 39 @brief start the interval 41 static inline int qos_interval_begin(interval it) in qos_interval_begin() 47 @brief update interval 49 static inline int qos_interval_update(interval it, uint64_t deadline_us) in qos_interval_update() 55 @brief interval become inactive until next begin [all …]
|
| /foundation/resourceschedule/ffrt/test/ut/ |
| D | deadline_test.cpp | 20 #include "sched/interval.h" 58 interval qi = qos_interval_create(deadline_us, qos); 62 interval qi1 = qos_interval_create(deadline_us, qos); 73 interval* qi = new interval(); 79 interval qi1 = qos_interval_create(deadline_us, qos); 90 interval* qi = new interval(); 96 interval qi1 = qos_interval_create(deadline_us, qos); 110 interval* qi = new interval(); 113 interval qi1 = qos_interval_create(deadline_us, qos); 126 interval* qi = new interval(); [all …]
|
| /foundation/communication/wifi/wifi/frameworks/native/interfaces/ |
| D | wifi_scan_msg.h | 181 * The interval is set to 120 and the count is set to 4. 182 * For example, the interval is set to 120 and the count is set to 4. 185 * Exponential interval. The value of interval is the initial value. 186 * After the value is multiplied by 2, the last fixed interval is used. 189 * If the number of consecutive count times is less than interval, 190 * the subsequent interval must be greater than interval. 193 … * If the number of consecutive count times is less than the value of interval, 200 IntervalMode intervalMode; /* Interval mode, which can be interval or count. */ 201 int interval; /* Interval, in seconds. */ member 202 int count; /* Number of times allowed in the interval */ [all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/common/ |
| D | task_scheduler.h | 63 …TaskId At(const Time &begin, Task task, Duration interval = INVALID_INTERVAL, uint64_t times = UNL… 72 innerTask.interval = interval; 81 TaskId Reset(TaskId taskId, const Duration &interval) in Reset() argument 84 if (running_.taskId == taskId && running_.interval != INVALID_INTERVAL) { in Reset() 85 running_.interval = interval; in Reset() 93 if (innerTask.interval != INVALID_INTERVAL) { in Reset() 94 innerTask.interval = interval; in Reset() 96 … auto it = tasks_.insert({ std::chrono::steady_clock::now() + interval, std::move(innerTask) }); in Reset() 111 TaskId Every(Duration interval, Task task) in Every() argument 113 return At(std::chrono::steady_clock::now() + interval, task, interval); in Every() [all …]
|
| D | executor_pool.h | 92 TaskId Schedule(Task task, Duration interval) in Schedule() argument 94 return Schedule(std::move(task), INVALID_DELAY, interval, UNLIMITED_TIMES); 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 106 innerTask.interval = interval; in Schedule() 126 TaskId Reset(TaskId taskId, Duration interval) in Reset() argument 128 … auto updated = delayTasks_.Update(taskId, [interval](InnerTask &task) -> std::pair<bool, Time> { in Reset() 129 if (task.interval != INVALID_INTERVAL) { in Reset() 130 task.interval = interval; in Reset() [all …]
|
| D | block_data.h | 24 …explicit BlockData(uint32_t interval, const T &invalid = T()) : INTERVAL(interval), data_(invalid)… in INTERVAL() function 40 cv_.wait_for(lock, std::chrono::seconds(INTERVAL), [this]() { in GetValue() 58 const uint32_t INTERVAL; variable
|
| /foundation/resourceschedule/ffrt/src/sched/ |
| D | deadline.cpp | 19 #include "sched/interval.h" 31 it = std::unique_ptr<Interval>(new (std::nothrow) FrameInterval(deadlineUs, qos)); in qos_interval_private_t() 33 it = std::unique_ptr<Interval>(new (std::nothrow) DefaultInterval(deadlineUs, qos)); in qos_interval_private_t() 37 Interval* operator->() in operator ->() 43 std::unique_ptr<Interval> it; 54 FFRT_LOGE("Invalid QoS Interval!"); in ffrt_interval_create() 65 FFRT_LOGE("QoS Interval Not Created Or Has Been Canceled!"); in ffrt_interval_update() 79 FFRT_LOGE("QoS Interval Not Created Or Has Been Canceled!"); in ffrt_interval_begin() 92 FFRT_LOGE("QoS Interval Not Created Or Has Been Canceled!"); in ffrt_interval_end() 106 FFRT_LOGE("QoS Interval Not Created Or Has Been Canceled!"); in ffrt_interval_destroy() [all …]
|
| D | multi_workgroup.cpp | 42 FFRT_LOGE("[WorkGroup] interval is unavailable"); in JoinWG() 70 FFRT_LOGE("[WorkGroup] start rtg(%{public}d) work interval failed", wg->rtgId); in WorkgroupStartInterval() 90 FFRT_LOGE("[WorkGroup] stop rtg(%{public}d) work interval failed", wg->rtgId); in WorkgroupStopInterval() 94 static void WorkgroupInit(struct Workgroup* wg, uint64_t interval, int rtgId) in WorkgroupInit() argument 97 wg->interval = interval; in WorkgroupInit() 106 struct Workgroup* WorkgroupCreate(uint64_t interval) in WorkgroupCreate() argument 136 WorkgroupInit(wg, interval, rtgId); in WorkgroupCreate()
|
| D | frame_interval.cpp | 24 FrameInterval::FrameInterval(uint64_t deadline, const QoS& qos) : Interval(deadline, qos), qos(qos) in FrameInterval() 48 FFRT_LOGE("[Error] Interval's workgroup is null in %s", __func__); in OnQoSIntervals() 61 FFRT_LOGD("[Error] Interval is already begun"); in Begin() 73 FFRT_LOGD("[Error] Interval is already end"); in End() 83 FFRT_LOGD("[Error] Interval has no workgroup"); in Join()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| D | task_manager.cpp | 34 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration interval) in Schedule() argument 36 return executors_->Schedule(task, interval); in Schedule() 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, uint… in Schedule() argument 44 return executors_->Schedule(task, delay, interval, times); in Schedule() 50 TaskManager::TaskId TaskManager::Reset(const TaskId &taskId, Duration interval) in Reset() argument 52 return executors_->Reset(taskId, interval); in Reset()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| D | task_executor_adapter.cpp | 28 TaskExecutorAdapter::Duration interval) in Schedule() argument 30 return TaskExecutor::GetInstance().Schedule(TaskExecutor::INVALID_DURATION, task, interval); in Schedule() 33 TaskExecutorAdapter::Duration delay, TaskExecutorAdapter::Duration interval) in Schedule() argument 35 return TaskExecutor::GetInstance().Schedule(delay, task, interval); in Schedule() 38 TaskExecutorAdapter::Duration delay, TaskExecutorAdapter::Duration interval, uint64_t times) in Schedule() argument 40 return TaskExecutor::GetInstance().Schedule(delay, task, interval, times); in Schedule() 48 TaskExecutorAdapter::Duration interval) in Reset() argument 50 return TaskExecutor::GetInstance().Reset(taskId, interval); in Reset()
|
| D | task_executor.cpp | 43 TaskExecutor::TaskId TaskExecutor::Schedule(Duration delay, const Task &task, Duration interval, ui… in Schedule() argument 48 return pool_->Schedule(task, delay, interval, times); in Schedule() 59 TaskExecutor::TaskId TaskExecutor::Reset(TaskExecutor::TaskId taskId, Duration interval) in Reset() argument 64 return pool_->Reset(taskId, interval); in Reset()
|
| /foundation/resourceschedule/device_standby/services/common/src/ |
| D | timed_task.cpp | 31 TimedTask::TimedTask(bool repeat, uint64_t interval, bool isExact, bool isIdle) in TimedTask() argument 34 this->interval = interval; in TimedTask() 67 void TimedTask::SetInterval(const uint64_t& interval) in SetInterval() argument 69 this->interval = interval; in SetInterval() 82 uint64_t WEAK_FUNC TimedTask::CreateTimer(bool repeat, uint64_t interval, bool isExact, bool isIdle, in CreateTimer() argument 85 auto timedTask = std::make_shared<TimedTask>(repeat, interval, isExact, isIdle); in CreateTimer() 107 … WEAK_FUNC TimedTask::RegisterDayNightSwitchTimer(uint64_t& timeId, bool repeat, uint64_t interval, in RegisterDayNightSwitchTimer() argument 110 timeId = CreateTimer(repeat, interval, false, false, callBack); in RegisterDayNightSwitchTimer()
|
| /foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| D | executor_pool.h | 96 TaskId Schedule(Task task, Duration interval) in Schedule() argument 98 return Schedule(std::move(task), INVALID_DELAY, interval, UNLIMITED_TIMES); 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 110 innerTask.interval = interval; in Schedule() 130 TaskId Reset(TaskId taskId, Duration interval) in Reset() argument 132 … auto updated = delayTasks_.Update(taskId, [interval](InnerTask &task) -> std::pair<bool, Time> { in Reset() 133 if (task.interval != INVALID_INTERVAL) { in Reset() 134 task.interval = interval; in Reset() [all …]
|
| /foundation/distributeddatamgr/kv_store/test/fuzztest/taskscheduler_fuzzer/ |
| D | taskscheduler_fuzzer.cpp | 40 std::chrono::duration<int> interval(time % MAX_INTERVAL_TIME); in EveryFUZZ() local 41 taskScheduler.Every(delay, interval, []() { }); in EveryFUZZ() 43 taskScheduler.Every(0, delay, interval, []() { }); in EveryFUZZ() 44 taskScheduler.Every(1, delay, interval, []() { }); in EveryFUZZ() 46 taskScheduler.Every(interval, []() { }); in EveryFUZZ() 53 std::chrono::duration<int> interval(time % MAX_INTERVAL_TIME); in ResetFuzz() local 57 taskScheduler.Reset(schedulerTask, interval); in ResetFuzz()
|
| /foundation/bundlemanager/bundle_framework/services/bundlemgr/src/aot/ |
| D | aot_loop_task.cpp | 30 const std::string AOT_INTERVAL = "bms.aot.idle.interval"; 37 uint32_t interval = EIGHT_HOURS_MS; in GetAOTIdleInterval() local 41 interval = static_cast<uint32_t>(std::stoi(str)); in GetAOTIdleInterval() 46 APP_LOGI("aot idle interval ms : %{public}u", interval); in GetAOTIdleInterval() 47 return interval; in GetAOTIdleInterval()
|
| /foundation/arkui/ui_lite/interfaces/kits/components/ |
| D | ui_repeat_button.h | 82 * @brief Sets the interval between two consecutive click events. 84 * @param interval Indicates the interval to set. 89 virtual void SetInterval(uint16_t interval) in SetInterval() argument 91 ticksInterval_ = interval; in SetInterval() 95 * @brief Obtains the interval between two consecutive click events. 97 * @return Returns the interval between two consecutive click events.
|
| /foundation/arkui/ui_lite/frameworks/layout/ |
| D | flex_layout.cpp | 37 int16_t& interval, in GetStartPos() argument 46 interval = 0; in GetStartPos() 60 interval = (length - validLengths[count]) / childsNum[count]; in GetStartPos() 61 pos = interval / 2; // 2: half in GetStartPos() 63 interval = (length - validLengths[count]) / (childsNum[count] + 1); in GetStartPos() 64 pos = interval; in GetStartPos() 66 interval = (length - validLengths[count]) / (childsNum[count] - 1); in GetStartPos() 71 void FlexLayout::GetNoWrapStartPos(const int16_t& length, int16_t& majorPos, int16_t& interval) in GetNoWrapStartPos() argument 77 GetStartPos(length, majorPos, interval, 0, &totalValidLength, &childrenNum); in GetNoWrapStartPos() 81 int16_t& interval, in GetRowStartPos() argument [all …]
|
| /foundation/communication/bluetooth/interfaces/inner_api/include/ |
| D | bluetooth_opp.h | 162 * @param interval Id. 170 * @param interval File Name. 178 * @param interval File Path. 186 * @param interval Mime Type. 194 * @param interval Device Name. 202 * @param interval Device Address. 210 * @param interval Direction. 218 * @param interval Status. 226 * @param interval Failed Reason. 234 * @param interval Time Stamp. [all …]
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
| D | fillp_timer.c | 130 "total_recvd_count: %u recv rate: %u pack input interval: %lld", in FillpCalRecvRate() 203 …FILLP_LOGDBG("enable, pcb->send.flowControl.sendTime:%lld, interval:%u", pcb->send.flowControl.sen… in FillpEnableSendTimer() 204 pcb->sendTimerNode.interval); in FillpEnableSendTimer() 210 pcb->send.flowControl.sendTime + pcb->sendTimerNode.interval); in FillpEnableSendTimer() 212 pcb->send.flowControl.sendTime + pcb->sendTimerNode.interval, &pcb->sendTimerNode); in FillpEnableSendTimer() 226 pcb->packTimerNode.interval); in FillpEnablePackTimer() 228 pcb->packTimerNode.interval + pcb->pcbInst->curTime, &pcb->packTimerNode); in FillpEnablePackTimer() 243 pcb->FcTimerNode.interval + pcb->pcbInst->curTime, &pcb->FcTimerNode); in FillpEnableFcTimer() 257 pcb->keepAliveTimerNode.interval + pcb->pcbInst->curTime, &pcb->keepAliveTimerNode); in FillpEnableKeepAliveTimer() 271 FILLP_LOGDBG("Delay NACK Timer Enable: curTime:%lld, interval:%u", pcb->pcbInst->curTime, in FillpEnableDelayNackTimer() [all …]
|
| /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; 34 TaskId Reset(const TaskId &taskId, Duration interval) override;
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| 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; 42 TaskId Reset(const TaskId &taskId, Duration interval) override;
|
| /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; 43 virtual TaskId Reset(const TaskId &taskId, Duration interval) = 0;
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/include/common/ |
| D | block_object.h | 23 …explicit BlockObject(uint32_t interval, const T &invalid = T()) : interval_(interval), data_(inval… in interval_() argument 46 void SetInterval(uint32_t interval) in SetInterval() argument 48 interval_ = interval; in SetInterval()
|