Lines Matching refs:timer
469 auto whichAlarms = [id](const TimerInfo &timer) { in RemoveLocked() argument
470 return timer.id == id; in RemoveLocked()
489 [id](const std::shared_ptr<TimerInfo> &timer) { in RemoveLocked() argument
490 return timer->id == id; in RemoveLocked()
568 void TimerManager::ReAddTimerLocked(std::shared_ptr<TimerInfo> timer, in ReAddTimerLocked() argument
573 timer->uid, timer->id, timer->originWhenElapsed.time_since_epoch().count(), in ReAddTimerLocked()
574 timer->whenElapsed.time_since_epoch().count(), GetBootTimeNs().time_since_epoch().count()); in ReAddTimerLocked()
575 auto whenElapsed = ConvertToElapsed(timer->when, timer->type); in ReAddTimerLocked()
577 if (timer->windowLength == milliseconds::zero()) { in ReAddTimerLocked()
580 maxElapsed = (timer->windowLength > milliseconds::zero()) ? in ReAddTimerLocked()
581 (whenElapsed + timer->windowLength) : in ReAddTimerLocked()
582 MaxTriggerTime(nowElapsed, whenElapsed, timer->repeatInterval); in ReAddTimerLocked()
584 timer->whenElapsed = whenElapsed; in ReAddTimerLocked()
585 timer->maxWhenElapsed = maxElapsed; in ReAddTimerLocked()
586 SetHandlerLocked(timer, true, true); in ReAddTimerLocked()
857 void TimerManager::NotifyWantAgentRetry(std::shared_ptr<TimerInfo> timer) in NotifyWantAgentRetry() argument
859 auto retryRegister = [timer]() { in NotifyWantAgentRetry()
862 if (TimerManager::GetInstance()->NotifyWantAgent(timer)) { in NotifyWantAgentRetry()
871 int32_t TimerManager::CheckUserIdForNotify(const std::shared_ptr<TimerInfo> &timer) in CheckUserIdForNotify() argument
875 …int getLocalIdErr = AccountSA::OsAccountManager::GetOsAccountLocalIdFromUid(timer->uid, userIdOfTi… in CheckUserIdForNotify()
889 timer->uid, timer->id); in CheckUserIdForNotify()
896 …ms = std::count_if(triggerList.begin(), triggerList.end(), [](auto timer) {return timer->wakeup;}); in DeliverTimersLocked() argument
897 for (const auto &timer : triggerList) { in DeliverTimersLocked() local
898 if (timer->wakeup) { in DeliverTimersLocked()
901 timer->id, timer->uid, timer->bundleName.c_str()); in DeliverTimersLocked()
904 StatisticReporter(IPCSkeleton::GetCallingPid(), wakeupNums, timer); in DeliverTimersLocked()
906 if (timer->callback) { in DeliverTimersLocked()
907 if (TimerProxy::GetInstance().CallbackAlarmIfNeed(timer) == PEER_END_DEAD in DeliverTimersLocked()
908 && !timer->wantAgent) { in DeliverTimersLocked()
909 DestroyTimer(timer->id); in DeliverTimersLocked()
913 if (timer->wantAgent) { in DeliverTimersLocked()
914 … if (!NotifyWantAgent(timer) && CheckNeedRecoverOnReboot(timer->bundleName, timer->type)) { in DeliverTimersLocked()
915 NotifyWantAgentRetry(timer); in DeliverTimersLocked()
917 if (CheckNeedRecoverOnReboot(timer->bundleName, timer->type)) { in DeliverTimersLocked()
923 ->EqualTo("timerId", static_cast<int64_t>(timer->id)); in DeliverTimersLocked()
931 ->EqualTo("timerId", static_cast<int64_t>(timer->id)); in DeliverTimersLocked()
935 if (((timer->flags & static_cast<uint32_t>(IS_DISPOSABLE)) > 0) && in DeliverTimersLocked()
936 (timer->repeatInterval == milliseconds::zero())) { in DeliverTimersLocked()
937 DestroyTimer(timer->id); in DeliverTimersLocked()
942 bool TimerManager::NotifyWantAgent(const std::shared_ptr<TimerInfo> &timer) in NotifyWantAgent() argument
945 auto wantAgent = timer->wantAgent; in NotifyWantAgent()
948 switch (CheckUserIdForNotify(timer)) { in NotifyWantAgent()
953 … TIME_HILOGE(TIME_MODULE_SERVICE, "want is nullptr, id=%{public}" PRId64 "", timer->id); in NotifyWantAgent()
960 holdRdbPredicates.EqualTo("timerId", static_cast<int64_t>(timer->id)); in NotifyWantAgent()
972 switch (CheckUserIdForNotify(timer)) { in NotifyWantAgent()
974 … TIME_HILOGI(TIME_MODULE_SERVICE, "user sw after FS, id=%{public}" PRId64 "", timer->id); in NotifyWantAgent()
978 … TIME_HILOGE(TIME_MODULE_SERVICE, "want is nullptr, id=%{public}" PRId64 "", timer->id); in NotifyWantAgent()
985 TIME_HILOGE(TIME_MODULE_SERVICE, "want is nullptr, id=%{public}" PRId64 "", timer->id); in NotifyWantAgent()
1030 auto timer = batch->Get(i); in AdjustTimer() local
1031 ReCalcuOriWhenElapsed(timer, nowElapsed); in AdjustTimer()
1032 isChanged = adjustTimer(timer) || isChanged; in AdjustTimer()
1057 void TimerManager::ReCalcuOriWhenElapsed(std::shared_ptr<TimerInfo> timer, in ReCalcuOriWhenElapsed() argument
1063 auto whenElapsed = ConvertToElapsed(timer->origWhen, timer->type); in ReCalcuOriWhenElapsed()
1065 if (timer->windowLength == milliseconds::zero()) { in ReCalcuOriWhenElapsed()
1068 maxElapsed = (timer->windowLength > milliseconds::zero()) ? in ReCalcuOriWhenElapsed()
1069 (whenElapsed + timer->windowLength) : in ReCalcuOriWhenElapsed()
1070 MaxTriggerTime(nowElapsed, whenElapsed, timer->repeatInterval); in ReCalcuOriWhenElapsed()
1072 timer->originWhenElapsed = whenElapsed; in ReCalcuOriWhenElapsed()
1073 timer->originMaxWhenElapsed = maxElapsed; in ReCalcuOriWhenElapsed()
1082 bool TimerManager::AdjustSingleTimer(std::shared_ptr<TimerInfo> timer) in AdjustSingleTimer() argument
1088 [this, timer] (AdjustTimerCallback adjustTimer) { adjustTimer(timer); }); in AdjustSingleTimer()
1315 const std::shared_ptr<TimerInfo> &timer, std::chrono::steady_clock::time_point nowElapsed) in HandleRepeatTimer() argument
1317 if (timer->repeatInterval > milliseconds::zero()) { in HandleRepeatTimer()
1319 duration_cast<milliseconds>(nowElapsed - timer->whenElapsed) / timer->repeatInterval); in HandleRepeatTimer()
1320 auto delta = count * timer->repeatInterval; in HandleRepeatTimer()
1321 auto nextElapsed = timer->whenElapsed + delta; in HandleRepeatTimer()
1322 … SetHandlerLocked(timer->id, timer->type, timer->when + delta, nextElapsed, timer->windowLength, in HandleRepeatTimer()
1323 …MaxTriggerTime(nowElapsed, nextElapsed, timer->repeatInterval), timer->repeatInterval, timer->call… in HandleRepeatTimer()
1324 timer->wantAgent, timer->flags, timer->uid, timer->pid, timer->bundleName); in HandleRepeatTimer()
1326 TimerProxy::GetInstance().RemoveUidTimerMap(timer); in HandleRepeatTimer()
1327 TimerProxy::GetInstance().RemovePidTimerMap(timer); in HandleRepeatTimer()